trait BlockSequencerOps extends AutoCloseable
- Alphabetic
- By Inheritance
- BlockSequencerOps
- AutoCloseable
- AnyRef
- Any
- Hide All
- Show All
- Public
- Protected
Abstract Value Members
- abstract def close(): Unit
- Definition Classes
- AutoCloseable
- Annotations
- @throws(classOf[java.lang.Exception])
- abstract def health(implicit traceContext: TraceContext): Future[SequencerDriverHealthStatus]
- abstract 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.
- abstract 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.
- abstract 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.
Concrete 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() @HotSpotIntrinsicCandidate()
- 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() @HotSpotIntrinsicCandidate()
- def hashCode(): Int
- Definition Classes
- AnyRef → Any
- Annotations
- @native() @HotSpotIntrinsicCandidate()
- 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() @HotSpotIntrinsicCandidate()
- final def notifyAll(): Unit
- Definition Classes
- AnyRef
- Annotations
- @native() @HotSpotIntrinsicCandidate()
- 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])