Package org.apache.pekko.persistence.journal
package org.apache.pekko.persistence.journal
-
ClassDescriptionAsynchronous message replay and sequence number recovery interface.Thrown if replay inactivity exceeds a specified timeout.Abstract journal, optimized for asynchronous, non-blocking writes.INTERNAL API.INTERNAL API.INTERNAL API.INTERNAL API.INTERNAL API.
EventAdaptersserves as a per-journal collection of bound event adapters.INTERNAL APIEventsSeq<E>No-op model adapter which passes through the incoming events as-is.No-op model adapter which passes through the incoming events as-is.This spec measures execution times of the basic operations that anpekko.persistence.PersistentActorprovides, using the provided Journal (plugin).This spec aims to verify custom pekko-persistence Journal implementations.PersistencePluginProxyExtensionImpl is anExtensionthat enables initialization of thePersistencePluginProxyvia configuration, without requiring any code changes or the creation of any actors.Facility to convert from and to specialised data models, as may be required by specialized persistence Journals.INTERNAL APIThe journal may support tagging of events that are used by theEventsByTagquery and it may support specifying the tags via anpekko.persistence.journal.EventAdapterthat wraps the events in aTaggedwith the giventags.Facility to convert to specialised data models, as may be required by specialized persistence Journals.