class DriverBlockSequencerOps extends BlockSequencerOps
- Alphabetic
- By Inheritance
- DriverBlockSequencerOps
- BlockSequencerOps
- AutoCloseable
- AnyRef
- Any
- Hide All
- Show All
- Public
- Protected
Instance Constructors
- new DriverBlockSequencerOps(driver: SequencerDriver, protocolVersion: ProtocolVersion)(implicit executionContext: ExecutionContext)
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]) @native() @IntrinsicCandidate()
- def close(): Unit
- Definition Classes
- DriverBlockSequencerOps → AutoCloseable
- final def eq(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
- def equals(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef → Any
- final def getClass(): Class[_ <: AnyRef]
- Definition Classes
- AnyRef → Any
- Annotations
- @native() @IntrinsicCandidate()
- def hashCode(): Int
- Definition Classes
- AnyRef → Any
- Annotations
- @native() @IntrinsicCandidate()
- def health(implicit traceContext: TraceContext): Future[SequencerDriverHealthStatus]
- Definition Classes
- DriverBlockSequencerOps → BlockSequencerOps
- final def isInstanceOf[T0]: Boolean
- Definition Classes
- Any
- final def ne(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
- final def notify(): Unit
- Definition Classes
- AnyRef
- Annotations
- @native() @IntrinsicCandidate()
- final def notifyAll(): Unit
- Definition Classes
- AnyRef
- Annotations
- @native() @IntrinsicCandidate()
- def register(member: Member)(implicit traceContext: TraceContext): EitherT[Future, SequencerWriteError[RegisterMemberError], Unit]
Register the given member.
Register the given member. Results in a com.digitalasset.canton.domain.block.RawLedgerBlock.RawBlockEvent.AddMember.
- Definition Classes
- DriverBlockSequencerOps → BlockSequencerOps
- def send(signedSubmission: SignedContent[SubmissionRequest])(implicit traceContext: TraceContext): EitherT[Future, SendAsyncError, Unit]
Send a submission request.
Send a submission request. Results in a com.digitalasset.canton.domain.block.RawLedgerBlock.RawBlockEvent.Send.
- Definition Classes
- DriverBlockSequencerOps → BlockSequencerOps
- def subscribe()(implicit traceContext: TraceContext): Source[RawLedgerBlock, KillSwitch]
Delivers a stream of blocks starting with
firstBlockHeight(if specified in the factory call) or the first block serveable.Delivers a stream of blocks starting with
firstBlockHeight(if specified in the factory call) or the first block serveable. Block heights must be consecutive.If
firstBlockHeightrefers to a block whose sequencing number the sequencer node has not yet observed, returns a source that will eventually serve that block when it gets created.Must succeed if an earlier call to
subscribedelivered a block with heightfirstBlockHeightunless the block has been pruned in between, in which case it failsMust succeed if an earlier call to
subscribedelivered a block with heightfirstBlockHeightunless the block has been pruned in between.This method will be called only once, so implementations do not have to try to create separate sources on every call to this method. It is acceptable to for the driver to have one internal source and just return it here.
- Definition Classes
- DriverBlockSequencerOps → BlockSequencerOps
- 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])