 | Akka.Persistence.Journal Namespace |
Classes| Class | Description | |
|---|---|---|
 | AsyncReplayTimeoutException |
This exception is thrown when the replay inactivity exceeds a specified timeout.
|
| AsyncWriteJournal |
Abstract journal, optimized for asynchronous, non-blocking writes.
|
| AsyncWriteProxy |
A journal that delegates actual storage to a target actor. For testing only.
|
| AsyncWriteProxyInitTimeout |
TBD
|
| AsyncWriteTarget |
TBD
|
| AsyncWriteTargetDeleteMessagesTo |
TBD
|
| AsyncWriteTargetReplayFailure |
TBD
|
| AsyncWriteTargetReplayMessages |
TBD
|
| AsyncWriteTargetReplaySuccess |
TBD
|
| AsyncWriteTargetWriteMessages |
TBD
|
| CombinedReadEventAdapter |
TBD
|
| EmptyEventSequence |
TBD
|
| EventAdapters |
TBD
|
| EventSequence |
TBD
|
| EventSequenceT |
TBD
|
| IdentityEventAdapter |
No-op model adapter which passes through the incoming events as-is.
|
| MemoryJournal |
In-memory journal for testing purposes.
|
| PersistencePluginProxy |
TBD
|
| PersistencePluginProxyTargetLocation |
TBD
|
| PersistencePluginProxyExtension | PersistencePluginProxyExtension is an IExtension that enables initialization
of the PersistencePluginProxy via configuration, without requiring any code changes or the
creation of any actors.
|
| ReplayFilter |
Detect corrupt event stream during replay. It uses the WriterGuid and the
SequenceNr in the replayed events to find events emitted by overlapping writers.
|
| SetStore |
TBD
|
| SharedMemoryJournal |
TBD
|
| WriteJournalBase |
TBD
|
Structures| Structure | Description | |
|---|---|---|
 | SingleEventSequence |
TBD
|
| Tagged |
The journal may support tagging of events that are used by the
`EventsByTag` query and it may support specifying the tags via an
IEventAdapter that wraps the events
in a Tagged with the given Tags. 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.
|
Interfaces| Interface | Description | |
|---|---|---|
 | IAsyncRecovery |
TBD
|
| IEmptyEventSequence |
TBD
|
| IEventAdapter | An IEventAdapter is both a IWriteEventAdapter and a IReadEventAdapter. 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 |
| IEventSequence |
TBD
|
| IMemoryMessages |
TBD
|
| IReadEventAdapter | Facility to convert from 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" |
| IWriteEventAdapter | 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 |
Enumerations| Enumeration | Description | |
|---|---|---|
 | ReplayFilterMode |
TBD
|