c
com.digitalasset.canton.synchronizer.sequencing.sequencer.bftordering.v30.BftOrderingServiceGrpc
BftOrderingServiceStub
Companion object BftOrderingServiceStub
class BftOrderingServiceStub extends AbstractStub[BftOrderingServiceStub] with BftOrderingService
Linear Supertypes
Ordering
- Alphabetic
- By Inheritance
Inherited
- BftOrderingServiceStub
- BftOrderingService
- AbstractService
- AbstractStub
- AnyRef
- Any
- Hide All
- Show All
Visibility
- Public
- Protected
Instance Constructors
- new BftOrderingServiceStub(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
- final def asInstanceOf[T0]: T0
- Definition Classes
- Any
- def build(channel: Channel, options: CallOptions): BftOrderingServiceStub
- Definition Classes
- BftOrderingServiceStub → AbstractStub
- 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
- final def getCallOptions(): CallOptions
- Definition Classes
- AbstractStub
- final def getChannel(): Channel
- Definition Classes
- AbstractStub
- final def getClass(): Class[_ <: AnyRef]
- Definition Classes
- AnyRef → Any
- Annotations
- @IntrinsicCandidate() @native()
- def hashCode(): Int
- Definition Classes
- AnyRef → Any
- Annotations
- @IntrinsicCandidate() @native()
- 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
- @IntrinsicCandidate() @native()
- final def notifyAll(): Unit
- Definition Classes
- AnyRef
- Annotations
- @IntrinsicCandidate() @native()
- def ping(request: PingRequest): Future[PingResponse]
- Definition Classes
- BftOrderingServiceStub → BftOrderingService
- def receive(responseObserver: StreamObserver[BftOrderingServiceReceiveResponse]): StreamObserver[BftOrderingServiceReceiveRequest]
For simplicity and to avoid the usage of mTLS, which is not well supported by all network infrastructure, each BFT ordering node (client endpoint) opens its own P2P connection to every other server endpoint, performs server authentication and then pushes messages to it.
For simplicity and to avoid the usage of mTLS, which is not well supported by all network infrastructure, each BFT ordering node (client endpoint) opens its own P2P connection to every other server endpoint, performs server authentication and then pushes messages to it.
Note that the Java gRPC implementation seems to implement unidirectional streams as bidirectional ones, which seems to require anyway at least one server-sent message before completion (according to https://github.com/grpc/grpc-java/issues/6568). Using a unidirectional stream and sending an empty response from the server results in Netty reference-counted buffer leaks.
- Definition Classes
- BftOrderingServiceStub → BftOrderingService
- def serviceCompanion: ServiceCompanion[BftOrderingService]
- Definition Classes
- BftOrderingService → AbstractService
- 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): BftOrderingServiceStub
- Definition Classes
- AbstractStub
- final def withCompression(arg0: String): BftOrderingServiceStub
- Definition Classes
- AbstractStub
- final def withDeadline(arg0: Deadline): BftOrderingServiceStub
- Definition Classes
- AbstractStub
- final def withDeadlineAfter(arg0: Long, arg1: TimeUnit): BftOrderingServiceStub
- Definition Classes
- AbstractStub
- final def withExecutor(arg0: Executor): BftOrderingServiceStub
- Definition Classes
- AbstractStub
- final def withInterceptors(arg0: <repeated...>[ClientInterceptor]): BftOrderingServiceStub
- Definition Classes
- AbstractStub
- Annotations
- @transient()
- final def withMaxInboundMessageSize(arg0: Int): BftOrderingServiceStub
- Definition Classes
- AbstractStub
- final def withMaxOutboundMessageSize(arg0: Int): BftOrderingServiceStub
- Definition Classes
- AbstractStub
- final def withOnReadyThreshold(arg0: Int): BftOrderingServiceStub
- Definition Classes
- AbstractStub
- final def withOption[T <: AnyRef](arg0: Key[T], arg1: T): BftOrderingServiceStub
- Definition Classes
- AbstractStub
- final def withWaitForReady(): BftOrderingServiceStub
- Definition Classes
- AbstractStub
Deprecated Value Members
- def finalize(): Unit
- Attributes
- protected[lang]
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.Throwable]) @Deprecated
- Deprecated
(Since version 9)
- final def withChannel(arg0: Channel): BftOrderingServiceStub
- Definition Classes
- AbstractStub
- Annotations
- @Deprecated
- Deprecated