Result of an event batch-read operation.
An event log wrapper that batches write commands.
An event log wrapper that batches write commands. Batched EventsourcingProtocol.Write commands are sent as EventsourcingProtocol.WriteN batch to the wrapped event log. Batched ReplicationProtocol.ReplicationWrite commands are sent as ReplicationProtocol.ReplicationWriteN batch to the wrapped event event log.
Batch sizes dynamically increase to a configurable limit under increasing load. The batch size limit can be
configured with eventuate.log.write-batch-size
. If there is no current write operation in progress, a new
Write
or ReplicationWrite
command is served immediately (as WriteN
or ReplicationWriteN
batch of size
1, respectively), keeping latency at a minimum.
A wrapper that can protect EventLog implementations from being overloaded while they are retrying to serve a write request.
A wrapper that can protect EventLog implementations from being overloaded while they are retrying to
serve a write request. If the circuit breaker is closed, it forwards all requests to the underlying event
log. If it is open, it replies with a failure message to the requestor. The circuit breaker can be opened
by sending it ServiceFailure
messages with a retry
value greater than or equal to the configuration
parameter eventuate.log.circuit-breaker.open-after-retries
. It can be closed again by sending it a
ServiceNormal
or ServiceInitialized
message. These messages are usually sent by EventLog
implementations and not by applications.
View of a Delete request.
View of a Delete request.
A marker that indicates that all event with a smaller sequence nr are not replayed any more.
A set of remote log ids that must have replicated events before they these events are allowed to be physically deleted locally.
An abstract event log that handles EventsourcingProtocol and ReplicationProtocol messages and translates them to read and write operations declared on the EventLogSPI trait.
An abstract event log that handles EventsourcingProtocol and ReplicationProtocol messages and translates them to read and write operations declared on the EventLogSPI trait. Storage providers implement an event log by implementing the EventLogSPI.
Event log state type (a subtype of EventLogState).
A clock that tracks the current sequence number and the version vector of an event log.
A clock that tracks the current sequence number and the version vector of an event log. The version vector is the merge result of vector timestamps of all events that have been written to that event log.
Event log storage provider interface (SPI).
Event log storage provider interface (SPI).
Event log state type.
Event log settings to be implemented by storage providers.
EventLog actor state that must be recovered on log actor initialization.
EventLog actor state that must be recovered on log actor initialization. Implementations are storage provider-specific.
Indicates that an event log is currently unavailable for serving requests.
Utility for writing events to an event log.
Notifies registered replicators about source log updates.
Result of an event batch-read operation.
Read event batch.
Last read position in the event log.