Failure reply after a AdjustEventLogClock.
Success reply after a AdjustEventLogClock.
Marker trait for protobuf-serializable replication protocol messages.
Success reply after a GetEventLogClock.
Requests the local replication progress for given
sourceLogId from a target log.
Failure reply after a GetReplicationProgress.
Success reply after a GetReplicationProgress.
Failure reply after a GetReplicationProgresses.
Success reply after a GetReplicationProgresses.
ReplicationEndpoint info object.
Replication endpoint id.
sequence numbers of logs managed by the replication endpoint.
Source-scoped replication metadata.
Instructs a source log to read up to
max events starting at
fromSequenceNr and applying
the given replication
ReplicationRead requests are sent within this envelope to allow a remote acceptor to dispatch the request to the appropriate log.
Base class for all ReplicationReadFailure
Failure reply after a ReplicationRead.
Indicates a problem reading events from the backend store at the source endpoint.
Success reply after a ReplicationRead.
Indicates that a ReplicationRead request timed out.
Instructs a target log to write replicated
events from one or more source logs along with the latest read
positions in the source logs.
Failure reply after a ReplicationWrite.
Instructs an event log to batch-execute the given
Success reply after a ReplicationWrite.
Requests a target log to set the given
Failure reply after a SetReplicationProgress.
Success reply after a SetReplicationProgress.
Instruct a log to adjust the sequence nr of the internal EventLogClock to the version vector.
Requests the clock from an event log.
Requests all local replication progresses from a log.
Update notification sent to a replicator indicating that new events are available for replication.
Completion reply after a ReplicationWriteN.