package internal

Ordering
  1. Alphabetic
Visibility
  1. Public
  2. Protected

Type Members

  1. 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 or SnapshotFallbackStore

    Annotations
    @ApiMayChange() @InternalApi()
  2. 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()
  3. class FallbackStoreProvider extends Extension

    INTERNAL API

    INTERNAL API

    Annotations
    @InternalApi()
  4. sealed trait ItemInJournal extends AnyRef
  5. sealed trait ItemInSnapshotStore extends AnyRef
  6. 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
  7. final case class SerializedEventMetadata(serId: Int, serManifest: String, payload: Array[Byte]) extends Product with Serializable
  8. 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
  9. 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
  10. final case class SerializedSnapshotMetadata(serId: Int, serManifest: String, payload: Array[Byte]) extends Product with Serializable
  11. 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()
  12. final case class SnapshotItemWithBreadcrumb(persistenceId: String, seqNr: Long, breadcrumb: (Int, String, Array[Byte])) extends ItemInSnapshotStore with Product with Serializable

Value Members

  1. object DynamoDBSizeCalculations
  2. object EventFallbackStore
    Annotations
    @InternalApi()
  3. object FallbackStoreProvider extends ExtensionId[FallbackStoreProvider]

    INTERNAL API

    INTERNAL API

    Annotations
    @InternalApi()
  4. object SnapshotFallbackStore
    Annotations
    @InternalApi()

Ungrouped