class SyncStateInspection extends NamedLogging
Implements inspection functions for the sync state of a participant node
Linear Supertypes
Ordering
- Alphabetic
- By Inheritance
Inherited
- SyncStateInspection
- NamedLogging
- AnyRef
- Any
- Hide All
- Show All
Visibility
- Public
- Protected
Instance Constructors
- new SyncStateInspection(syncDomainPersistentStateManager: SyncDomainPersistentStateManager, participantNodePersistentState: ParticipantNodePersistentState, pruningProcessor: PruningProcessor, timeouts: ProcessingTimeout, maxDbConnections: Int, loggerFactory: NamedLoggerFactory)(implicit ec: 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]) @native() @HotSpotIntrinsicCandidate()
- def contractCount(domain: DomainAlias)(implicit traceContext: TraceContext): Future[Int]
- def contractCountInAcs(domain: DomainAlias, timestamp: CantonTimestamp)(implicit traceContext: TraceContext): Future[Option[Int]]
- def currentAcsSnapshot(persistentState: SyncDomainPersistentState)(implicit traceContext: TraceContext): Future[Either[AcsError, Map[LfContractId, CantonTimestamp]]]
- 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 findAcceptedTransactions(domain: DomainAlias, from: Option[CantonTimestamp] = None, to: Option[CantonTimestamp] = None, limit: Option[Int] = None)(implicit traceContext: TraceContext): Seq[(DisplayOffset, LfCommittedTransaction)]
- def findAcs(domain: DomainAlias)(implicit traceContext: TraceContext): EitherT[Future, AcsError, Map[LfContractId, CantonTimestamp]]
returns the potentially big ACS of a given domain
- def findComputedCommitments(domain: DomainAlias, start: CantonTimestamp, end: CantonTimestamp, counterParticipant: Option[ParticipantId] = None)(implicit traceContext: TraceContext): Iterable[(CommitmentPeriod, ParticipantId, CommitmentType)]
- def findContracts(domain: DomainAlias, filterId: Option[String], filterPackage: Option[String], filterTemplate: Option[String], limit: Int)(implicit traceContext: TraceContext): List[(Boolean, SerializableContract)]
searches the pcs and returns the contract and activeness flag
- def findEvents(domain: DomainAlias, from: Option[CantonTimestamp] = None, to: Option[CantonTimestamp] = None, limit: Option[Int] = None)(implicit traceContext: TraceContext): Seq[(DisplayOffset, TimestampedEvent)]
Returns the events from the given domain; if the specified domain is empty, returns the events from the combined, multi-domain event log.
Returns the events from the given domain; if the specified domain is empty, returns the events from the combined, multi-domain event log.
fromandtoonly have an effect if the domain isn't empty.- Exceptions thrown
scala.RuntimeException(by Await.result and if lookup fails)
- def findMessage(domain: DomainAlias, criterion: SearchCriterion)(implicit traceContext: TraceContext): Either[SequencedEventNotFoundError, PossiblyIgnoredProtocolEvent]
- def findMessages(domain: DomainAlias, from: Option[Instant], to: Option[Instant], limit: Option[Int])(implicit traceContext: TraceContext): Seq[PossiblyIgnoredProtocolEvent]
- def findReceivedCommitments(domain: DomainAlias, start: CantonTimestamp, end: CantonTimestamp, counterParticipant: Option[ParticipantId] = None)(implicit traceContext: TraceContext): Iterable[SignedProtocolMessage[AcsCommitment]]
- def forceCleanPrehead(newHead: Option[RequestCounterCursorPrehead], domain: DomainAlias)(implicit traceContext: TraceContext): Either[String, Future[Unit]]
Update the prehead for clean requests to the given value, bypassing all checks.
Update the prehead for clean requests to the given value, bypassing all checks. Only used for testing.
- final def getClass(): Class[_ <: AnyRef]
- Definition Classes
- AnyRef → Any
- Annotations
- @native() @HotSpotIntrinsicCandidate()
- def getOffsetByTime(pruneUpTo: CantonTimestamp)(implicit traceContext: TraceContext): Future[Option[LedgerOffset]]
- def hashCode(): Int
- Definition Classes
- AnyRef → Any
- Annotations
- @native() @HotSpotIntrinsicCandidate()
- final def isInstanceOf[T0]: Boolean
- Definition Classes
- Any
- def locateOffset(numTransactions: Long)(implicit traceContext: TraceContext): Future[Either[String, LedgerOffset]]
- def logger: TracedLogger
- Attributes
- protected
- Definition Classes
- NamedLogging
- val loggerFactory: NamedLoggerFactory
- Attributes
- protected
- Definition Classes
- SyncStateInspection → NamedLogging
- def lookupCleanPrehead(domain: DomainAlias)(implicit traceContext: TraceContext): Either[String, Future[Option[RequestCounterCursorPrehead]]]
- def lookupContractDomain(contractIds: Set[LfContractId])(implicit traceContext: TraceContext): Future[Map[LfContractId, DomainAlias]]
For a set of contracts lookup which domain they are currently in.
For a set of contracts lookup which domain they are currently in. If a contract is not found in a available ACS it will be omitted from the response.
- def lookupTransactionDomain(transactionId: LedgerTransactionId)(implicit traceContext: TraceContext): Future[Option[DomainId]]
- implicit def namedLoggingContext(implicit traceContext: TraceContext): NamedLoggingContext
- Attributes
- protected
- Definition Classes
- NamedLogging
- final def ne(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
- def noOutstandingCommitmentsTs(domain: DomainAlias, beforeOrAt: CantonTimestamp)(implicit traceContext: TraceContext): Option[CantonTimestamp]
- def noTracingLogger: Logger
- Attributes
- protected
- Definition Classes
- NamedLogging
- final def notify(): Unit
- Definition Classes
- AnyRef
- Annotations
- @native() @HotSpotIntrinsicCandidate()
- final def notifyAll(): Unit
- Definition Classes
- AnyRef
- Annotations
- @native() @HotSpotIntrinsicCandidate()
- def outstandingCommitments(domain: DomainAlias, start: CantonTimestamp, end: CantonTimestamp, counterParticipant: Option[ParticipantId])(implicit traceContext: TraceContext): Iterable[(CommitmentPeriod, ParticipantId)]
- def requestJournalSize(domain: DomainAlias, start: CantonTimestamp = CantonTimestamp.Epoch, end: Option[CantonTimestamp] = None)(implicit traceContext: TraceContext): Option[Int]
- def requestStateInJournal(rc: RequestCounter, domain: DomainAlias)(implicit traceContext: TraceContext): Either[String, Future[Option[RequestData]]]
- def safeToPrune(beforeOrAt: CantonTimestamp, ledgerEnd: LedgerOffset)(implicit traceContext: TraceContext): Either[String, Option[LedgerOffset]]
- def storeActiveContractsToFile(parties: Set[PartyId], target: File, batchSize: PositiveInt, filterDomain: (DomainId) => Boolean, timestamp: Option[CantonTimestamp], protocolVersion: Option[ProtocolVersion])(implicit traceContext: TraceContext): Either[String, Map[DomainId, Long]]
- 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])