class LocalParticipantTestingGroup extends ParticipantTestingGroup with FeatureFlagFilter with NoTracing
Linear Supertypes
Ordering
- Alphabetic
- By Inheritance
Inherited
- LocalParticipantTestingGroup
- NoTracing
- ParticipantTestingGroup
- Helpful
- FeatureFlagFilter
- NamedLogging
- AnyRef
- Any
- Hide All
- Show All
Visibility
- Public
- Protected
Instance Constructors
- new LocalParticipantTestingGroup(participantRef: ParticipantReference with BaseInspection[ParticipantNode], consoleEnvironment: ConsoleEnvironment, loggerFactory: NamedLoggerFactory)
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 acs_search(synchronizerAlias: SynchronizerAlias, exactId: String = "", filterPackage: String = "", filterTemplate: String = "", filterStakeholder: Option[PartyId] = None, limit: PositiveInt = defaultLimit): List[SerializableContract]
- Annotations
- @Summary(s = "Lookup of active contracts", flag = FeatureFlag.Testing)
- final def asInstanceOf[T0]: T0
- Definition Classes
- Any
- def await_synchronizer_time(synchronizerId: SynchronizerId, time: CantonTimestamp, timeout: NonNegativeDuration = consoleEnvironment.commandTimeouts.ledgerCommand): Unit
- Definition Classes
- ParticipantTestingGroup
- Annotations
- @Summary(s = "Await for the given time to be reached on the given synchronizer", flag = FeatureFlag.Testing)
- def await_synchronizer_time(synchronizerAlias: SynchronizerAlias, time: CantonTimestamp, timeout: NonNegativeDuration): Unit
- Definition Classes
- ParticipantTestingGroup
- Annotations
- @Summary(s = "Await for the given time to be reached on the given synchronizer", flag = FeatureFlag.Testing)
- def bong(targets: Set[ParticipantId], validators: Set[ParticipantId] = Set(), timeout: NonNegativeDuration = consoleEnvironment.commandTimeouts.testingBong, levels: Int = 0, synchronizerId: Option[SynchronizerId] = None, workflowId: String = "", id: String = ""): Duration
- Definition Classes
- ParticipantTestingGroup
- Annotations
- @Summary(s = "Send a bong to a set of target parties over the ledger. Levels > 0 leads to an exploding ping with exponential number of contracts. " +
"Throw a RuntimeException in case of failure.", flag = FeatureFlag.Testing) @Description(s = """Initiates a racy ping to multiple participants,
measuring the roundtrip time of the fastest responder, with an optional timeout.
Grace-period is the time the bong will wait for a duplicate spent (which would indicate an error in the system) before exiting.
If levels > 0, the ping command will lead to a binary explosion and subsequent dilation of
contracts, where ``level`` determines the number of levels we will explode. As a result, the system will create
(2^(L+2) - 3) contracts (where L stands for ``level``).
Normally, only the initiator is a validator. Additional validators can be added using the validators argument.
The bong command comes handy to run a burst test against the system and quickly leads to an overloading state.""")
- def cantonConfig: CantonConfig
- Attributes
- protected
- Definition Classes
- FeatureFlagFilter
- def check[T](flag: FeatureFlag)(command: => T): T
- Attributes
- protected
- Definition Classes
- FeatureFlagFilter
- def clone(): AnyRef
- Attributes
- protected[lang]
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.CloneNotSupportedException]) @IntrinsicCandidate() @native()
- val consoleEnvironment: ConsoleEnvironment
- Definition Classes
- ParticipantTestingGroup → FeatureFlagFilter
- def crypto_api(): SyncCryptoApiParticipantProvider
- Annotations
- @Summary(s = "Return the sync crypto api provider, which provides access to all cryptographic methods", flag = FeatureFlag.Testing)
- def defaultLimit: PositiveInt
- Attributes
- protected
- 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
- def fetch_synchronizer_time(synchronizerId: SynchronizerId, timeout: NonNegativeDuration = consoleEnvironment.commandTimeouts.ledgerCommand): CantonTimestamp
- Definition Classes
- ParticipantTestingGroup
- Annotations
- @Summary(s = "Fetch the current time from the given synchronizer", flag = FeatureFlag.Testing)
- def fetch_synchronizer_time(synchronizerAlias: SynchronizerAlias, timeout: NonNegativeDuration): CantonTimestamp
- Definition Classes
- ParticipantTestingGroup
- Annotations
- @Summary(s = "Fetch the current time from the given synchronizer", flag = FeatureFlag.Testing)
- def fetch_synchronizer_times(timeout: NonNegativeDuration = consoleEnvironment.commandTimeouts.ledgerCommand): Unit
- Definition Classes
- ParticipantTestingGroup
- Annotations
- @Summary(s = "Fetch the current time from all connected synchronizers", flag = FeatureFlag.Testing)
- def find_clean_commitments_timestamp(synchronizerAlias: SynchronizerAlias, beforeOrAt: CantonTimestamp = CantonTimestamp.now()): Option[CantonTimestamp]
- Annotations
- @Summary(s = "The latest timestamp before or at the given one for which no commitment is outstanding", flag = FeatureFlag.Testing) @Description(s = """The latest timestamp before or at the given one for which no commitment is outstanding.
|Note that this doesn't imply that pruning is possible at this timestamp, as the system might require some
|additional data for crash recovery. Thus, this is useful for testing commitments; use the commands in the pruning
|group for pruning.
|Additionally, the result needn't fall on a "commitment tick" as specified by the reconciliation interval.""")
- final def getClass(): Class[_ <: AnyRef]
- Definition Classes
- AnyRef → Any
- Annotations
- @IntrinsicCandidate() @native()
- def hashCode(): Int
- Definition Classes
- AnyRef → Any
- Annotations
- @IntrinsicCandidate() @native()
- def help(methodName: String)(implicit consoleEnvironment: ConsoleEnvironment): Unit
- Definition Classes
- Helpful
- Annotations
- @Summary(s = "Help for specific commands (use help() or help(\"method\") for more information)", flag = console.this.Help.Summary.<init>$default$2) @Topic(t = Seq("Top-level Commands"))
- def help()(implicit consoleEnvironment: ConsoleEnvironment): Unit
- Definition Classes
- Helpful
- final def isInstanceOf[T0]: Boolean
- Definition Classes
- Any
- def logger: TracedLogger
- Attributes
- protected
- Definition Classes
- NamedLogging
- val loggerFactory: NamedLoggerFactory
- Definition Classes
- ParticipantTestingGroup → NamedLogging
- def lookup_transaction(updateId: String): Option[LfVersionedTransaction]
- Annotations
- @Summary(s = "Lookup of accepted transactions by update ID", flag = FeatureFlag.Testing)
- def maybe_bong(targets: Set[ParticipantId], validators: Set[ParticipantId] = Set(), timeout: NonNegativeDuration = consoleEnvironment.commandTimeouts.testingBong, levels: Int = 0, synchronizerId: Option[SynchronizerId] = None, workflowId: String = "", id: String = ""): Option[Duration]
- Definition Classes
- ParticipantTestingGroup
- Annotations
- @Summary(s = "Like bong, but returns None in case of failure.", flag = FeatureFlag.Testing)
- 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 pcs_search(synchronizerAlias: SynchronizerAlias, exactId: String = "", filterPackage: String = "", filterTemplate: String = "", activeSet: Boolean = false, limit: PositiveInt = defaultLimit): List[(Boolean, SerializableContract)]
- Annotations
- @Summary(s = "Lookup contracts in the Private Contract Store", flag = FeatureFlag.Testing) @Description(s = """Get raw access to the PCS of the given synchronizer sync controller.
The filter commands will check if the target value ``contains`` the given string.
The arguments can be started with ``^`` such that ``startsWith`` is used for comparison or ``!`` to use ``equals``.
The ``activeSet`` argument allows to restrict the search to the active contract set.
For contract ID filtration only exact match is supported.
""")
- def sequencer_messages(synchronizerAlias: SynchronizerAlias, from: Option[Instant] = None, to: Option[Instant] = None, limit: PositiveInt = defaultLimit): Seq[PossiblyIgnoredProtocolEvent]
- Annotations
- @Summary(s = "Retrieve all sequencer messages", flag = FeatureFlag.Testing) @Description(s = """Optionally allows filtering for sequencer from a certain time span (inclusive on both ends) and
|limiting the number of displayed messages. The returned messages will be ordered on most synchronizer ledger implementations
|if a time span is given.
|
|Fails if the participant has never connected to the synchronizer.""")
- def state_inspection: SyncStateInspection
- Annotations
- @Summary(s = "Obtain access to the state inspection interface. Use at your own risk.", flag = FeatureFlag.Testing) @Description(s = """The state inspection methods can fatally and permanently corrupt the state of a participant.
|The API is subject to change in any way.""")
- final def synchronized[T0](arg0: => T0): T0
- Definition Classes
- AnyRef
- def toString(): String
- Definition Classes
- AnyRef → Any
- implicit def traceContext: TraceContext
- Attributes
- protected
- Definition Classes
- NoTracing
- 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])