class SequencerServiceBlockingStub extends AbstractStub[SequencerServiceBlockingStub] with SequencerServiceBlockingClient
- Alphabetic
- By Inheritance
- SequencerServiceBlockingStub
- SequencerServiceBlockingClient
- AbstractStub
- AnyRef
- Any
- Hide All
- Show All
- Public
- Protected
Instance Constructors
- new SequencerServiceBlockingStub(channel: Channel, options: CallOptions = _root_.io.grpc.CallOptions.DEFAULT)
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
- def acknowledge(request: AcknowledgeRequest): Empty
Allows a member to acknowledge that they have read all events up to and including the provided timestamp, and that they will never re-read these events again.
Allows a member to acknowledge that they have read all events up to and including the provided timestamp, and that they will never re-read these events again. This information is currently only used for informational purposes and to provide a watermark for which it is safe to prune earlier events from the sequencer data stores. There is no requirement for every event to be individually acknowledged, and in fact callers are encouraged to only periodically record acknowledgements (at an interval of minutes is expected to be more than sufficient for pruning).
- Definition Classes
- SequencerServiceBlockingStub → SequencerServiceBlockingClient
- final def asInstanceOf[T0]: T0
- Definition Classes
- Any
- def build(channel: Channel, options: CallOptions): SequencerServiceBlockingStub
- Definition Classes
- SequencerServiceBlockingStub → AbstractStub
- 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 getCallOptions(): CallOptions
- Definition Classes
- AbstractStub
- final def getChannel(): Channel
- Definition Classes
- AbstractStub
- 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()
- def sendAsync(request: SubmissionRequest): SendAsyncResponse
Submit a send request to the sequencer for sequencing asynchronously.
Submit a send request to the sequencer for sequencing asynchronously. The rpc request may return an error if the request cannot be processed at all - see SendAsyncResponse for these scenarios. The sequencer may emit a Deliver or DeliverError event from this send, if the subscriber witnesses an event greater or equal to the supplied maxSequencingTime, the sequencer guarantees not to publish a future Deliver event for this send. The sequencer implementation may however publish a future DeliverError (typically used to indicate maxSequencingTime exceeded).
- Definition Classes
- SequencerServiceBlockingStub → SequencerServiceBlockingClient
- def sendAsyncUnauthenticated(request: SubmissionRequest): SendAsyncResponse
Submit a send request to the sequencer for sequencing asynchronously exactly like SendAsync, except that this meant to be used only by unauthenticated members for very specific operations that do not require authentication such as requesting that a participant's topology data gets accepted by the topology manager
Submit a send request to the sequencer for sequencing asynchronously exactly like SendAsync, except that this meant to be used only by unauthenticated members for very specific operations that do not require authentication such as requesting that a participant's topology data gets accepted by the topology manager
- Definition Classes
- SequencerServiceBlockingStub → SequencerServiceBlockingClient
- def serviceCompanion: SequencerService
- Definition Classes
- SequencerServiceBlockingClient
- def subscribe(request: SubscriptionRequest): Iterator[SubscriptionResponse]
Establishes a stream with the server to receive sequenced events from the domain after the given counter.
Establishes a stream with the server to receive sequenced events from the domain after the given counter. The delivered events will have a sequential counter and monotonically increasing timestamp. TBD: Message TTL - How far back should it go when the participant initiate a subscription ?
- Definition Classes
- SequencerServiceBlockingStub → SequencerServiceBlockingClient
- def subscribeUnauthenticated(request: SubscriptionRequest): Iterator[SubscriptionResponse]
Establishes a stream with the server to receive sequenced events exactly like Subscribe, except that this is supposed to be used only by unauthenticated members similarly to SendAsyncUnauthenticated
Establishes a stream with the server to receive sequenced events exactly like Subscribe, except that this is supposed to be used only by unauthenticated members similarly to SendAsyncUnauthenticated
- Definition Classes
- SequencerServiceBlockingStub → SequencerServiceBlockingClient
- 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])
- final def withCallCredentials(arg0: CallCredentials): SequencerServiceBlockingStub
- Definition Classes
- AbstractStub
- final def withCompression(arg0: String): SequencerServiceBlockingStub
- Definition Classes
- AbstractStub
- final def withDeadline(arg0: Deadline): SequencerServiceBlockingStub
- Definition Classes
- AbstractStub
- final def withDeadlineAfter(arg0: Long, arg1: TimeUnit): SequencerServiceBlockingStub
- Definition Classes
- AbstractStub
- final def withExecutor(arg0: Executor): SequencerServiceBlockingStub
- Definition Classes
- AbstractStub
- final def withInterceptors(arg0: <repeated...>[ClientInterceptor]): SequencerServiceBlockingStub
- Definition Classes
- AbstractStub
- Annotations
- @transient()
- final def withMaxInboundMessageSize(arg0: Int): SequencerServiceBlockingStub
- Definition Classes
- AbstractStub
- final def withMaxOutboundMessageSize(arg0: Int): SequencerServiceBlockingStub
- Definition Classes
- AbstractStub
- final def withOption[T <: AnyRef](arg0: Key[T], arg1: T): SequencerServiceBlockingStub
- Definition Classes
- AbstractStub
- final def withWaitForReady(): SequencerServiceBlockingStub
- Definition Classes
- AbstractStub
Deprecated Value Members
- def finalize(): Unit
- Attributes
- protected[lang]
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.Throwable]) @Deprecated
- Deprecated
- final def withChannel(arg0: Channel): SequencerServiceBlockingStub
- Definition Classes
- AbstractStub
- Annotations
- @Deprecated
- Deprecated