Package akka.persistence.journal
-
Interface Summary Interface Description AsyncRecovery Asynchronous message replay and sequence number recovery interface.AsyncReplay A plugin may implement this trait as an optimization.AsyncWriteJournal Abstract journal, optimized for asynchronous, non-blocking writes.EmptyEventSeq EventAdapter PersistencePluginProxy.PluginType ReadEventAdapter Facility to convert from and to specialised data models, as may be required by specialized persistence Journals.WriteEventAdapter Facility to convert to specialised data models, as may be required by specialized persistence Journals.WriteJournalBase -
Class Summary Class Description AsyncWriteJournal.Desequenced AsyncWriteJournal.Desequenced$ AsyncWriteJournal.Resequencer AsyncWriteJournal$ INTERNAL API.EmptyEventSeq$ EventAdapters EventAdaptersserves as a per-journal collection of bound event adapters.EventAdapters.CombinedReadEventAdapter$ EventAdapters$ INTERNAL APIEventSeq EventSeq$ EventsSeq<E> EventsSeq$ IdentityEventAdapter No-op model adapter which passes through the incoming events as-is.IdentityEventAdapter$ No-op model adapter which passes through the incoming events as-is.IdentityEventAdapters IdentityEventAdapters$ JournalPerfSpec This spec measures execution times of the basic operations that anPersistentActorprovides, using the provided Journal (plugin).JournalPerfSpec.BenchActor JournalPerfSpec.Cmd JournalPerfSpec.Cmd$ JournalPerfSpec.ResetCounter$ JournalPerfSpec$ JournalSpec This spec aims to verify custom akka-persistence Journal implementations.JournalSpec$ NoopReadEventAdapter$ NoopWriteEventAdapter$ PersistencePluginProxy PersistencePluginProxy.TargetLocation PersistencePluginProxy.TargetLocation$ PersistencePluginProxy$ PersistencePluginProxyExtension PersistencePluginProxyExtension$ PersistencePluginProxyExtensionImpl PersistencePluginProxyExtensionImpl is anExtensionthat enables initialization of thePersistencePluginProxyvia configuration, without requiring any code changes or the creation of any actors.ReplayFilter$ INTERNAL APISingleEventSeq SingleEventSeq$ Tagged The journal may support tagging of events that are used by theEventsByTagquery and it may support specifying the tags via anEventAdapterthat wraps the events in aTaggedwith the giventags.Tagged$ -
Exception Summary Exception Description AsyncReplayTimeoutException Thrown if replay inactivity exceeds a specified timeout.