package journal
- Alphabetic
- Public
- Protected
Type Members
- trait AsyncRecovery extends AnyRef
Asynchronous message replay and sequence number recovery interface.
- class AsyncReplayTimeoutException extends PekkoException
Thrown if replay inactivity exceeds a specified timeout.
Thrown if replay inactivity exceeds a specified timeout.
- Annotations
- @SerialVersionUID()
- trait AsyncWriteJournal extends Actor with WriteJournalBase with AsyncRecovery
Abstract journal, optimized for asynchronous, non-blocking writes.
- sealed trait EmptyEventSeq extends EventSeq
- trait EventAdapter extends WriteEventAdapter with ReadEventAdapter
An EventAdapter is both a WriteEventAdapter and a ReadEventAdapter.
An EventAdapter is both a WriteEventAdapter and a ReadEventAdapter. Facility to convert from and to specialised data models, as may be required by specialized persistence Journals.
Typical use cases include (but are not limited to):
- adding metadata, a.k.a. "tagging" - by wrapping objects into tagged counterparts
- manually converting to the Journals storage format, such as JSON, BSON or any specialised binary format
- adapting incoming events in any way before persisting them by the journal
- class EventAdapters extends AnyRef
EventAdapters
serves as a per-journal collection of bound event adapters.EventAdapters
serves as a per-journal collection of bound event adapters.- Annotations
- @ccompatUsedUntil213()
- sealed abstract class EventSeq extends AnyRef
- final case class EventsSeq[E](events: Seq[E]) extends EventSeq with Product with Serializable
- abstract class JournalPerfSpec extends JournalSpec
This spec measures execution times of the basic operations that an pekko.persistence.PersistentActor provides, using the provided Journal (plugin).
This spec measures execution times of the basic operations that an pekko.persistence.PersistentActor provides, using the provided Journal (plugin).
It is *NOT* meant to be a comprehensive benchmark, but rather aims to help plugin developers to easily determine if their plugin's performance is roughly as expected. It also validates the plugin still works under "more messages" scenarios.
In case your journal plugin needs some kind of setup or teardown, override the
beforeAll
orafterAll
methods (don't forget to callsuper
in your overridden methods).For a Java and JUnit consumable version of the TCK please refer to pekko.persistence.japi.journal.JavaJournalPerfSpec.
- abstract class JournalSpec extends PluginSpec with MayVerb with OptionalTests with JournalCapabilityFlags
This spec aims to verify custom pekko-persistence Journal implementations.
This spec aims to verify custom pekko-persistence Journal implementations. Plugin authors are highly encouraged to include it in their plugin's test suites.
In case your journal plugin needs some kind of setup or teardown, override the
beforeAll
orafterAll
methods (don't forget to callsuper
in your overridden methods).For a Java and JUnit consumable version of the TCK please refer to pekko.persistence.japi.journal.JavaJournalSpec.
- final class PersistencePluginProxy extends Actor with Stash with ActorLogging
- class PersistencePluginProxyExtensionImpl extends Extension
PersistencePluginProxyExtensionImpl is an
Extension
that enables initialization of thePersistencePluginProxy
via configuration, without requiring any code changes or the creation of any actors. - trait ReadEventAdapter extends AnyRef
Facility to convert from and to specialised data models, as may be required by specialized persistence Journals.
Facility to convert from and to specialised data models, as may be required by specialized persistence Journals.
Typical use cases include (but are not limited to):
- extracting events from "envelopes"
- manually converting to the Journals storage format, such as JSON, BSON or any specialised binary format
- adapting incoming events from a "data model" to the "domain model"
- final case class SingleEventSeq(event: Any) extends EventSeq with Product with Serializable
- case class Tagged(payload: Any, tags: Set[String]) extends Product with Serializable
The journal may support tagging of events that are used by the
EventsByTag
query and it may support specifying the tags via an pekko.persistence.journal.EventAdapter that wraps the events in aTagged
with the giventags
.The journal may support tagging of events that are used by the
EventsByTag
query and it may support specifying the tags via an pekko.persistence.journal.EventAdapter that wraps the events in aTagged
with the giventags
. The journal may support other ways of doing tagging. Please consult the documentation of the specific journal implementation for more information.The journal will unwrap the event and store the
payload
. - trait WriteEventAdapter extends AnyRef
Facility to convert to specialised data models, as may be required by specialized persistence Journals.
Facility to convert to specialised data models, as may be required by specialized persistence Journals.
Typical use cases include (but are not limited to):
- adding metadata, a.k.a. "tagging" - by wrapping objects into tagged counterparts
- manually converting to the Journals storage format, such as JSON, BSON or any specialised binary format
- splitting up large events into sequences of smaller ones
Value Members
- object EmptyEventSeq extends EventSeq with EmptyEventSeq
- object EventSeq
- case object IdentityEventAdapter extends EventAdapter with Product with Serializable
No-op model adapter which passes through the incoming events as-is.
- object JournalPerfSpec extends Serializable
- object JournalSpec extends Serializable
- object PersistencePluginProxy
- object PersistencePluginProxyExtension extends ExtensionId[PersistencePluginProxyExtensionImpl] with ExtensionIdProvider