Object

com.rbmhtechnology.eventuate

ReplicationProtocol

Related Doc: package eventuate

Permalink

object ReplicationProtocol

Linear Supertypes
AnyRef, Any
Ordering
  1. Alphabetic
  2. By Inheritance
Inherited
  1. ReplicationProtocol
  2. AnyRef
  3. Any
  1. Hide All
  2. Show All
Visibility
  1. Public
  2. All

Type Members

  1. case class AdjustEventLogClockFailure(cause: Throwable) extends Product with Serializable

    Permalink

    Failure reply after a AdjustEventLogClock.

  2. case class AdjustEventLogClockSuccess(clock: EventLogClock) extends Product with Serializable

    Permalink

    Success reply after a AdjustEventLogClock.

    Success reply after a AdjustEventLogClock. Contains the adjusted clock.

  3. trait Format extends Serializable

    Permalink

    Marker trait for protobuf-serializable replication protocol messages.

  4. case class GetEventLogClockSuccess(clock: EventLogClock) extends Product with Serializable

    Permalink

    Success reply after a GetEventLogClock.

  5. case class GetReplicationProgress(sourceLogId: String) extends Product with Serializable

    Permalink

    Requests the local replication progress for given sourceLogId from a target log.

    Requests the local replication progress for given sourceLogId from a target log.

    See also

    GetReplicationProgresses

  6. case class GetReplicationProgressFailure(cause: Throwable) extends Product with Serializable

    Permalink

    Failure reply after a GetReplicationProgress.

  7. case class GetReplicationProgressSuccess(sourceLogId: String, storedReplicationProgress: Long, currentTargetVersionVector: VectorTime) extends Product with Serializable

    Permalink

    Success reply after a GetReplicationProgress.

  8. case class GetReplicationProgressesFailure(cause: Throwable) extends Product with Serializable

    Permalink

    Failure reply after a GetReplicationProgresses.

  9. case class GetReplicationProgressesSuccess(progresses: Map[String, Long]) extends Product with Serializable

    Permalink

    Success reply after a GetReplicationProgresses.

  10. case class IncompatibleApplicationVersionException(sourceEndpointId: String, sourceApplicationVersion: ApplicationVersion, targetApplicationVersion: ApplicationVersion) extends ReplicationReadException with Format with Product with Serializable

    Permalink

    Indicates that events cannot be replication from a source ReplicationEndpoint to a target ReplicationEndpoint because their application versions are incompatible.

  11. case class ReplicationEndpointInfo(endpointId: String, logSequenceNrs: Map[String, Long]) extends Format with Product with Serializable

    Permalink

    ReplicationEndpoint info object.

    ReplicationEndpoint info object. Exchanged between replication endpoints to establish replication connections.

    endpointId

    Replication endpoint id.

    logSequenceNrs

    sequence numbers of logs managed by the replication endpoint.

  12. case class ReplicationMetadata(replicationProgress: Long, currentVersionVector: VectorTime) extends Product with Serializable

    Permalink

    Source-scoped replication metadata.

    Source-scoped replication metadata.

    replicationProgress

    Replication read progress at source log.

    currentVersionVector

    When used with ReplicationWrite the current version vector at the source log. When used with ReplicationWriteSuccess the current version vector at the target log.

  13. case class ReplicationRead(fromSequenceNr: Long, max: Int, scanLimit: Int, filter: ReplicationFilter, targetLogId: String, replicator: ActorRef, currentTargetVersionVector: VectorTime) extends Format with Product with Serializable

    Permalink

    Instructs a source log to read up to max events starting at fromSequenceNr and applying the given replication filter.

  14. case class ReplicationReadEnvelope(payload: ReplicationRead, logName: String, targetApplicationName: String, targetApplicationVersion: ApplicationVersion) extends Format with Product with Serializable

    Permalink

    ReplicationRead requests are sent within this envelope to allow a remote acceptor to dispatch the request to the appropriate log.

  15. abstract class ReplicationReadException extends RuntimeException

    Permalink

    Base class for all ReplicationReadFailure causes.

  16. case class ReplicationReadFailure(cause: ReplicationReadException, targetLogId: String) extends Format with Product with Serializable

    Permalink

    Failure reply after a ReplicationRead.

  17. case class ReplicationReadSourceException(message: String) extends ReplicationReadException with Format with Product with Serializable

    Permalink

    Indicates a problem reading events from the backend store at the source endpoint.

  18. case class ReplicationReadSuccess(events: Seq[DurableEvent], fromSequenceNr: Long, replicationProgress: Long, targetLogId: String, currentSourceVersionVector: VectorTime) extends DurableEventBatch with Format with Product with Serializable

    Permalink

    Success reply after a ReplicationRead.

  19. case class ReplicationReadTimeoutException(timeout: FiniteDuration) extends ReplicationReadException with Product with Serializable

    Permalink

    Indicates that a ReplicationRead request timed out.

  20. case class ReplicationWrite(events: Seq[DurableEvent], metadata: Map[String, ReplicationMetadata], continueReplication: Boolean = false, replyTo: ActorRef = null) extends UpdateableEventBatch[ReplicationWrite] with Product with Serializable

    Permalink

    Instructs a target log to write replicated events from one or more source logs along with the latest read positions in the source logs.

  21. case class ReplicationWriteFailure(cause: Throwable) extends Product with Serializable

    Permalink

    Failure reply after a ReplicationWrite.

  22. case class ReplicationWriteN(writes: Seq[ReplicationWrite]) extends Product with Serializable

    Permalink

    Instructs an event log to batch-execute the given writes.

  23. case class ReplicationWriteSuccess(events: Seq[DurableEvent], metadata: Map[String, ReplicationMetadata], continueReplication: Boolean = false) extends Product with Serializable

    Permalink

    Success reply after a ReplicationWrite.

  24. case class SetReplicationProgress(sourceLogId: String, replicationProgress: Long) extends Product with Serializable

    Permalink

    Requests a target log to set the given replicationProgress for sourceLogId.

  25. case class SetReplicationProgressFailure(cause: Throwable) extends Product with Serializable

    Permalink

    Failure reply after a SetReplicationProgress.

  26. case class SetReplicationProgressSuccess(sourceLogId: String, storedReplicationProgress: Long) extends Product with Serializable

    Permalink

    Success reply after a SetReplicationProgress.

