class Persistence extends Extension
- Alphabetic
- By Inheritance
- Persistence
- Extension
- AnyRef
- Any
- by any2stringadd
- by StringFormat
- by Ensuring
- by ArrowAssoc
- Hide All
- Show All
- Public
- Protected
Instance Constructors
- new Persistence(system: ExtendedActorSystem)
Value Members
- final def !=(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
- final def ##: Int
- Definition Classes
- AnyRef → Any
- def +(other: String): String
- Implicit
- This member is added by an implicit conversion from Persistence toany2stringadd[Persistence] performed by method any2stringadd in scala.Predef.
- Definition Classes
- any2stringadd
- def ->[B](y: B): (Persistence, B)
- Implicit
- This member is added by an implicit conversion from Persistence toArrowAssoc[Persistence] performed by method ArrowAssoc in scala.Predef.
- Definition Classes
- ArrowAssoc
- Annotations
- @inline()
- final def ==(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
- 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.
- 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.
- final def asInstanceOf[T0]: T0
- Definition Classes
- Any
- def clone(): AnyRef
- Attributes
- protected[lang]
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.CloneNotSupportedException]) @native() @HotSpotIntrinsicCandidate()
- lazy val defaultInternalStashOverflowStrategy: StashOverflowStrategy
- def ensuring(cond: (Persistence) => Boolean, msg: => Any): Persistence
- Implicit
- This member is added by an implicit conversion from Persistence toEnsuring[Persistence] performed by method Ensuring in scala.Predef.
- Definition Classes
- Ensuring
- def ensuring(cond: (Persistence) => Boolean): Persistence
- Implicit
- This member is added by an implicit conversion from Persistence toEnsuring[Persistence] performed by method Ensuring in scala.Predef.
- Definition Classes
- Ensuring
- def ensuring(cond: Boolean, msg: => Any): Persistence
- Implicit
- This member is added by an implicit conversion from Persistence toEnsuring[Persistence] performed by method Ensuring in scala.Predef.
- Definition Classes
- Ensuring
- def ensuring(cond: Boolean): Persistence
- Implicit
- This member is added by an implicit conversion from Persistence toEnsuring[Persistence] performed by method Ensuring in scala.Predef.
- Definition Classes
- Ensuring
- final def eq(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
- def equals(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef → Any
- final def getClass(): Class[_ <: AnyRef]
- Definition Classes
- AnyRef → Any
- Annotations
- @native() @HotSpotIntrinsicCandidate()
- 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,
numberOfSlicesis 128 and given 4numberOfRangesthis method will return ranges (0 to 255), (256 to 511), (512 to 767) and (768 to 1023). - def hashCode(): Int
- Definition Classes
- AnyRef → Any
- Annotations
- @native() @HotSpotIntrinsicCandidate()
- final def isInstanceOf[T0]: Boolean
- Definition Classes
- Any
- final def ne(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
- final def notify(): Unit
- Definition Classes
- AnyRef
- Annotations
- @native() @HotSpotIntrinsicCandidate()
- final def notifyAll(): Unit
- Definition Classes
- AnyRef
- Annotations
- @native() @HotSpotIntrinsicCandidate()
- final def numberOfSlices: Int
A slice is deterministically defined based on the persistence id.
A slice is deterministically defined based on the persistence id.
numberOfSlicesis 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.numberOfSlicesis 1024 - def persistenceId(persistentActor: ActorRef): String
Creates a canonical persistent actor id from a persistent actor ref.
- val settings: PersistenceSettings
- 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.
- 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,
numberOfSlicesis 1024 and given 4numberOfRangesthis method will return ranges (0 to 255), (256 to 511), (512 to 767) and (768 to 1023). - final def synchronized[T0](arg0: => T0): T0
- Definition Classes
- AnyRef
- val system: ExtendedActorSystem
- def toString(): String
- Definition Classes
- AnyRef → Any
- final def wait(arg0: Long, arg1: Int): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.InterruptedException])
- final def wait(arg0: Long): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.InterruptedException]) @native()
- final def wait(): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.InterruptedException])
Deprecated Value Members
- def finalize(): Unit
- Attributes
- protected[lang]
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.Throwable]) @Deprecated
- Deprecated
- def formatted(fmtstr: String): String
- Implicit
- This member is added by an implicit conversion from Persistence toStringFormat[Persistence] performed by method StringFormat in scala.Predef.
- Definition Classes
- StringFormat
- Annotations
- @deprecated @inline()
- Deprecated
(Since version 2.12.16) Use
formatString.format(value)instead ofvalue.formatted(formatString), or use thef""string interpolator. In Java 15 and later,formattedresolves to the new method in String which has reversed parameters.
- def →[B](y: B): (Persistence, B)
- Implicit
- This member is added by an implicit conversion from Persistence toArrowAssoc[Persistence] performed by method ArrowAssoc in scala.Predef.
- Definition Classes
- ArrowAssoc
- Annotations
- @deprecated
- Deprecated
(Since version 2.13.0) Use
->instead. If you still wish to display it as one character, consider using a font with programming ligatures such as Fira Code.