class GrpcParticipantInspectionService extends ParticipantInspectionService with NamedLogging
- Alphabetic
- By Inheritance
- GrpcParticipantInspectionService
- NamedLogging
- ParticipantInspectionService
- AbstractService
- AnyRef
- Any
- Hide All
- Show All
- Public
- Protected
Instance Constructors
- new GrpcParticipantInspectionService(syncStateInspection: SyncStateInspection, ips: IdentityProvidingServiceClient, indexedStringStore: IndexedStringStore, synchronizerAliasManager: SynchronizerAliasManager, loggerFactory: NamedLoggerFactory)(implicit executionContext: ExecutionContext)
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]) @IntrinsicCandidate() @native()
- def countInFlight(request: CountInFlightRequest): Future[CountInFlightResponse]
Count in-flight submissions and transactions for a synchronizer
Count in-flight submissions and transactions for a synchronizer
- Definition Classes
- GrpcParticipantInspectionService → ParticipantInspectionService
- final def eq(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
- def equals(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef → Any
- implicit def errorLoggingContext(implicit traceContext: TraceContext): ErrorLoggingContext
- Attributes
- protected
- Definition Classes
- NamedLogging
- final def getClass(): Class[_ <: AnyRef]
- Definition Classes
- AnyRef → Any
- Annotations
- @IntrinsicCandidate() @native()
- def getConfigForSlowCounterParticipants(request: GetConfigForSlowCounterParticipantsRequest): Future[GetConfigForSlowCounterParticipantsResponse]
Get the current configuration for metrics for slow counter-participants.
Get the current configuration for metrics for slow counter-participants.
- Definition Classes
- GrpcParticipantInspectionService → ParticipantInspectionService
- def getIntervalsBehindForCounterParticipants(request: GetIntervalsBehindForCounterParticipantsRequest): Future[GetIntervalsBehindForCounterParticipantsResponse]
Get the number of intervals that counter-participants are behind in sending commitments.
Get the number of intervals that counter-participants are behind in sending commitments. Can be used to decide whether to ignore slow counter-participants w.r.t. pruning.
- Definition Classes
- GrpcParticipantInspectionService → ParticipantInspectionService
- def hashCode(): Int
- Definition Classes
- AnyRef → Any
- Annotations
- @IntrinsicCandidate() @native()
- def inspectCommitmentContracts(request: InspectCommitmentContractsRequest, responseObserver: StreamObserver[InspectCommitmentContractsResponse]): Unit
TODO(#9557) R2
TODO(#9557) R2
- Definition Classes
- GrpcParticipantInspectionService → ParticipantInspectionService
- final def isInstanceOf[T0]: Boolean
- Definition Classes
- Any
- def logger: TracedLogger
- Attributes
- protected
- Definition Classes
- NamedLogging
- val loggerFactory: NamedLoggerFactory
- Attributes
- protected
- Definition Classes
- GrpcParticipantInspectionService → NamedLogging
- def lookupOffsetByTime(request: LookupOffsetByTimeRequest): Future[LookupOffsetByTimeResponse]
Look up the ledger offset corresponding to the timestamp, specifically the largest offset such that no later offset corresponds to a later timestamp than the specified one.
Look up the ledger offset corresponding to the timestamp, specifically the largest offset such that no later offset corresponds to a later timestamp than the specified one.
- Definition Classes
- GrpcParticipantInspectionService → ParticipantInspectionService
- def lookupReceivedAcsCommitments(request: LookupReceivedAcsCommitmentsRequest): Future[LookupReceivedAcsCommitmentsResponse]
List the counter-participants of a participant and their ACS commitments together with the match status TODO(#18749) R1 Can also be used for R1, to fetch commitments that a counter participant received from myself
List the counter-participants of a participant and their ACS commitments together with the match status TODO(#18749) R1 Can also be used for R1, to fetch commitments that a counter participant received from myself
- Definition Classes
- GrpcParticipantInspectionService → ParticipantInspectionService
- def lookupSentAcsCommitments(request: LookupSentAcsCommitmentsRequest): Future[LookupSentAcsCommitmentsResponse]
Look up the ACS commitments computed and sent by a participant
Look up the ACS commitments computed and sent by a participant
- Definition Classes
- GrpcParticipantInspectionService → ParticipantInspectionService
- implicit def namedLoggingContext(implicit traceContext: TraceContext): NamedLoggingContext
- Attributes
- protected
- Definition Classes
- NamedLogging
- final def ne(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
- def noTracingLogger: Logger
- Attributes
- protected
- Definition Classes
- NamedLogging
- final def notify(): Unit
- Definition Classes
- AnyRef
- Annotations
- @IntrinsicCandidate() @native()
- final def notifyAll(): Unit
- Definition Classes
- AnyRef
- Annotations
- @IntrinsicCandidate() @native()
- def openCommitment(request: OpenCommitmentRequest, responseObserver: StreamObserver[OpenCommitmentResponse]): Unit
Request metadata about shared contracts used in commitment computation at a specific time Subject to the data still being available on the participant TODO(#9557) R2
Request metadata about shared contracts used in commitment computation at a specific time Subject to the data still being available on the participant TODO(#9557) R2
- Definition Classes
- GrpcParticipantInspectionService → ParticipantInspectionService
- def serviceCompanion: ServiceCompanion[ParticipantInspectionService]
- Definition Classes
- ParticipantInspectionService → AbstractService
- def setConfigForSlowCounterParticipants(request: SetConfigForSlowCounterParticipantsRequest): Future[SetConfigForSlowCounterParticipantsResponse]
Configure metrics for slow counter-participants (i.e., that are behind in sending commitments) and configure thresholds for when a counter-participant is deemed slow.
Configure metrics for slow counter-participants (i.e., that are behind in sending commitments) and configure thresholds for when a counter-participant is deemed slow.
returns error if synchronizer ids re not distinct.
- Definition Classes
- GrpcParticipantInspectionService → ParticipantInspectionService
- 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])