AbstractWork |
A base implementation for a Work instance, dealing with most of the details around state change.
|
BaseOverflowRecordFilter |
Base for filter that saves long record's value in an alternate storage.
|
KeyValueStoreOverflowRecordFilter |
Filter that use a KeyValueStore to pass big record value
|
MemoryBlockingQueue |
|
MemoryWorkQueuing |
Implementation of a WorkQueuing using in-memory queuing.
|
NuxeoBlockingQueue |
|
SleepWork |
Simple work that just sleeps, mostly used for tests.
|
StreamWorkManager |
WorkManager impl that appends works into a Log.
|
WorkComputation |
A Stream computation that consumes works.
|
WorkHolder |
|
WorkManagerImpl |
|
WorkManagerImpl.WorkCompletionSynchronizer |
Simple synchronizer to wake up when an in-JVM work is completed.
|
WorkStateHelper |
Work state helper to handle, out-of-API, distributed, work states.
|