com.digitalasset.canton.admin.participant.v30.PartyManagementServiceGrpc
PartyManagementServiceBlockingStub
class PartyManagementServiceBlockingStub extends AbstractStub[PartyManagementServiceBlockingStub] with PartyManagementServiceBlockingClient
- Alphabetic
- By Inheritance
- PartyManagementServiceBlockingStub
- PartyManagementServiceBlockingClient
- AbstractStub
- AnyRef
- Any
- Hide All
- Show All
- Public
- Protected
Instance Constructors
- new PartyManagementServiceBlockingStub(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 addPartyAsync(request: AddPartyAsyncRequest): AddPartyAsyncResponse
Initiate adding a party already hosted on one or more non-local participants to the local participant in the specified synchronizer.
Initiate adding a party already hosted on one or more non-local participants to the local participant in the specified synchronizer. Performs some checks synchronously and then starts the replication asynchronously.
- Definition Classes
- PartyManagementServiceBlockingStub → PartyManagementServiceBlockingClient
- final def asInstanceOf[T0]: T0
- Definition Classes
- Any
- def build(channel: Channel, options: CallOptions): PartyManagementServiceBlockingStub
- Definition Classes
- PartyManagementServiceBlockingStub → 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
- def exportAcs(request: ExportAcsRequest): Iterator[ExportAcsResponse]
Export the ACS for the given parties from the participant.
Export the ACS for the given parties from the participant.
- Definition Classes
- PartyManagementServiceBlockingStub → PartyManagementServiceBlockingClient
- def exportAcsAtTimestamp(request: ExportAcsAtTimestampRequest): Iterator[ExportAcsAtTimestampResponse]
Export the ACS for the given parties at a timestamp (that is the effective time of a topology transaction).
Export the ACS for the given parties at a timestamp (that is the effective time of a topology transaction).
- Definition Classes
- PartyManagementServiceBlockingStub → PartyManagementServiceBlockingClient
- def getAddPartyStatus(request: GetAddPartyStatusRequest): GetAddPartyStatusResponse
Status endpoint that given an add_party_request_id returns status information about progress, completion, or errors of a previous call to AddPartyAsync on the source or target participant.
Status endpoint that given an add_party_request_id returns status information about progress, completion, or errors of a previous call to AddPartyAsync on the source or target participant.
Note that the status reflects the state as perceived by the local participant and does not imply the state of remote participants. The status on the target participant is more authoritative as the target participant drives the process of adding the party. For example when the target participant status indicates "completed", the party has been added successfully.
- Definition Classes
- PartyManagementServiceBlockingStub → PartyManagementServiceBlockingClient
- 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 getHighestOffsetByTimestamp(request: GetHighestOffsetByTimestampRequest): GetHighestOffsetByTimestampResponse
For a given timestamp, find the highest ledger offset among all events that have record time <= timestamp.
For a given timestamp, find the highest ledger offset among all events that have record time <= timestamp.
Returns a ledger offset, or an error otherwise. Depending on the error cause, a retry may make sense. Retryable errors are defined as: OUT_OF_RANGE/INVALID_TIMESTAMP_PARTY_MANAGEMENT_ERROR. Further, a returned offset is guaranteed to be "clean", meaning all events have been processed fully and published to the Ledger API DB until the requested timestamp.
- Definition Classes
- PartyManagementServiceBlockingStub → PartyManagementServiceBlockingClient
- 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 serviceCompanion: ServiceCompanion[PartyManagementService]
- Definition Classes
- PartyManagementServiceBlockingClient
- 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): PartyManagementServiceBlockingStub
- Definition Classes
- AbstractStub
- final def withCompression(arg0: String): PartyManagementServiceBlockingStub
- Definition Classes
- AbstractStub
- final def withDeadline(arg0: Deadline): PartyManagementServiceBlockingStub
- Definition Classes
- AbstractStub
- final def withDeadlineAfter(arg0: Long, arg1: TimeUnit): PartyManagementServiceBlockingStub
- Definition Classes
- AbstractStub
- final def withExecutor(arg0: Executor): PartyManagementServiceBlockingStub
- Definition Classes
- AbstractStub
- final def withInterceptors(arg0: <repeated...>[ClientInterceptor]): PartyManagementServiceBlockingStub
- Definition Classes
- AbstractStub
- Annotations
- @transient()
- final def withMaxInboundMessageSize(arg0: Int): PartyManagementServiceBlockingStub
- Definition Classes
- AbstractStub
- final def withMaxOutboundMessageSize(arg0: Int): PartyManagementServiceBlockingStub
- Definition Classes
- AbstractStub
- final def withOnReadyThreshold(arg0: Int): PartyManagementServiceBlockingStub
- Definition Classes
- AbstractStub
- final def withOption[T <: AnyRef](arg0: Key[T], arg1: T): PartyManagementServiceBlockingStub
- Definition Classes
- AbstractStub
- final def withWaitForReady(): PartyManagementServiceBlockingStub
- 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): PartyManagementServiceBlockingStub
- Definition Classes
- AbstractStub
- Annotations
- @Deprecated
- Deprecated