Packages

package internal

Ordering
  1. Alphabetic
Visibility
  1. Public
  2. Protected

Type Members

  1. 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()
  2. class FallbackStoreProvider extends Extension

    INTERNAL API

    INTERNAL API

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

    INTERNAL API

    INTERNAL API

    Annotations
    @InternalApi()
  3. object FallbackStoreProvider extends ExtensionId[FallbackStoreProvider]

    INTERNAL API

    INTERNAL API

    Annotations
    @InternalApi()

Ungrouped