c
com.digitalasset.canton.synchronizer.sequencer.store.DbSequencerStore
DeliverStoreEventRow
Companion object DeliverStoreEventRow
case class DeliverStoreEventRow[P](timestamp: CantonTimestamp, instanceIndex: Int, eventType: EventTypeDiscriminator, messageIdO: Option[MessageId] = None, senderO: Option[SequencerMemberId] = None, recipientsO: Option[NonEmpty[SortedSet[SequencerMemberId]]] = None, payloadO: Option[P] = None, topologyTimestampO: Option[CantonTimestamp] = None, traceContext: TraceContext, errorO: Option[ByteString], trafficReceiptO: Option[TrafficReceipt]) extends Product with Serializable
- trafficReceiptO
If traffic management is enabled, there should always be traffic information for the sender. 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.
Linear Supertypes
Ordering
- Alphabetic
- By Inheritance
Inherited
- DeliverStoreEventRow
- Serializable
- Product
- Equals
- AnyRef
- Any
- Hide All
- Show All
Visibility
- Public
- Protected
Instance Constructors
- new DeliverStoreEventRow(timestamp: CantonTimestamp, instanceIndex: Int, eventType: EventTypeDiscriminator, messageIdO: Option[MessageId] = None, senderO: Option[SequencerMemberId] = None, recipientsO: Option[NonEmpty[SortedSet[SequencerMemberId]]] = None, payloadO: Option[P] = None, topologyTimestampO: Option[CantonTimestamp] = None, traceContext: TraceContext, errorO: Option[ByteString], trafficReceiptO: Option[TrafficReceipt])
- trafficReceiptO
If traffic management is enabled, there should always be traffic information for the sender. 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.
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
- lazy val asStoreEvent: Either[String, Sequenced[P]]
- def clone(): AnyRef
- Attributes
- protected[lang]
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.CloneNotSupportedException]) @IntrinsicCandidate() @native()
- final def eq(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
- val errorO: Option[ByteString]
- val eventType: EventTypeDiscriminator
- final def getClass(): Class[_ <: AnyRef]
- Definition Classes
- AnyRef → Any
- Annotations
- @IntrinsicCandidate() @native()
- val instanceIndex: Int
- final def isInstanceOf[T0]: Boolean
- Definition Classes
- Any
- val messageIdO: Option[MessageId]
- final def ne(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
- final def notify(): Unit
- Definition Classes
- AnyRef
- Annotations
- @IntrinsicCandidate() @native()
- final def notifyAll(): Unit
- Definition Classes
- AnyRef
- Annotations
- @IntrinsicCandidate() @native()
- val payloadO: Option[P]
- def productElementNames: Iterator[String]
- Definition Classes
- Product
- val recipientsO: Option[NonEmpty[SortedSet[SequencerMemberId]]]
- val senderO: Option[SequencerMemberId]
- final def synchronized[T0](arg0: => T0): T0
- Definition Classes
- AnyRef
- val timestamp: CantonTimestamp
- val topologyTimestampO: Option[CantonTimestamp]
- val traceContext: TraceContext
- val trafficReceiptO: Option[TrafficReceipt]
- 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])