package store

Ordering
  1. Alphabetic
Visibility
  1. Public
  2. Protected

Type Members

  1. case class CounterCheckpoint(counter: SequencerCounter, timestamp: CantonTimestamp) extends Product with Serializable

    Records when a memberId was registered

  2. class DbSequencerStore extends SequencerStore with NamedLogging

    Database backed sequencer store.

    Database backed sequencer store. Supports many concurrent instances reading and writing to the same backing database.

  3. case class DeliverErrorStoreEvent(sender: SequencerMemberId, messageId: MessageId, message: String, traceContext: TraceContext) extends StoreEvent[Nothing] with Product with Serializable
  4. case class DeliverStoreEvent[P](sender: SequencerMemberId, messageId: MessageId, members: NonEmptySet[SequencerMemberId], payload: P, signingTimestampO: Option[CantonTimestamp], traceContext: TraceContext) extends StoreEvent[P] with Product with Serializable

    Structure for storing a deliver events.

    Structure for storing a deliver events.

    members

    should include the sender and event recipients as they all will read the event

  5. class HASequencerWriterStore extends SequencerWriterStore with FlagCloseable with NamedLogging

    Sequencer writer storage intended to use a resource.DbStorageMulti.

  6. case class HeartbeatStoreEvent(traceContext: TraceContext) extends StoreEvent[Nothing] with Product with Serializable

    Heartbeats will be received by all members and have no payloads (they just carry the timestamp).

  7. class InMemorySequencerStore extends SequencerStore
  8. sealed trait IsEnabledError extends AnyRef
  9. case class Payload(id: PayloadId, content: ByteString) extends Product with Serializable

    Payload with a assigned id and content as bytes

  10. case class PayloadId(str: String36) extends LengthLimitedStringWrapper with Product with Serializable

    Identifier for a payload.

    Identifier for a payload. Must be globally unique.

  11. case class Presequenced[+E <: StoreEvent[_]](event: E, maxSequencingTimeO: Option[CantonTimestamp]) extends HasTraceContext with Product with Serializable
  12. case class RegisteredMember(memberId: SequencerMemberId, registeredFrom: CantonTimestamp) extends Product with Serializable
  13. sealed trait SaveCounterCheckpointError extends AnyRef
  14. sealed trait SaveLowerBoundError extends AnyRef
  15. sealed trait SaveWatermarkError extends AnyRef
  16. case class Sequenced[+P](timestamp: CantonTimestamp, event: StoreEvent[P]) extends HasTraceContext with Product with Serializable

    Wrapper to assign a timestamp to a event.

    Wrapper to assign a timestamp to a event. Useful to structure this way as events are only timestamped right before they are persisted (this is effectively the "sequencing" step). Before this point the sequencer component is free to reorder incoming events.

  17. class SequencerMemberCache extends AnyRef

    Read through async cache with no eviction (as members should be immutable).

    Read through async cache with no eviction (as members should be immutable). Members will only be cached if entries are found.

  18. case class SequencerMemberId(id: Int) extends Product with Serializable

    In the sequencer database we use integers to represent members.

    In the sequencer database we use integers to represent members. Wrap this in the APIs to not confuse with other numeric types.

  19. trait SequencerStore extends NamedLogging

    Persistence for the Sequencer.

    Persistence for the Sequencer. Writers are expected to create a SequencerWriterStore which may delegate to this underlying store through an appropriately managed storage instance.

  20. trait SequencerWriterStore extends AutoCloseable

    A subset of the sequencer storage methods required by the SequencerWriter with convenience methods to avoid passing the instanceIndex everywhere.

  21. sealed trait StoreEvent[+PayloadReference] extends HasTraceContext

    Sequencer events in a structure suitable for persisting in our events store.

    Sequencer events in a structure suitable for persisting in our events store. The payload type is parameterized to allow specifying either a full payload or just a id referencing a payload.

  22. class UniqueKeyViolationException extends RuntimeException

    Thrown when a record that must be unique is inserted with a non-unique key.

    Thrown when a record that must be unique is inserted with a non-unique key. Mirrors the type of exceptions that we would expect to see from a database.

  23. case class Watermark(timestamp: CantonTimestamp, online: Boolean) extends Product with Serializable

    Time that the sequencer commits to not writing events before, and therefore it is safe to read events less or equal to this timestamp.

Ungrouped