Packages

class Persistence extends Extension

Persistence extension.

Source
Persistence.scala
Linear Supertypes
Extension, AnyRef, Any
Type Hierarchy
Ordering
  1. Alphabetic
  2. By Inheritance
Inherited
  1. Persistence
  2. Extension
  3. AnyRef
  4. Any
Implicitly
  1. by any2stringadd
  2. by StringFormat
  3. by Ensuring
  4. by ArrowAssoc
  1. Hide All
  2. Show All
Visibility
  1. Public
  2. Protected

Instance Constructors

  1. new Persistence(system: ExtendedActorSystem)

Value Members

  1. final def adaptersFor(journalPluginId: String, journalPluginConfig: Config): EventAdapters

    Returns an akka.persistence.journal.EventAdapters object which serves as a per-journal collection of bound event adapters.

    Returns an akka.persistence.journal.EventAdapters object which serves as a per-journal collection of bound event adapters. If no adapters are registered for a given journal the EventAdapters object will simply return the identity adapter for each class, otherwise the most specific adapter matching a given class will be returned.

    The provided journalPluginConfig will be used to configure the plugin instead of the actor system config.

  2. final def adaptersFor(journalPluginId: String): EventAdapters

    Returns an akka.persistence.journal.EventAdapters object which serves as a per-journal collection of bound event adapters.

    Returns an akka.persistence.journal.EventAdapters object which serves as a per-journal collection of bound event adapters. If no adapters are registered for a given journal the EventAdapters object will simply return the identity adapter for each class, otherwise the most specific adapter matching a given class will be returned.

  3. lazy val defaultInternalStashOverflowStrategy: StashOverflowStrategy
  4. final def getSliceRanges(numberOfRanges: Int): List[Pair[Integer, Integer]]

    Java API: Split the total number of slices into ranges by the given numberOfRanges.

    Java API: Split the total number of slices into ranges by the given numberOfRanges.

    For example, numberOfSlices is 128 and given 4 numberOfRanges this method will return ranges (0 to 255), (256 to 511), (512 to 767) and (768 to 1023).

  5. final def numberOfSlices: Int

    A slice is deterministically defined based on the persistence id.

    A slice is deterministically defined based on the persistence id. numberOfSlices is not configurable because changing the value would result in different slice for a persistence id than what was used before, which would result in invalid eventsBySlices.

    numberOfSlices is 1024

  6. def persistenceId(persistentActor: ActorRef): String

    Creates a canonical persistent actor id from a persistent actor ref.

  7. val settings: PersistenceSettings
  8. final def sliceForPersistenceId(persistenceId: String): Int

    A slice is deterministically defined based on the persistence id.

    A slice is deterministically defined based on the persistence id. The purpose is to evenly distribute all persistence ids over the slices and be able to query the events for a range of slices.

  9. final def sliceRanges(numberOfRanges: Int): IndexedSeq[Range]

    Scala API: Split the total number of slices into ranges by the given numberOfRanges.

    Scala API: Split the total number of slices into ranges by the given numberOfRanges.

    For example, numberOfSlices is 1024 and given 4 numberOfRanges this method will return ranges (0 to 255), (256 to 511), (512 to 767) and (768 to 1023).

  10. val system: ExtendedActorSystem