akka

persistence

package persistence

Source
package.scala
Linear Supertypes
Content Hierarchy Learn more about scaladoc diagrams
Ordering
  1. Alphabetic
  2. By inheritance
Inherited
  1. persistence
  2. AnyRef
  3. Any
  1. Hide All
  2. Show all
Learn more about member selection
Visibility
  1. Public
  2. All

Type Members

  1. abstract class AbstractPersistentActor extends AbstractActor with PersistentActor with Eventsourced

    Java API: an persistent actor - can be used to implement command or event sourcing.

  2. abstract class AbstractPersistentActorWithAtLeastOnceDelivery extends AbstractPersistentActor with AtLeastOnceDelivery

    Java API compatible with lambda expressions

  3. abstract class AbstractPersistentView extends AbstractActor with PersistentView

    Java API: compatible with lambda expressions (to be used with akka.japi.pf.ReceiveBuilder)

  4. trait AtLeastOnceDelivery extends Processor

    Mix-in this trait with your PersistentActor to send messages with at-least-once delivery semantics to destinations.

  5. class Persistence extends Extension

    Persistence extension.

  6. case class PersistenceFailure(payload: Any, sequenceNr: Long, cause: Throwable) extends Product with Serializable

    Sent to a Processor if a journal fails to write a Persistent message.

  7. final class PersistenceSettings extends AnyRef

    Persistence configuration.

  8. trait PersistentActor extends ProcessorImpl with Eventsourced

    An persistent Actor - can be used to implement command or event sourcing.

  9. trait PersistentRepr extends Persistent with Resequenceable with PersistentId with Message

    Plugin API: representation of a persistent message in the journal plugin API.

  10. trait PersistentView extends Actor with Recovery

    A view replicates the persistent message stream of a PersistentActor.

  11. case class Recover(fromSnapshot: SnapshotSelectionCriteria = SnapshotSelectionCriteria.Latest, toSequenceNr: Long = scala.Long.MaxValue, replayMax: Long = scala.Long.MaxValue) extends Product with Serializable

    Instructs a persistent actor to recover itself.

  12. trait Recovery extends Actor with Snapshotter with Stash with StashFactory

    Recovery state machine that loads snapshots and replays messages.

  13. abstract class RecoveryCompleted extends AnyRef

  14. case class RecoveryFailure(cause: Throwable) extends Product with Serializable

    Sent to a Processor if a journal fails to replay messages or fetch that processor's highest sequence number.

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

    Sent to a PersistentActor after failed saving of a snapshot.

  16. case class SaveSnapshotSuccess(metadata: SnapshotMetadata) extends Product with Serializable

    Sent to a PersistentActor after successful saving of a snapshot.

  17. case class SelectedSnapshot(metadata: SnapshotMetadata, snapshot: Any) extends Product with Serializable

    Plugin API: a selected snapshot matching SnapshotSelectionCriteria.

  18. case class SnapshotMetadata(persistenceId: String, sequenceNr: Long, timestamp: Long = 0L) extends Product with Serializable

    Snapshot metadata.

  19. case class SnapshotOffer(metadata: SnapshotMetadata, snapshot: Any) extends Product with Serializable

    Offers a PersistentActor a previously saved snapshot during recovery.

  20. case class SnapshotSelectionCriteria(maxSequenceNr: Long = scala.Long.MaxValue, maxTimestamp: Long = scala.Long.MaxValue) extends Product with Serializable

    Selection criteria for loading and deleting snapshots.

  21. trait Snapshotter extends Actor

    Snapshot API on top of the internal snapshot protocol.

  22. abstract class UntypedPersistentActor extends UntypedActor with ProcessorImpl with Eventsourced

    Java API: an persistent actor - can be used to implement command or event sourcing.

  23. abstract class UntypedPersistentActorWithAtLeastOnceDelivery extends UntypedPersistentActor with AtLeastOnceDelivery

    Java API: Use this class instead of UntypedPersistentActor to send messages with at-least-once delivery semantics to destinations.

  24. abstract class UntypedPersistentView extends UntypedActor with PersistentView

    Java API.

  25. case class Update(await: Boolean = false, replayMax: Long = scala.Long.MaxValue) extends Product with Serializable

    Instructs a PersistentView to update itself.

  26. abstract class AbstractEventsourcedProcessor extends AbstractPersistentActor

    Java API: compatible with lambda expressions (to be used with akka.japi.pf.ReceiveBuilder): command handler.

  27. abstract class AbstractProcessor extends AbstractActor with Processor

    Java API: compatible with lambda expressions

  28. abstract class AbstractView extends AbstractActor with View

    Java API: compatible with lambda expressions (to be used with akka.japi.pf.ReceiveBuilder)

  29. final class Channel extends Actor

    A channel is used by Processors (and Views) for sending Persistent messages to destinations.

  30. case class ChannelSettings(redeliverMax: Int = 5, redeliverInterval: FiniteDuration = ..., redeliverFailureListener: Option[ActorRef] = scala.None) extends Product with Serializable

    A Channel configuration object.

  31. sealed abstract class ConfirmablePersistent extends Persistent

    Persistent message that has been delivered by a Channel or PersistentChannel.

  32. case class Deliver(persistent: Persistent, destination: ActorPath) extends Message with Product with Serializable

    Instructs a Channel or PersistentChannel to deliver a persistent message to a destination.

  33. trait Delivered extends Message

    Plugin API: confirmation message generated by receivers of ConfirmablePersistent messages by calling ConfirmablePersistent.confirm().

  34. case class DeliveredByChannel(persistenceId: String, channelId: String, persistentSequenceNr: Long, deliverySequenceNr: Long = 0L, channel: ActorRef = null) extends Delivered with PersistentConfirmation with Product with Serializable

    Plugin API.

  35. case class DeliveredByPersistentChannel(channelId: String, persistentSequenceNr: Long, deliverySequenceNr: Long = 0L, channel: ActorRef = null) extends Delivered with PersistentId with Product with Serializable

    Plugin API.

  36. trait EventsourcedProcessor extends Processor with Eventsourced

    An event sourced processor.

  37. sealed abstract class Persistent extends Resequenceable

    Persistent message.

  38. case class PersistentBatch(batch: Seq[Resequenceable]) extends Message with Product with Serializable

    Instructs a Processor to atomically write the contained Persistent messages to the journal.

  39. final class PersistentChannel extends Actor

    A PersistentChannel implements the same functionality as a Channel but additionally persists Deliver requests before they are served.

  40. case class PersistentChannelSettings(redeliverMax: Int = 5, redeliverInterval: FiniteDuration = ..., redeliverFailureListener: Option[ActorRef] = scala.None, replyPersistent: Boolean = false, pendingConfirmationsMax: Long = scala.Long.MaxValue, pendingConfirmationsMin: Long = scala.Long.MaxValue, idleTimeout: FiniteDuration = ...) extends Product with Serializable

    A PersistentChannel configuration object.

  41. trait PersistentConfirmation extends AnyRef

    Plugin API: confirmation entry written by journal plugins.

  42. trait PersistentId extends AnyRef

    Plugin API: persistent message identifier.

  43. trait Processor extends ProcessorImpl

    An actor that persists (journals) messages of type Persistent.

  44. case class RedeliverFailure(messages: Seq[ConfirmablePersistent]) extends Product with Serializable

    Notification message to inform channel listeners about messages that have reached the maximum number of redeliveries.

  45. class ResetException extends AkkaException

    Exception thrown by a PersistentChannel child actor to re-initiate delivery.

  46. abstract class UntypedEventsourcedProcessor extends UntypedPersistentActor

    Java API: an event sourced processor.

  47. abstract class UntypedProcessor extends UntypedActor with Processor

    Java API: an actor that persists (journals) messages of type Persistent.

  48. abstract class UntypedView extends UntypedActor with View

    Java API.

  49. trait View extends Actor with Recovery

    A view replicates the persistent message stream of a processor.

