| Modifier and Type | Method and Description |
|---|---|
| public void | delete(CacheEntry
the cache entry for which a delete operation will be added to the write behind queue entry)Add a delete operation for the given cache entry |
| public long | Returns: the amount of elements still awaiting processing.Gets the best estimate for items in the queue still awaiting processing. |
| public void | setOperationsFilter(OperationsFilter<T>
the filter that will be used as of now filter)Set the operations filter that should be used. |
| public void | start(CacheWriter
the cache writer that should be used to process the operations writer)Start the write behind queue with a cache writer |
| public void | |
| public void |
| delete | back to summary |
|---|---|
| public void delete(CacheEntry entry) Add a delete operation for the given cache entry
| |
| getQueueSize | back to summary |
|---|---|
| public long getQueueSize() Gets the best estimate for items in the queue still awaiting processing. Not including elements currently processed
| |
| setOperationsFilter | back to summary |
|---|---|
| public void setOperationsFilter(OperationsFilter<T> filter) Set the operations filter that should be used.
| |
| start | back to summary |
|---|---|
| public void start(CacheWriter writer) throws CacheException Start the write behind queue with a cache writer
| |
| stop | back to summary |
|---|---|
| public void stop() throws CacheException Stop the coordinator and all the internal data structures. This stops as quickly as possible without losing any previously added items. However, no guarantees are made towards the processing of these items. It's highly likely that items are still inside the internal data structures and not processed.
| |
| write | back to summary |
|---|---|
| public void write(Element element) Add a write operation for a given element.
| |