|
Class Summary |
| AtomicCounter |
Defines a simple "atomic counter" that allows clients to increment the
encapsulated sequence number and wait synchronously until particular values
are reached. |
| AtomicIntervalGuard<D> |
Tracks the sequence number and time interval between a group of tasks
processing transactions to ensure that the first and last tasks do not get
too far apart in the log. |
| EventIdWatchPredicate |
Implements a WatchPredicate to identify that a particular native event ID has
been reached. |
| HeartbeatWatchPredicate |
Implements a WatchPredicate that returns true when we see an event that is
marked as a heartbeat. |
| ProcessHelper |
Implements a simple helper to execute operating system processes with
consistent logging and handling of errors. |
| SeqnoWatchPredicate |
Implements a WatchPredicate to identify that a particular sequence number has
been reached. |
| SourceTimestampWatchPredicate |
Implements a WatchPredicate to identify that a particular sequence number has
been reached. |
| Watch<E> |
Implements a "watch" operation that waits for a predicate to be fulfilled on
a particular event in an event processing queue. |
| WatchManager<E> |
Manages a list of event watches and allows clients to submit events to the
list for processing to see if there is a predicate match. |