com.digitalasset.canton.synchronizer.sequencer.store
DeliverStoreEvent
Companion object DeliverStoreEvent
final case class DeliverStoreEvent[P](sender: SequencerMemberId, messageId: MessageId, members: NonEmpty[SortedSet[SequencerMemberId]], payload: P, topologyTimestampO: Option[CantonTimestamp], traceContext: TraceContext, trafficReceiptO: Option[TrafficReceipt]) extends StoreEvent[P] with Product with Serializable
Structure for storing a deliver events.
- members
should include the sender and event recipients as they all will read the event
- topologyTimestampO
The timestamp of the snapshot to be used for determining the signing key of this event, resolving group addresses, and for checking signatures on envelopes scala.None means that the sequencing timestamp should be used.
- Alphabetic
- By Inheritance
- DeliverStoreEvent
- Serializable
- Product
- Equals
- StoreEvent
- HasTraceContext
- AnyRef
- Any
- Hide All
- Show All
- Public
- Protected
Instance Constructors
- new DeliverStoreEvent(sender: SequencerMemberId, messageId: MessageId, members: NonEmpty[SortedSet[SequencerMemberId]], payload: P, topologyTimestampO: Option[CantonTimestamp], traceContext: TraceContext, trafficReceiptO: Option[TrafficReceipt])
- members
should include the sender and event recipients as they all will read the event
- topologyTimestampO
The timestamp of the snapshot to be used for determining the signing key of this event, resolving group addresses, and for checking signatures on envelopes scala.None means that the sequencing timestamp should be used.
Value Members
- final def !=(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
- final def ##: Int
- Definition Classes
- AnyRef → Any
- final def ==(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
- final def asInstanceOf[T0]: T0
- Definition Classes
- Any
- def clone(): AnyRef
- Attributes
- protected[lang]
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.CloneNotSupportedException]) @IntrinsicCandidate() @native()
- val description: String
Description of the event to be used in logs
Description of the event to be used in logs
- Definition Classes
- DeliverStoreEvent → StoreEvent
- final def eq(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
- final def getClass(): Class[_ <: AnyRef]
- Definition Classes
- AnyRef → Any
- Annotations
- @IntrinsicCandidate() @native()
- final def isInstanceOf[T0]: Boolean
- Definition Classes
- Any
- def map[P2](f: (P) => P2): StoreEvent[P2]
- Definition Classes
- DeliverStoreEvent → StoreEvent
- val members: NonEmpty[SortedSet[SequencerMemberId]]
All members that should receive (parts of) this event
All members that should receive (parts of) this event
- Definition Classes
- DeliverStoreEvent → StoreEvent
- val messageId: MessageId
- Definition Classes
- DeliverStoreEvent → StoreEvent
- final def ne(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
- lazy val notifies: WriteNotification
Who gets notified of the event once it is successfully sequenced
Who gets notified of the event once it is successfully sequenced
- Definition Classes
- DeliverStoreEvent → StoreEvent
- final def notify(): Unit
- Definition Classes
- AnyRef
- Annotations
- @IntrinsicCandidate() @native()
- final def notifyAll(): Unit
- Definition Classes
- AnyRef
- Annotations
- @IntrinsicCandidate() @native()
- val payload: P
- def payloadO: Option[P]
- Definition Classes
- DeliverStoreEvent → StoreEvent
- def productElementNames: Iterator[String]
- Definition Classes
- Product
- val sender: SequencerMemberId
- Definition Classes
- DeliverStoreEvent → StoreEvent
- final def synchronized[T0](arg0: => T0): T0
- Definition Classes
- AnyRef
- val topologyTimestampO: Option[CantonTimestamp]
The timestamp of the snapshot to be used for determining the signing key of this event, resolving group addresses, and for checking signatures on envelopes, if absent, sequencing time will be used instead.
The timestamp of the snapshot to be used for determining the signing key of this event, resolving group addresses, and for checking signatures on envelopes, if absent, sequencing time will be used instead. Absent on errors.
- Definition Classes
- DeliverStoreEvent → StoreEvent
- val traceContext: TraceContext
- Definition Classes
- DeliverStoreEvent → HasTraceContext
- val trafficReceiptO: Option[TrafficReceipt]
If traffic management is enabled, there should always be traffic information.
If traffic management is enabled, there should always be traffic information. The information might be discarded later though, in case the event is being processed as part of a subscription for any of the recipients that isn't the sender.
- Definition Classes
- DeliverStoreEvent → StoreEvent
- final def wait(arg0: Long, arg1: Int): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.InterruptedException])
- final def wait(arg0: Long): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.InterruptedException]) @native()
- final def wait(): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.InterruptedException])