AbstractPersistentActor |
Java API: an persistent actor - can be used to implement command or Event Sourcing.
|
AbstractPersistentActorWithAtLeastOnceDelivery |
Java API: compatible with lambda expressions
|
AbstractPersistentActorWithTimers |
|
AtLeastOnceDelivery.AtLeastOnceDeliverySnapshot |
Snapshot of current AtLeastOnceDelivery state.
|
AtLeastOnceDelivery.AtLeastOnceDeliverySnapshot$ |
|
AtLeastOnceDelivery.Internal$ |
INTERNAL API
|
AtLeastOnceDelivery.UnconfirmedDelivery |
Information about a message that has not been confirmed.
|
AtLeastOnceDelivery.UnconfirmedDelivery$ |
|
AtLeastOnceDelivery.UnconfirmedWarning |
|
AtLeastOnceDelivery.UnconfirmedWarning$ |
|
AtLeastOnceDelivery$ |
|
AtomicWrite |
|
AtomicWrite$ |
|
CapabilityFlag |
|
CapabilityFlag$ |
|
DeleteMessagesFailure |
|
DeleteMessagesFailure$ |
|
DeleteMessagesSuccess |
|
DeleteMessagesSuccess$ |
|
DeleteSnapshotFailure |
|
DeleteSnapshotFailure$ |
|
DeleteSnapshotsFailure |
|
DeleteSnapshotsFailure$ |
|
DeleteSnapshotsSuccess |
Sent to a PersistentActor after successful deletion of specified range of snapshots.
|
DeleteSnapshotsSuccess$ |
|
DeleteSnapshotSuccess |
|
DeleteSnapshotSuccess$ |
|
DiscardConfigurator |
|
DiscardToDeadLetterStrategy |
Discard the message to pekko.actor.DeadLetter .
|
DiscardToDeadLetterStrategy$ |
Discard the message to pekko.actor.DeadLetter .
|
Eventsourced.AsyncHandlerInvocation |
INTERNAL API: does not force the actor to stash commands; Originates from either `persistAsync` or `defer` calls
|
Eventsourced.AsyncHandlerInvocation$ |
|
Eventsourced.RecoveryTick |
INTERNAL API: message used to detect that recovery timed out
|
Eventsourced.RecoveryTick$ |
|
Eventsourced.StashingHandlerInvocation |
INTERNAL API: forces actor to stash incoming commands until all these invocations are handled
|
Eventsourced.StashingHandlerInvocation$ |
|
Eventsourced$ |
INTERNAL API
|
JournalProtocol |
INTERNAL API.
|
JournalProtocol.DeleteMessagesTo |
Request to delete all persistent messages with sequence numbers up to toSequenceNr
(inclusive).
|
JournalProtocol.DeleteMessagesTo$ |
|
JournalProtocol.LoopMessageSuccess |
|
JournalProtocol.LoopMessageSuccess$ |
|
JournalProtocol.RecoverySuccess |
|
JournalProtocol.RecoverySuccess$ |
|
JournalProtocol.ReplayedMessage |
|
JournalProtocol.ReplayedMessage$ |
|
JournalProtocol.ReplayMessages |
Request to replay messages to persistentActor .
|
JournalProtocol.ReplayMessages$ |
|
JournalProtocol.ReplayMessagesFailure |
|
JournalProtocol.ReplayMessagesFailure$ |
|
JournalProtocol.WriteMessageFailure |
|
JournalProtocol.WriteMessageFailure$ |
|
JournalProtocol.WriteMessageRejected |
|
JournalProtocol.WriteMessageRejected$ |
|
JournalProtocol.WriteMessages |
Request to write messages.
|
JournalProtocol.WriteMessages$ |
|
JournalProtocol.WriteMessagesFailed |
|
JournalProtocol.WriteMessagesFailed$ |
|
JournalProtocol.WriteMessagesSuccessful$ |
|
JournalProtocol.WriteMessageSuccess |
|
JournalProtocol.WriteMessageSuccess$ |
|
JournalProtocol$ |
INTERNAL API.
|
NonPersistentRepr$ |
|
Persistence |
Persistence extension.
|
Persistence.PluginHolder$ |
|
Persistence$ |
Persistence extension provider.
|
PersistencePlugin$ |
INTERNAL API
|
PersistenceSettings |
Persistence configuration.
|
PersistentImpl$ |
|
PersistentRepr$ |
|
PluginSpec |
|
Protocol |
INTERNAL API.
|
Protocol$ |
INTERNAL API.
|
Recovery |
|
Recovery$ |
|
RecoveryCompleted |
|
RecoveryCompleted$ |
|
RecoveryPermitter$ |
INTERNAL API
|
ReplyToStrategy |
Reply to sender with predefined response, and discard the received message silently.
|
ReplyToStrategy$ |
|
SaveSnapshotFailure |
|
SaveSnapshotFailure$ |
|
SaveSnapshotSuccess |
|
SaveSnapshotSuccess$ |
|
SelectedSnapshot |
|
SelectedSnapshot$ |
|
SnapshotMetadata |
Snapshot metadata.
|
SnapshotMetadata$ |
|
SnapshotOffer |
|
SnapshotOffer$ |
|
SnapshotProtocol |
INTERNAL API.
|
SnapshotProtocol.DeleteSnapshot |
Instructs snapshot store to delete a snapshot.
|
SnapshotProtocol.DeleteSnapshot$ |
|
SnapshotProtocol.DeleteSnapshots |
Instructs snapshot store to delete all snapshots that match criteria .
|
SnapshotProtocol.DeleteSnapshots$ |
|
SnapshotProtocol.LoadSnapshot |
Instructs a snapshot store to load a snapshot.
|
SnapshotProtocol.LoadSnapshot$ |
|
SnapshotProtocol.LoadSnapshotFailed |
|
SnapshotProtocol.LoadSnapshotFailed$ |
|
SnapshotProtocol.LoadSnapshotResult |
|
SnapshotProtocol.LoadSnapshotResult$ |
|
SnapshotProtocol.SaveSnapshot |
Instructs snapshot store to save a snapshot.
|
SnapshotProtocol.SaveSnapshot$ |
|
SnapshotProtocol$ |
INTERNAL API.
|
SnapshotSelectionCriteria |
Selection criteria for loading and deleting snapshots.
|
SnapshotSelectionCriteria$ |
|
TestPayload |
|
TestPayload$ |
|
TestSerializer |
|
ThrowExceptionConfigurator |
|
ThrowOverflowExceptionStrategy |
Throw pekko.actor.StashOverflowException , hence the persistent actor will starting recovery
if guarded by default supervisor strategy.
|
ThrowOverflowExceptionStrategy$ |
Throw pekko.actor.StashOverflowException , hence the persistent actor will starting recovery
if guarded by default supervisor strategy.
|
TraitOrder |
INTERNAL API
|
TraitOrder$ |
INTERNAL API
|