| ConcurrentDoublyLinkedList<E> |
A concurrent linked-list implementation of a Deque (double-ended
queue).
|
| DebugUtil |
|
| LogDeferDocId |
|
| LogDeferThrowable |
|
| MonoBridge<T> |
Protects against concurrent op cancellation.
|
| QueryUtil |
|
| ReactiveLock |
A mutex pessimistic lock, compatible with reactive.
|
| ReactiveLock.Waiter |
|
| ReactiveWaitGroup |
Provides locking functionality in line with Go's WaitGroups, in a reactive compatible way.
|
| ReactiveWaitGroup.Waiter |
|
| SchedulerUtil |
|
| TestAttemptContextFactory |
Can be used for testing transactions, but is for internal use only.
|
| TestAttemptContextReactive |
Can be used for testing transactions, but is for internal use only.
|
| TransactionMock |
Can be used for testing transactions, but is for internal use only.
|