@CheckReturnValue @ParametersAreNonnullByDefault
See: Description
| Interface | Description |
|---|---|
| BatchDeliveryListener<I> |
Listens to start and end of the
Inbox batch delivery. |
| CatchUpProcess.DispatchCatchingUp<I> |
A method object dispatching the event to catch-up.
|
| CatchUpSignal |
A marker interface for the signals controlling the execution of catch-up processes.
|
| CatchUpStorage |
A storage for the state of the ongoing catch-up processes.
|
| CommandEndpoint<I> |
An endpoint which accepts commands.
|
| EventEndpoint<I> |
An endpoint which accepts events.
|
| InboxStorage |
A contract for storages of
Inbox messages. |
| Page<M> |
A page of messages obtained from a sharded storage in a read operation.
|
| RepositoryLookup<I> |
A function that searches for the
ProjectionRepository instance by the type URL
of the state of the managed projection. |
| ShardedWorkRegistry |
The registry of the shard indexes along with the identifiers of the nodes, which
process the messages corresponding to each index.
|
| ShardObserver |
An abstract base for observers of the updates made to the contents of shards.
|
| Class | Description |
|---|---|
| AbstractWorkRegistry |
An implementation base for
ShardedWorkRegistries based on a specific
persistence mechanism. |
| CatchUpProcess<I> |
A process that performs a projection catch-up.
|
| CatchUpProcessBuilder<I> |
A builder for
CatchUpProcess. |
| CatchUpReadRequest |
A request to read the state of
CatchUp from the storage. |
| Delivery |
Delivers the messages to the entities.
|
| DeliveryBuilder |
A builder for
Delivery instances. |
| DeliveryMonitor |
A controlling monitor of a
Inbox Delivery process. |
| DeliveryStats |
The statistics on delivering the messages
from a certain shard.
|
| DeliveryStrategy |
Determines the index of a shard for the given identifier of an entity.
|
| Inbox.Builder<I> |
A builder of
Inbox instances. |
| InboxReadRequest |
A request to read a certain
InboxMessage by its ID. |
| LocalDispatchingObserver |
An observer of changes to the shard contents, which triggers immediate delivery of the
sharded messages.
|
| ShardProcessingSession |
The session of processing the messages, which reside in a shard.
|
| UniformAcrossAllShards |
The strategy of splitting the entities into a number of shards uniformly.
|
| Exception | Description |
|---|---|
| CatchUpAlreadyStartedException |
An exception telling that the projection catch-up cannot be started, since some of the requested
entities are already catching up.
|