class SyncStateInspection extends NamedLogging

Implements inspection functions for the sync state of a participant node

Linear Supertypes
NamedLogging, AnyRef, Any
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. def currentAcsSnapshot(persistentState: SyncDomainPersistentState)(implicit traceContext: TraceContext): Future[Either[AcsError, Map[LfContractId, CantonTimestamp]]]
  9. final def eq(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef
  10. def equals(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef → Any
  11. def findAcceptedTransactions(domain: DomainAlias, from: Option[CantonTimestamp] = None, to: Option[CantonTimestamp] = None, limit: Option[Int] = None)(implicit traceContext: TraceContext): Seq[(DisplayOffset, LfCommittedTransaction)]
  12. def findAcs(domain: DomainAlias)(implicit traceContext: TraceContext): EitherT[Future, AcsError, Map[LfContractId, CantonTimestamp]]

    returns the potentially big ACS of a given domain

  13. def findComputedCommitments(domain: DomainAlias, start: CantonTimestamp, end: CantonTimestamp, counterParticipant: Option[ParticipantId] = None)(implicit traceContext: TraceContext): Iterable[(CommitmentPeriod, ParticipantId, CommitmentType)]
  14. 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

  15. 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)

  16. def findMessage(domain: DomainAlias, criterion: SearchCriterion)(implicit traceContext: TraceContext): Either[SequencedEventNotFoundError, PossiblyIgnoredProtocolEvent]
  17. def findMessages(domain: DomainAlias, from: Option[Instant], to: Option[Instant], limit: Option[Int])(implicit traceContext: TraceContext): Seq[PossiblyIgnoredProtocolEvent]
  18. def findReceivedCommitments(domain: DomainAlias, start: CantonTimestamp, end: CantonTimestamp, counterParticipant: Option[ParticipantId] = None)(implicit traceContext: TraceContext): Iterable[SignedProtocolMessage[AcsCommitment]]
  19. def forceCleanPrehead(newHead: Option[CursorPrehead[RequestCounter]], 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.

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

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