Package org.apache.pekko.persistence

package org.apache.pekko.persistence

Related Packages

Package	Description
org.apache.pekko
org.apache.pekko.persistence.fsm
org.apache.pekko.persistence.journal
org.apache.pekko.persistence.query
org.apache.pekko.persistence.scalatest
org.apache.pekko.persistence.serialization
org.apache.pekko.persistence.snapshot
org.apache.pekko.persistence.state
org.apache.pekko.persistence.testkit
org.apache.pekko.persistence.typed

Class	Description
AbstractPersistentActor	Java API: an persistent actor - can be used to implement command or Event Sourcing.
AbstractPersistentActorLike	INTERNAL API
AbstractPersistentActorWithAtLeastOnceDelivery	Java API: compatible with lambda expressions
AbstractPersistentActorWithTimers	Java API: Combination of AbstractPersistentActor and pekko.actor.AbstractActorWithTimers.
AtLeastOnceDelivery	Scala API: Mix-in this trait with your PersistentActor to send messages with at-least-once delivery semantics to destinations.
AtLeastOnceDelivery.AtLeastOnceDeliverySnapshot	Snapshot of current AtLeastOnceDelivery state.
AtLeastOnceDelivery.AtLeastOnceDeliverySnapshot$
AtLeastOnceDelivery.Internal$	INTERNAL API
AtLeastOnceDelivery.MaxUnconfirmedMessagesExceededException
AtLeastOnceDelivery.UnconfirmedDelivery	Information about a message that has not been confirmed.
AtLeastOnceDelivery.UnconfirmedDelivery$
AtLeastOnceDelivery.UnconfirmedWarning
AtLeastOnceDelivery.UnconfirmedWarning$
AtLeastOnceDelivery$
AtLeastOnceDeliveryLike
AtomicWrite
AtomicWrite$
CapabilityFlag
CapabilityFlag$
CapabilityFlags
DeleteMessagesFailure	Reply message to a failed JournalProtocol.DeleteMessagesTo request.
DeleteMessagesFailure$
DeleteMessagesSuccess	Reply message to a successful JournalProtocol.DeleteMessagesTo request.
DeleteMessagesSuccess$
DeleteSnapshotFailure	Sent to a PersistentActor after failed deletion of a snapshot.
DeleteSnapshotFailure$
DeleteSnapshotsFailure	Sent to a PersistentActor after failed deletion of a range of snapshots.
DeleteSnapshotsFailure$
DeleteSnapshotsSuccess	Sent to a PersistentActor after successful deletion of specified range of snapshots.
DeleteSnapshotsSuccess$
DeleteSnapshotSuccess	Sent to a PersistentActor after successful deletion of a snapshot.
DeleteSnapshotSuccess$
DiscardConfigurator
DiscardToDeadLetterStrategy	Discard the message to pekko.actor.DeadLetter.
DiscardToDeadLetterStrategy$	Discard the message to pekko.actor.DeadLetter.
Eventsourced	INTERNAL API.
Eventsourced.AsyncHandlerInvocation	INTERNAL API: does not force the actor to stash commands; Originates from either `persistAsync` or `defer` calls
Eventsourced.AsyncHandlerInvocation$
Eventsourced.PendingHandlerInvocation	INTERNAL API
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.State
Eventsourced$	INTERNAL API
JournalCapabilityFlags
JournalProtocol	INTERNAL API.
JournalProtocol.DeleteMessagesTo	Request to delete all persistent messages with sequence numbers up to toSequenceNr (inclusive).
JournalProtocol.DeleteMessagesTo$
JournalProtocol.LoopMessageSuccess	Reply message to a JournalProtocol.WriteMessages with a non-persistent message.
JournalProtocol.LoopMessageSuccess$
JournalProtocol.Message	Marker trait shared by internal journal messages.
JournalProtocol.RecoverySuccess	Reply message to a successful JournalProtocol.ReplayMessages request.
JournalProtocol.RecoverySuccess$
JournalProtocol.ReplayedMessage	Reply message to a JournalProtocol.ReplayMessages request.
JournalProtocol.ReplayedMessage$
JournalProtocol.ReplayMessages	Request to replay messages to persistentActor.
JournalProtocol.ReplayMessages$
JournalProtocol.ReplayMessagesFailure	Reply message to a failed JournalProtocol.ReplayMessages request.
JournalProtocol.ReplayMessagesFailure$
JournalProtocol.Request	Internal journal command.
JournalProtocol.Response	Internal journal acknowledgement.
JournalProtocol.WriteMessageFailure	Reply message to a failed JournalProtocol.WriteMessages request.
JournalProtocol.WriteMessageFailure$
JournalProtocol.WriteMessageRejected	Reply message to a rejected JournalProtocol.WriteMessages request.
JournalProtocol.WriteMessageRejected$
JournalProtocol.WriteMessages	Request to write messages.
JournalProtocol.WriteMessages$
JournalProtocol.WriteMessagesFailed	Reply message to a failed JournalProtocol.WriteMessages request.
JournalProtocol.WriteMessagesFailed$
JournalProtocol.WriteMessagesSuccessful$	Reply message to a successful JournalProtocol.WriteMessages request.
JournalProtocol.WriteMessageSuccess	Reply message to a successful JournalProtocol.WriteMessages request.
JournalProtocol.WriteMessageSuccess$
JournalProtocol$	INTERNAL API.
NonPersistentRepr$
Persistence	Persistence extension.
Persistence.PluginHolder$
Persistence$	Persistence extension provider.
PersistenceIdentity	Identification of PersistentActor.
PersistencePlugin$	INTERNAL API
PersistenceRecovery
PersistenceSettings	Persistence configuration.
PersistenceStash
PersistentActor	Scala API: A persistent Actor - can be used to implement command or Event Sourcing.
PersistentEnvelope	INTERNAL API
PersistentImpl$
PersistentRepr	Plugin API: representation of a persistent message in the journal plugin API.
PersistentRepr$
PluginProvider<T,ScalaDsl,JavaDsl>	INTERNAL API
PluginSpec
Protocol	INTERNAL API.
Protocol.Message	INTERNAL API.
Protocol$	INTERNAL API.
Recovery	Recovery mode configuration object to be returned in PersistenceRecovery.recovery().
Recovery$
RecoveryCompleted
RecoveryCompleted$	Sent to a PersistentActor when the journal replay has been finished.
RecoveryPermitter$	INTERNAL API
RecoveryTimedOut
ReplyToStrategy	Reply to sender with predefined response, and discard the received message silently.
ReplyToStrategy$
RuntimePluginConfig
SaveSnapshotFailure	Sent to a PersistentActor after failed saving of a snapshot.
SaveSnapshotFailure$
SaveSnapshotSuccess	Sent to a PersistentActor after successful saving of a snapshot.
SaveSnapshotSuccess$
SelectedSnapshot	Plugin API: a selected snapshot matching SnapshotSelectionCriteria.
SelectedSnapshot$
SnapshotMetadata	Snapshot metadata.
SnapshotMetadata$
SnapshotOffer	Offers a PersistentActor a previously saved snapshot during recovery.
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	Reply message to a failed SnapshotProtocol.LoadSnapshot request.
SnapshotProtocol.LoadSnapshotFailed$
SnapshotProtocol.LoadSnapshotResult	Response message to a SnapshotProtocol.LoadSnapshot message.
SnapshotProtocol.LoadSnapshotResult$
SnapshotProtocol.Message	Marker trait shared by internal snapshot messages.
SnapshotProtocol.Request	Internal snapshot command.
SnapshotProtocol.Response	Internal snapshot acknowledgement.
SnapshotProtocol.SaveSnapshot	Instructs snapshot store to save a snapshot.
SnapshotProtocol.SaveSnapshot$
SnapshotProtocol$	INTERNAL API.
SnapshotSelectionCriteria	Selection criteria for loading and deleting snapshots.
SnapshotSelectionCriteria$
SnapshotStoreCapabilityFlags
Snapshotter	Snapshot API on top of the internal snapshot protocol.
StashOverflowStrategy	This defines how to handle the current received message which failed to stash, when the size of Stash exceeding the capacity of Stash.
StashOverflowStrategyConfigurator	Implement this interface in order to configure the stashOverflowStrategy for the internal stash of persistent actor.
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