Value Members

  1. final def !=(arg0: Any): Boolean

    Permalink
    Definition Classes
    AnyRef → Any
  2. final def ##(): Int

    Permalink
    Definition Classes
    AnyRef → Any
  3. final def ==(arg0: Any): Boolean

    Permalink
    Definition Classes
    AnyRef → Any
  4. object AdjustEventLogClock extends Product with Serializable

    Permalink

    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.

  5. object GetEventLogClock extends Product with Serializable

    Permalink

    Requests the clock from an event log.

  6. object GetReplicationProgresses extends Product with Serializable

    Permalink

    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.

  7. object ReplicationDue extends Format with Product with Serializable

    Permalink

    Update notification sent to a replicator indicating that new events are available for replication.

  8. object ReplicationEndpointInfo extends Serializable

    Permalink
  9. object ReplicationWriteNComplete extends Product with Serializable

    Permalink

    Completion reply after a ReplicationWriteN.

  10. final def asInstanceOf[T0]: T0

    Permalink
    Definition Classes
    Any
  11. def clone(): AnyRef

    Permalink
    Attributes
    protected[java.lang]
    Definition Classes
    AnyRef
    Annotations
    @throws( ... )
  12. final def eq(arg0: AnyRef): Boolean

    Permalink
    Definition Classes
    AnyRef
  13. def equals(arg0: Any): Boolean

    Permalink
    Definition Classes
    AnyRef → Any
  14. def finalize(): Unit

    Permalink
    Attributes
    protected[java.lang]
    Definition Classes
    AnyRef
    Annotations
    @throws( classOf[java.lang.Throwable] )
  15. final def getClass(): Class[_]

    Permalink
    Definition Classes
    AnyRef → Any
  16. def hashCode(): Int

    Permalink
    Definition Classes
    AnyRef → Any
  17. final def isInstanceOf[T0]: Boolean

    Permalink
    Definition Classes
    Any
  18. final def ne(arg0: AnyRef): Boolean

    Permalink
    Definition Classes
    AnyRef
  19. final def notify(): Unit

    Permalink
    Definition Classes
    AnyRef
  20. final def notifyAll(): Unit

    Permalink
    Definition Classes
    AnyRef
  21. final def synchronized[T0](arg0: ⇒ T0): T0

    Permalink
    Definition Classes
    AnyRef
  22. def toString(): String

    Permalink
    Definition Classes
    AnyRef → Any
  23. final def wait(): Unit

    Permalink
    Definition Classes
    AnyRef
    Annotations
    @throws( ... )
  24. final def wait(arg0: Long, arg1: Int): Unit

    Permalink
    Definition Classes
    AnyRef
    Annotations
    @throws( ... )
  25. final def wait(arg0: Long): Unit

    Permalink
    Definition Classes
    AnyRef
    Annotations
    @throws( ... )

Inherited from AnyRef

Inherited from Any

Ungrouped