Failure reply after a AdjustEventLogClock.
Success reply after a AdjustEventLogClock.
Success reply after a AdjustEventLogClock. Contains the adjusted clock.
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.
Requests the local replication progress for given sourceLogId
from a target log.
GetReplicationProgresses
Failure reply after a GetReplicationProgress.
Success reply after a GetReplicationProgress.
Failure reply after a GetReplicationProgresses.
Success reply after a GetReplicationProgresses.
Indicates that events cannot be replication from a source ReplicationEndpoint to a target ReplicationEndpoint because their application versions are incompatible.
ReplicationEndpoint info object.
ReplicationEndpoint info object. Exchanged between replication endpoints to establish replication connections.
Replication endpoint id.
sequence numbers of logs managed by the replication endpoint.
Source-scoped replication metadata.
Source-scoped replication metadata.
Replication read progress at source log.
When used with ReplicationWrite the current version vector at the source log. When used with ReplicationWriteSuccess the current version vector at the target log.
Instructs a source log to read up to max
events starting at fromSequenceNr
and applying
the given replication filter
.
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 cause
s.
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 writes
.
Success reply after a ReplicationWrite.
Requests a target log to set the given replicationProgress
for sourceLogId
.
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.
Instruct a log to adjust the sequence nr of the internal EventLogClock to the version vector. This is ensures that the sequence nr is greater than or equal to the log's entry in the version vector.
Requests the clock from an event log.
Requests all local replication progresses from a log.
Requests all local replication progresses from a log. The local replication progress is the sequence number in the remote log up to which the local log has replicated all events from the remote log.
Update notification sent to a replicator indicating that new events are available for replication.
Completion reply after a ReplicationWriteN.