- case class CounterCheckpoint(counter: SequencerCounter, timestamp: CantonTimestamp) extends Product with Serializable
Records when a memberId was registered
- class DbSequencerStore extends SequencerStore with NamedLogging
Database backed sequencer store.
- case class DeliverErrorStoreEvent(sender: SequencerMemberId, messageId: MessageId, message: String, traceContext: TraceContext) extends StoreEvent[Nothing] with Product with Serializable
- 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.
should include the sender and event recipients as they all will read the event
- class HASequencerWriterStore extends SequencerWriterStore with FlagCloseable with NamedLogging
Sequencer writer storage intended to use a resource.DbStorageMulti.
- 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).
- class InMemorySequencerStore extends SequencerStore
- sealed trait IsEnabledError extends AnyRef
- case class Payload(id: PayloadId, content: ByteString) extends Product with Serializable
Payload with a assigned id and content as bytes
- case class PayloadId(str: String36) extends LengthLimitedStringWrapper with Product with Serializable
Identifier for a payload.
- case class Presequenced[+E <: StoreEvent[_]](event: E, maxSequencingTimeO: Option[CantonTimestamp]) extends HasTraceContext with Product with Serializable
- case class RegisteredMember(memberId: SequencerMemberId, registeredFrom: CantonTimestamp) extends Product with Serializable
- sealed trait SaveCounterCheckpointError extends AnyRef
- sealed trait SaveLowerBoundError extends AnyRef
- sealed trait SaveWatermarkError extends AnyRef
- case class Sequenced[+P](timestamp: CantonTimestamp, event: StoreEvent[P]) extends HasTraceContext with Product with Serializable
Wrapper to assign a timestamp to a event.
- class SequencerMemberCache extends AnyRef
Read through async cache with no eviction (as members should be immutable).
- case class SequencerMemberId(id: Int) extends Product with Serializable
In the sequencer database we use integers to represent members.
- trait SequencerStore extends NamedLogging
Persistence for the Sequencer.
- trait SequencerWriterStore extends AutoCloseable
A subset of the sequencer storage methods required by the SequencerWriter with convenience methods to avoid passing the
- sealed trait StoreEvent[+PayloadReference] extends HasTraceContext
Sequencer events in a structure suitable for persisting in our events store.
- class UniqueKeyViolationException extends RuntimeException
Thrown when a record that must be unique is inserted with a non-unique key.
- 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.
- object CounterCheckpoint extends Serializable
- object DeliverStoreEvent extends Serializable
- object IsEnabledError
- object PayloadId extends LengthLimitedStringWrapperCompanion[String36, PayloadId] with Serializable
- object Presequenced extends Serializable
- object SaveCounterCheckpointError
- object SaveLowerBoundError
- object SaveWatermarkError
- object SequencerMemberId extends Serializable
- object SequencerStore
- object SequencerWriterStore