package internal
- Alphabetic
- Public
- Protected
Type Members
- trait FallbackStore[Breadcrumb <: AnyRef] extends AnyRef
INTERNAL API API MAY CHANGE
INTERNAL API API MAY CHANGE
Plugin API for a fallback store for events and snapshots. The journal and snapshot store implementations may, if configured to use an implementation of this API, use this fallback store to store events (resp. snapshots) while only storing a reference (aka "breadcrumb") returned by the plugin in the journal (resp. snapshot store). The event or 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()
- 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
- final case class SnapshotItemWithBreadcrumb(persistenceId: String, seqNr: Long, breadcrumb: (Int, String, Array[Byte])) extends ItemInSnapshotStore with Product with Serializable
Value Members
- object DynamoDBSizeCalculations
- object FallbackStore
INTERNAL API
INTERNAL API
- Annotations
- @InternalApi()
- object FallbackStoreProvider extends ExtensionId[FallbackStoreProvider]
INTERNAL API
INTERNAL API
- Annotations
- @InternalApi()