package internal
- Alphabetic
- Public
- Protected
Type Members
- trait CommonFallbackStore[Breadcrumb <: AnyRef] extends AnyRef
INTERNAL API API MAY CHANGE
INTERNAL API API MAY CHANGE
Do not inherit directly from this interface. Instead inherit one or both of
EventFallbackStore
orSnapshotFallbackStore
- Annotations
- @ApiMayChange() @InternalApi()
- trait EventFallbackStore[Breadcrumb <: AnyRef] extends CommonFallbackStore[Breadcrumb]
INTERNAL API API MAY CHANGE
INTERNAL API API MAY CHANGE
Plugin API for a fallback store for events. The journal implementations may, if configured to use an implementation of this API, use this fallback store to store events while only storing a reference (aka "breadcrumb") returned by the plugin in the journal. The event can then be retrieved by providing the breadcrumb.
Implementations must have a constructor taking an actor system, a Config object, and the config path
- Breadcrumb
the type of breadcrumb emitted and aceepted by this store: this type should have an Akka serializer registered and may not be generic
- Annotations
- @ApiMayChange() @InternalApi()
- class FallbackStoreProvider extends Extension
INTERNAL API
INTERNAL API
- Annotations
- @InternalApi()
- sealed trait ItemInJournal extends AnyRef
- sealed trait ItemInSnapshotStore extends AnyRef
- final case class JournalItemWithBreadcrumb(persistenceId: String, seqNr: Long, writeTimestamp: Instant, readTimestamp: Instant, writerUuid: String, tags: Set[String], metadata: Option[SerializedEventMetadata], breadcrumbSerId: Int, breadcrumbSerManifest: String, breadcrumbPayload: Option[Array[Byte]]) extends ItemInJournal with Product with Serializable
- final case class SerializedEventMetadata(serId: Int, serManifest: String, payload: Array[Byte]) extends Product with Serializable
- final case class SerializedJournalItem(persistenceId: String, seqNr: Long, writeTimestamp: Instant, readTimestamp: Instant, payload: Option[Array[Byte]], serId: Int, serManifest: String, writerUuid: String, tags: Set[String], metadata: Option[SerializedEventMetadata]) extends SerializedItem with ItemInJournal with Product with Serializable
- final case class SerializedSnapshotItem(persistenceId: String, seqNr: Long, writeTimestamp: Instant, eventTimestamp: Instant, payload: Array[Byte], serId: Int, serManifest: String, tags: Set[String], metadata: Option[SerializedSnapshotMetadata]) extends SerializedItem with ItemInSnapshotStore with Product with Serializable
- final case class SerializedSnapshotMetadata(serId: Int, serManifest: String, payload: Array[Byte]) extends Product with Serializable
- trait SnapshotFallbackStore[Breadcrumb <: AnyRef] extends CommonFallbackStore[Breadcrumb]
INTERNAL API API MAY CHANGE
INTERNAL API API MAY CHANGE
Plugin API for a fallback store for snapshots. The snapshot store implementations may, if configured to use an implementation of this API, use this fallback store to store snapshots while only storing a reference (aka "breadcrumb") returned by the plugin in the snapshot store. The snapshot can then be retrieved by providing the breadcrumb.
Implementations must have a constructor taking an actor system, a Config object, and the config path
- Breadcrumb
the type of breadcrumb emitted and aceepted by this store: this type should have an Akka serializer registered and may not be generic
- Annotations
- @ApiMayChange() @InternalApi()
- final case class SnapshotItemWithBreadcrumb(persistenceId: String, seqNr: Long, breadcrumb: (Int, String, Array[Byte])) extends ItemInSnapshotStore with Product with Serializable
Value Members
- object DynamoDBSizeCalculations
- object EventFallbackStore
- Annotations
- @InternalApi()
- object FallbackStoreProvider extends ExtensionId[FallbackStoreProvider]
INTERNAL API
INTERNAL API
- Annotations
- @InternalApi()
- object SnapshotFallbackStore
- Annotations
- @InternalApi()