Namespace Akka.Persistence.Extras

Used to reset a PersistenceSupervisor automatically on a timer.

A built-in envelope for making user-defined messages IConfirmableMessage without changing the types of the messages themselves.

Designed to play nicely with typed Receive statements inside actors.

A built-in envelope for making user-defined messages IConfirmableMessage without changing the types of the messages themselves.

Used to persist the handling of a IConfirmableMessage

The settings used to configure how the DeDuplicatingReceiveActor will process duplicates of messages and how it will configure its state.

extension used to inject all of the relevant settings.

INTERNAL API.

Used by the to create a singleton ExtraPersistence instance specific to the actor system who calls it.

Journal-based AtLeastOnceDelivery semantics.

Used to reset a PersistenceSupervisor manually, often for testing purposes.

Akka.Pattern.BackoffSupervisor implementation that buffers un-delivered and un-persisted messages down to a Akka.Persistence.PersistentActor child.

INTERNAL API. Default snapshot implementation.

Used to work around issues with value tuple syntax in older versions of the compiler.

Used to decorate messages with the ability to be confirmed without duplicates via a DeDuplicatingReceiveActor.

Typed "wrapper" interface for exposing confirmable messages that are wrapped inside their confirmation metadata.

Configuration used by PersistenceSupervisor.

Interface for data structures used for tracking delivery state.

INTERNAL API. Used for writing out IReceiverState data to the snapshot store.

The order in which any single sender can deliver messages to this receiver.