object Sequencer extends HasLoggerName
- Alphabetic
- By Inheritance
- Sequencer
- HasLoggerName
- AnyRef
- Any
- Hide All
- Show All
- Public
- Protected
Type Members
- type RegisterError = SequencerWriteError[RegisterMemberError]
- type SenderSigned[A <: HasCryptographicEvidence] = SignedContent[A]
Type alias for a content that is signed by the sender (as in, whoever sent the SubmissionRequest to the sequencer).
Type alias for a content that is signed by the sender (as in, whoever sent the SubmissionRequest to the sequencer). Note that the sequencer itself can be the "sender": for instance when processing balance updates for traffic control, the sequencer will craft a SetTrafficPurchased protocol message and sign it as the "sender".
- type SequencedEventSource = Source[SequencedEventOrError, (KillSwitch, FutureUnlessShutdown[Done])]
The materialized future completes when all internal side-flows of the source have completed after the kill switch was pulled.
The materialized future completes when all internal side-flows of the source have completed after the kill switch was pulled. Termination of the main flow must be awaited separately.
- type SequencerSigned[A <: HasCryptographicEvidence] = SignedContent[OrderingRequest[SenderSigned[A]]]
Type alias for content that has been signed by the sequencer.
Type alias for content that has been signed by the sequencer. The purpose of this is to identify which sequencer has processed a submission request, such that after the request is ordered and processed by all sequencers, each sequencer knows which sequencer received the submission request. The signature here will always be one of a sequencer.
- type SignedOrderingRequest = SignedContent[OrderingRequest[SenderSigned[SubmissionRequest]]]
Ordering request signed by the sequencer.
Ordering request signed by the sequencer. Outer signature is the signature of the sequencer that received the submission request. Inner signature is the signature of the member from which the submission request originated.
┌─────────────────┐ ┌────────────┐ │SenderSigned │ │Sequencer │ ┌─────────────────┐ │ ┌──────────────┤ │ │ │Sender │signs │ │Submission │sends │ │ │(e.g participant)├───────►│ │Request ├──────►│ │ └─────────────────┘ └──┴──────────────┘ └─────┬──────┘ │ │signs ▼ ┌──────────────────────┐ │SequencerSigned │ │ ┌────────────────────┤ send to │ │SenderSigned │ ordering│ │ ┌──────────────────┤ ◄────────┤ │ │Submission │ │ │ │Request │ └─┴─┴──────────────────┘
- implicit final class SignedOrderingRequestOps extends AnyVal
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()
- final def eq(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
- def equals(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef → Any
- implicit def errorLoggingContextFromNamedLoggingContext(implicit loggingContext: NamedLoggingContext): ErrorLoggingContext
Convert a com.digitalasset.canton.logging.NamedLoggingContext into an com.digitalasset.canton.logging.ErrorLoggingContext to fix the logger name to the current class name.
Convert a com.digitalasset.canton.logging.NamedLoggingContext into an com.digitalasset.canton.logging.ErrorLoggingContext to fix the logger name to the current class name.
- Attributes
- protected
- Definition Classes
- HasLoggerName
- final def getClass(): Class[_ <: AnyRef]
- Definition Classes
- AnyRef → Any
- Annotations
- @IntrinsicCandidate() @native()
- def hashCode(): Int
- Definition Classes
- AnyRef → Any
- Annotations
- @IntrinsicCandidate() @native()
- val healthName: String
- final def isInstanceOf[T0]: Boolean
- Definition Classes
- Any
- implicit def loggerNameFromThisClass: LoggerNameFromClass
- Attributes
- protected
- Definition Classes
- HasLoggerName
- 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()
- final def synchronized[T0](arg0: => T0): T0
- Definition Classes
- AnyRef
- def toString(): String
- Definition Classes
- AnyRef → Any
- 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])