Value Members

  1. object AtLeastOnceDelivery

  2. object Persistence extends ExtensionId[Persistence] with ExtensionIdProvider

    Persistence extension.

  3. object PersistentRepr extends Serializable

  4. object Recover extends Serializable

  5. object RecoveryCompleted extends RecoveryCompleted with Product with Serializable

    Sent to a Processor when the journal replay has been finished.

  6. object SelectedSnapshot extends Serializable

  7. object SnapshotSelectionCriteria extends Serializable

  8. object Update extends Product with Serializable

  9. package journal

  10. package serialization

  11. package snapshot

  12. implicit val snapshotMetadataOrdering: Ordering[SnapshotMetadata]

Deprecated Value Members

  1. object Channel

    Annotations
    @deprecated
    Deprecated

    (Since version 2.3.4) Channel will be removed, see akka.persistence.AtLeastOnceDelivery instead.

  2. object ChannelSettings extends Serializable

    Annotations
    @deprecated
    Deprecated

    (Since version 2.3.4) Channel will be removed, see akka.persistence.AtLeastOnceDelivery instead.

  3. object ConfirmablePersistent

    Annotations
    @deprecated
    Deprecated

    (Since version 2.3.4) Use akka.persistence.PersistentActor instead

  4. object Deliver extends Serializable

    Annotations
    @deprecated
    Deprecated

    (Since version 2.3.4) Channel will be removed, see akka.persistence.AtLeastOnceDelivery instead.

  5. object Persistent

    Annotations
    @deprecated
    Deprecated

    (Since version 2.3.4) Use akka.persistence.PersistentActor instead

  6. object PersistentBatch extends Serializable

    Annotations
    @deprecated
    Deprecated

    (Since version 2.3.4) Use akka.persistence.PersistentActor instead

  7. object PersistentChannel

    Annotations
    @deprecated
    Deprecated

    (Since version 2.3.4) Channel will be removed, see akka.persistence.AtLeastOnceDelivery instead.

  8. object PersistentChannelSettings extends Serializable

    Annotations
    @deprecated
    Deprecated

    (Since version 2.3.4) PersistentChannel will be removed, see akka.persistence.AtLeastOnceDelivery instead.

  9. object Reset extends Product with Serializable

    Resets a PersistentChannel, forcing it to redeliver all unconfirmed persistent messages.

Inherited from AnyRef

Inherited from Any

Ungrouped