class SyncStateInspection extends NamedLogging

Implements inspection functions for the sync state of a participant node

Linear Supertypes
Ordering
  1. Alphabetic
  2. By Inheritance
Inherited
  1. SyncStateInspection
  2. NamedLogging
  3. AnyRef
  4. Any
  1. Hide All
  2. Show All
Visibility
  1. Public
  2. Protected

Instance Constructors

  1. new SyncStateInspection(syncDomainPersistentStateManager: SyncDomainPersistentStateManager, participantNodePersistentState: ParticipantNodePersistentState, pruningProcessor: PruningProcessor, timeouts: ProcessingTimeout, loggerFactory: NamedLoggerFactory)(implicit ec: ExecutionContext)

Value Members

  1. final def !=(arg0: Any): Boolean
    Definition Classes
    AnyRef → Any
  2. final def ##: Int
    Definition Classes
    AnyRef → Any
  3. final def ==(arg0: Any): Boolean
    Definition Classes
    AnyRef → Any
  4. final def asInstanceOf[T0]: T0
    Definition Classes
    Any
  5. def clone(): AnyRef
    Attributes
    protected[lang]
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.CloneNotSupportedException]) @native() @HotSpotIntrinsicCandidate()
  6. def contractCount(domain: DomainAlias)(implicit traceContext: TraceContext): Future[Int]
  7. def contractCountInAcs(domain: DomainAlias, timestamp: CantonTimestamp)(implicit traceContext: TraceContext): Future[Option[Int]]
  8. final def eq(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef
  9. def equals(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef → Any
  10. def findAcceptedTransactions(domain: DomainAlias, from: Option[CantonTimestamp] = None, to: Option[CantonTimestamp] = None, limit: Option[Int] = None)(implicit traceContext: TraceContext): Seq[(DisplayOffset, LfCommittedTransaction)]
  11. def findComputedCommitments(domain: DomainAlias, start: CantonTimestamp, end: CantonTimestamp, counterParticipant: Option[ParticipantId] = None)(implicit traceContext: TraceContext): Iterable[(CommitmentPeriod, ParticipantId, CommitmentType)]
  12. 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

  13. 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. from and to only have an effect if the domain isn't empty.

    Exceptions thrown

    scala.RuntimeException (by Await.result and if lookup fails)

  14. def findMessages(domain: DomainAlias, from: Option[Instant], to: Option[Instant], limit: Option[Int])(implicit traceContext: TraceContext): Option[Iterable[SignedSequencedEvent[DefaultOpenEnvelope]]]
  15. def findReceivedCommitments(domain: DomainAlias, start: CantonTimestamp, end: CantonTimestamp, counterParticipant: Option[ParticipantId] = None)(implicit traceContext: TraceContext): Iterable[SignedProtocolMessage[AcsCommitment]]
  16. def forceCleanPrehead(rcO: Option[(RequestCounter, CantonTimestamp)], 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.

  17. final def getClass(): Class[_ <: AnyRef]
    Definition Classes
    AnyRef → Any
    Annotations
    @native() @HotSpotIntrinsicCandidate()
  18. def getOffsetByTime(pruneUpTo: CantonTimestamp)(implicit traceContext: TraceContext): Future[Option[LedgerOffset]]
  19. def hashCode(): Int
    Definition Classes
    AnyRef → Any
    Annotations
    @native() @HotSpotIntrinsicCandidate()
  20. final def isInstanceOf[T0]: Boolean
    Definition Classes
    Any
  21. def locateOffset(numTransactions: Long)(implicit traceContext: TraceContext): Future[Either[String, LedgerOffset]]
  22. def logger: TracedLogger
    Attributes
    protected
    Definition Classes
    NamedLogging
  23. val loggerFactory: NamedLoggerFactory
    Attributes
    protected
    Definition Classes
    SyncStateInspectionNamedLogging
  24. implicit def loggingContext(implicit traceContext: TraceContext): ErrorLoggingContext
    Attributes
    protected
    Definition Classes
    NamedLogging
  25. def lookupCleanPrehead(domain: DomainAlias)(implicit traceContext: TraceContext): Either[String, Future[Option[RequestCounter]]]
  26. 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.

  27. def lookupTransactionDomain(transactionId: LedgerTransactionId)(implicit traceContext: TraceContext): Future[Option[DomainId]]
  28. final def ne(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef
  29. def noOutstandingCommitmentsTs(domain: DomainAlias, beforeOrAt: CantonTimestamp)(implicit traceContext: TraceContext): Option[CantonTimestamp]
  30. def noTracingLogger: Logger
    Attributes
    protected
    Definition Classes
    NamedLogging
  31. final def notify(): Unit
    Definition Classes
    AnyRef
    Annotations
    @native() @HotSpotIntrinsicCandidate()
  32. final def notifyAll(): Unit
    Definition Classes
    AnyRef
    Annotations
    @native() @HotSpotIntrinsicCandidate()
  33. def outstandingCommitments(domain: DomainAlias, start: CantonTimestamp, end: CantonTimestamp, counterParticipant: Option[ParticipantId])(implicit traceContext: TraceContext): Iterable[(CommitmentPeriod, ParticipantId)]
  34. def recentHeartbeat(domain: DomainAlias)(implicit traceContext: TraceContext): Option[Heartbeat]
  35. def requestJournalSize(domain: DomainAlias, start: CantonTimestamp = CantonTimestamp.Epoch, end: Option[CantonTimestamp] = None)(implicit traceContext: TraceContext): Option[Int]
  36. def requestStateInJournal(rc: RequestCounter, domain: DomainAlias)(implicit traceContext: TraceContext): Either[String, Future[Option[RequestData]]]
  37. def safeToPrune(beforeOrAt: CantonTimestamp, ledgerEnd: LedgerOffset)(implicit traceContext: TraceContext): Either[String, Option[LedgerOffset]]
  38. final def synchronized[T0](arg0: => T0): T0
    Definition Classes
    AnyRef
  39. def toString(): String
    Definition Classes
    AnyRef → Any
  40. final def wait(arg0: Long, arg1: Int): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.InterruptedException])
  41. final def wait(arg0: Long): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.InterruptedException]) @native()
  42. final def wait(): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.InterruptedException])

Deprecated Value Members

  1. def finalize(): Unit
    Attributes
    protected[lang]
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.Throwable]) @Deprecated
    Deprecated

Inherited from NamedLogging

Inherited from AnyRef

Inherited from Any

Ungrouped