@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.
|