Packages

class SequencerServiceBlockingStub extends AbstractStub[SequencerServiceBlockingStub] with SequencerServiceBlockingClient

Ordering
  1. Alphabetic
  2. By Inheritance
Inherited
  1. SequencerServiceBlockingStub
  2. SequencerServiceBlockingClient
  3. AbstractStub
  4. AnyRef
  5. Any
  1. Hide All
  2. Show All
Visibility
  1. Public
  2. Protected

Instance Constructors

  1. new SequencerServiceBlockingStub(channel: Channel, options: CallOptions = _root_.io.grpc.CallOptions.DEFAULT)

Value Members

  1. final def !=(arg0: Any): Boolean
    Definition Classes
    AnyRef → Any
  2. final def ##: Int
    Definition Classes
    AnyRef → Any
  3. final def ==(arg0: Any): Boolean
    Definition Classes
    AnyRef → Any
  4. 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
    SequencerServiceBlockingStubSequencerServiceBlockingClient
  5. def acknowledgeSigned(request: SignedContent): Empty

    Newer version of acknowledgements.

    Newer version of acknowledgements. To be active for protocol versions >= 4. The argument here is an AcknowledgeRequest wrapped in SignedContent. The signature is checked on the server side to avoid that malicious sequencers create fake acknowledgements in multi-writer architectures where writers don't fully trust each other.

    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
    SequencerServiceBlockingStubSequencerServiceBlockingClient
  6. final def asInstanceOf[T0]: T0
    Definition Classes
    Any
  7. def build(channel: Channel, options: CallOptions): SequencerServiceBlockingStub
    Definition Classes
    SequencerServiceBlockingStub → AbstractStub
  8. def clone(): AnyRef
    Attributes
    protected[lang]
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.CloneNotSupportedException]) @native() @HotSpotIntrinsicCandidate()
  9. def downloadTopologyStateForInit(request: TopologyStateForInitRequest): Iterator[TopologyStateForInitResponse]

    Download the topology state for a member up to including the topology transaction that made the member known on the domain.

    Download the topology state for a member up to including the topology transaction that made the member known on the domain.

    Definition Classes
    SequencerServiceBlockingStubSequencerServiceBlockingClient
  10. final def eq(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef
  11. def equals(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef → Any
  12. final def getCallOptions(): CallOptions
    Definition Classes
    AbstractStub
  13. final def getChannel(): Channel
    Definition Classes
    AbstractStub
  14. final def getClass(): Class[_ <: AnyRef]
    Definition Classes
    AnyRef → Any
    Annotations
    @native() @HotSpotIntrinsicCandidate()
  15. def hashCode(): Int
    Definition Classes
    AnyRef → Any
    Annotations
    @native() @HotSpotIntrinsicCandidate()
  16. final def isInstanceOf[T0]: Boolean
    Definition Classes
    Any
  17. final def ne(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef
  18. final def notify(): Unit
    Definition Classes
    AnyRef
    Annotations
    @native() @HotSpotIntrinsicCandidate()
  19. final def notifyAll(): Unit
    Definition Classes
    AnyRef
    Annotations
    @native() @HotSpotIntrinsicCandidate()
  20. 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). Used in protocol version 3

    Definition Classes
    SequencerServiceBlockingStubSequencerServiceBlockingClient
  21. def sendAsyncSigned(request: SignedContent): SendAsyncSignedResponse

    Newer version of request submission (for authenticated members).

    Newer version of request submission (for authenticated members). To be active for protocol versions 4. The argument here is a SubmissionRequest wrapped in SignedContent. The signature is checked on the server side to avoid that malicious sequencers create fake submission requests in multi-writer architectures where writers don't fully trust each other.

    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
    SequencerServiceBlockingStubSequencerServiceBlockingClient
  22. 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 Used in protocol versions 3 and 4

    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 Used in protocol versions 3 and 4

    Definition Classes
    SequencerServiceBlockingStubSequencerServiceBlockingClient
  23. def sendAsyncUnauthenticatedVersioned(request: SendAsyncUnauthenticatedVersionedRequest): SendAsyncResponse

    Submit a send request to the sequencer for sequencing asynchronously exactly like SendAsyncVersioned, 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 SendAsyncVersioned, 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

    Used in protocol version 5 or higher

    Definition Classes
    SequencerServiceBlockingStubSequencerServiceBlockingClient
  24. def sendAsyncVersioned(request: SendAsyncVersionedRequest): SendAsyncSignedResponse

    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).

    The signature is checked on the server side to avoid that malicious sequencers create fake submission requests in multi-writer architectures where writers don't fully trust each other.

    Used in protocol version 5 or higher

    Definition Classes
    SequencerServiceBlockingStubSequencerServiceBlockingClient
  25. def serviceCompanion: ServiceCompanion[SequencerService]
  26. 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
    SequencerServiceBlockingStubSequencerServiceBlockingClient
  27. 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
    SequencerServiceBlockingStubSequencerServiceBlockingClient
  28. def subscribeUnauthenticatedVersioned(request: SubscriptionRequest): Iterator[VersionedSubscriptionResponse]

    Same as SubscribeUnauthenticated(SubscriptionRequest) but delivers byte array rather than typed message to support multiple versions.

    Same as SubscribeUnauthenticated(SubscriptionRequest) but delivers byte array rather than typed message to support multiple versions.

    Definition Classes
    SequencerServiceBlockingStubSequencerServiceBlockingClient
  29. def subscribeVersioned(request: SubscriptionRequest): Iterator[VersionedSubscriptionResponse]

    Same as Subscribe(SubscriptionRequest) but delivers byte array rather than typed message to support multiple versions.

    Same as Subscribe(SubscriptionRequest) but delivers byte array rather than typed message to support multiple versions.

    Definition Classes
    SequencerServiceBlockingStubSequencerServiceBlockingClient
  30. final def synchronized[T0](arg0: => T0): T0
    Definition Classes
    AnyRef
  31. def toString(): String
    Definition Classes
    AnyRef → Any
  32. final def wait(arg0: Long, arg1: Int): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.InterruptedException])
  33. final def wait(arg0: Long): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.InterruptedException]) @native()
  34. final def wait(): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.InterruptedException])
  35. final def withCallCredentials(arg0: CallCredentials): SequencerServiceBlockingStub
    Definition Classes
    AbstractStub
  36. final def withCompression(arg0: String): SequencerServiceBlockingStub
    Definition Classes
    AbstractStub
  37. final def withDeadline(arg0: Deadline): SequencerServiceBlockingStub
    Definition Classes
    AbstractStub
  38. final def withDeadlineAfter(arg0: Long, arg1: TimeUnit): SequencerServiceBlockingStub
    Definition Classes
    AbstractStub
  39. final def withExecutor(arg0: Executor): SequencerServiceBlockingStub
    Definition Classes
    AbstractStub
  40. final def withInterceptors(arg0: <repeated...>[ClientInterceptor]): SequencerServiceBlockingStub
    Definition Classes
    AbstractStub
    Annotations
    @transient()
  41. final def withMaxInboundMessageSize(arg0: Int): SequencerServiceBlockingStub
    Definition Classes
    AbstractStub
  42. final def withMaxOutboundMessageSize(arg0: Int): SequencerServiceBlockingStub
    Definition Classes
    AbstractStub
  43. final def withOption[T <: AnyRef](arg0: Key[T], arg1: T): SequencerServiceBlockingStub
    Definition Classes
    AbstractStub
  44. final def withWaitForReady(): SequencerServiceBlockingStub
    Definition Classes
    AbstractStub

Deprecated Value Members

  1. def finalize(): Unit
    Attributes
    protected[lang]
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.Throwable]) @Deprecated @Deprecated
    Deprecated
  2. final def withChannel(arg0: Channel): SequencerServiceBlockingStub
    Definition Classes
    AbstractStub
    Annotations
    @Deprecated @Deprecated
    Deprecated

Inherited from AnyRef

Inherited from Any

Ungrouped