EventsourcingProtocol

Type Members

1. case class Delete(toSequenceNr: Long, remoteLogIds: Set[String] = Set.empty) extends Product with Serializable

   

   Instructs an event log to delete events with a sequence nr less or equal a given one.

   Instructs an event log to delete events with a sequence nr less or equal a given one. Deleted events are not replayed any more, however depending on the log implementation and remoteLogIds they might still be replicated.

   toSequenceNr

   All events with a less or equal sequence nr are not replayed any more.

   remoteLogIds

   A set of remote log ids that must have replicated events before they are allowed to be physically deleted.

2. case class DeleteFailure(cause: Throwable) extends Product with Serializable

   

   Failure reply after a Delete

3. case class DeleteSnapshots(lowerSequenceNr: Long) extends Product with Serializable

   

   Instructs an event log to delete all snapshots with a sequence number greater than or equal to lowerSequenceNr.

4. case class DeleteSnapshotsFailure(cause: Throwable) extends Product with Serializable

   

   Failure reply after a DeleteSnapshots.

5. case class DeleteSuccess(deletedTo: Long) extends Product with Serializable

   

   Success reply after a Delete

   Success reply after a Delete

   deletedTo

   The actually written deleted to marker. Minimum of Delete.toSequenceNr and the current sequence nr

6. case class LoadSnapshot(emitterId: String, instanceId: Int) extends Product with Serializable

   

   Instructs an event log to load the most recent snapshot for emitterId.

7. case class LoadSnapshotFailure(cause: Throwable, instanceId: Int) extends Product with Serializable

   

   Failure reply after a LoadSnapshot.

8. case class LoadSnapshotSuccess(snapshot: Option[Snapshot], instanceId: Int) extends Product with Serializable

   

   Success reply after a LoadSnapshot.

9. case class Replay(fromSequenceNr: Long, max: Int, subscriber: Option[ActorRef], aggregateId: Option[String], instanceId: Int) extends Product with Serializable

   

   Instructs an event log to read up to max events starting at fromSequenceNr.

   Instructs an event log to read up to max events starting at fromSequenceNr. If aggregateId is defined, only those events that have the aggregate id in their destinationAggregateIds are returned.

10. case class ReplayFailure(cause: Throwable, replayProgress: Long, instanceId: Int) extends Product with Serializable

    

    Failure reply after a Replay.

11. case class ReplaySuccess(events: Seq[DurableEvent], replayProgress: Long, instanceId: Int) extends DurableEventBatch with Product with Serializable

    

    Success reply after a Replay.

12. case class SaveSnapshot(snapshot: Snapshot, initiator: ActorRef, instanceId: Int) extends Product with Serializable

    

    Instructs an event log to save the given snapshot.

13. case class SaveSnapshotFailure(metadata: SnapshotMetadata, cause: Throwable, instanceId: Int) extends Product with Serializable

    

    Failure reply after a SaveSnapshot.

14. case class SaveSnapshotSuccess(metadata: SnapshotMetadata, instanceId: Int) extends Product with Serializable

    

    Success reply after a SaveSnapshot.

15. case class Write(events: Seq[DurableEvent], initiator: ActorRef, replyTo: ActorRef, correlationId: Int, instanceId: Int) extends UpdateableEventBatch[Write] with Product with Serializable

    

    Instructs an event log to write the given events.

16. case class WriteFailure(events: Seq[DurableEvent], cause: Throwable, correlationId: Int, instanceId: Int) extends Product with Serializable

    

    Failure reply after a Write.

17. case class WriteN(writes: Seq[Write]) extends Product with Serializable

    

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

18. case class WriteSuccess(events: Seq[DurableEvent], correlationId: Int, instanceId: Int) extends Product with Serializable

    

    Success reply after a Write.

19. case class Written(event: DurableEvent) extends Product with Serializable

    

    Sent by an event log to all registered participants, if event has been successfully written.

    Sent by an event log to all registered participants, if event has been successfully written. This message is not sent to a participant if that participant has sent a corresponding Write.