Packages

final 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(syncPersistentStateManager: SyncPersistentStateManager, participantNodePersistentState: Eval[ParticipantNodePersistentState], timeouts: ProcessingTimeout, journalCleaningControl: JournalGarbageCollectorControl, connectedSynchronizersLookup: ConnectedSynchronizersLookup, syncCrypto: SyncCryptoApiParticipantProvider, participantId: ParticipantId, futureSupervisor: FutureSupervisor, 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. def acceptedTransactionCount(synchronizerAlias: SynchronizerAlias)(implicit traceContext: TraceContext): Int
  5. def acsPruningStatus(synchronizerAlias: SynchronizerAlias)(implicit traceContext: TraceContext): Option[PruningStatus]
    Annotations
    @VisibleForTesting()
  6. def activeContractsStakeholdersFilter(synchronizerId: SynchronizerId, toc: TimeOfChange, parties: Set[LfPartyId])(implicit traceContext: TraceContext): FutureUnlessShutdown[Set[(SerializableContract, ReassignmentCounter)]]
  7. def addOrUpdateConfigsForSlowCounterParticipants(configs: Seq[ConfigForSlowCounterParticipants], thresholds: Seq[ConfigForSynchronizerThresholds])(implicit traceContext: TraceContext): FutureUnlessShutdown[Unit]
  8. def allProtocolVersions: Map[SynchronizerId, ProtocolVersion]
  9. final def asInstanceOf[T0]: T0
    Definition Classes
    Any
  10. def bufferedCommitments(synchronizerAlias: SynchronizerAlias, endAtOrBefore: CantonTimestamp)(implicit traceContext: TraceContext): Iterable[AcsCommitment]
  11. def cleanSequencedEventStoreAboveCleanSynchronizerIndex(synchronizerAlias: SynchronizerAlias)(implicit traceContext: TraceContext): Unit
  12. def clone(): AnyRef
    Attributes
    protected[lang]
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.CloneNotSupportedException]) @IntrinsicCandidate() @native()
  13. def contractCount(implicit traceContext: TraceContext): FutureUnlessShutdown[Int]
  14. def contractCountInAcs(synchronizerAlias: SynchronizerAlias, timestamp: CantonTimestamp)(implicit traceContext: TraceContext): FutureUnlessShutdown[Option[Int]]
  15. def countInFlight(synchronizerAlias: SynchronizerAlias)(implicit traceContext: TraceContext): EitherT[FutureUnlessShutdown, String, InFlightCount]
  16. def crossSynchronizerReceivedCommitmentMessages(synchronizerPeriods: Seq[SynchronizerSearchCommitmentPeriod], counterParticipants: Seq[ParticipantId], states: Seq[CommitmentPeriodState], verbose: Boolean)(implicit traceContext: TraceContext): Either[String, Iterable[ReceivedAcsCommitment]]
  17. def crossSynchronizerSentCommitmentMessages(synchronizerPeriods: Seq[SynchronizerSearchCommitmentPeriod], counterParticipants: Seq[ParticipantId], states: Seq[CommitmentPeriodState], verbose: Boolean)(implicit traceContext: TraceContext): Either[String, Iterable[SentAcsCommitment]]
  18. final def eq(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef
  19. def equals(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef → Any
  20. implicit def errorLoggingContext(implicit traceContext: TraceContext): ErrorLoggingContext
    Attributes
    protected
    Definition Classes
    NamedLogging
  21. def exportAcsDumpActiveContracts(outputStream: OutputStream, filterSynchronizerId: (SynchronizerId) => Boolean, parties: Set[LfPartyId], timestamp: Option[CantonTimestamp], contractSynchronizerRenames: Map[SynchronizerId, (SynchronizerId, ProtocolVersion)], skipCleanTimestampCheck: Boolean, partiesOffboarding: Boolean)(implicit traceContext: TraceContext): EitherT[FutureUnlessShutdown, AcsInspectionError, Unit]
  22. def findAcs(synchronizerAlias: SynchronizerAlias)(implicit traceContext: TraceContext): EitherT[FutureUnlessShutdown, SyncStateInspectionError, Map[LfContractId, (TimeOfChange, ReassignmentCounter)]]

    Returns the potentially large ACS of a given synchronizer containing a map of contract IDs to tuples containing the latest activation timestamp and the contract reassignment counter

  23. def findAllKnownParticipants(synchronizerFilter: Seq[SynchronizerId] = Seq.empty, participantFilter: Seq[ParticipantId] = Seq.empty)(implicit traceContext: TraceContext): FutureUnlessShutdown[Map[SynchronizerId, Set[ParticipantId]]]
  24. def findComputedCommitments(synchronizerAlias: SynchronizerAlias, start: CantonTimestamp, end: CantonTimestamp, counterParticipant: Option[ParticipantId] = None)(implicit traceContext: TraceContext): Iterable[(CommitmentPeriod, ParticipantId, HashedCommitmentType)]
  25. def findContractPayloads(synchronizerId: SynchronizerId, contractIds: Seq[LfContractId], limit: Int)(implicit traceContext: TraceContext): FutureUnlessShutdown[Map[LfContractId, SerializableContract]]
  26. def findContracts(synchronizerAlias: SynchronizerAlias, exactId: 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

  27. def findLastComputedAndSent(synchronizerAlias: SynchronizerAlias)(implicit traceContext: TraceContext): Option[CantonTimestampSecond]
  28. def findMessage(synchronizerAlias: SynchronizerAlias, criterion: SearchCriterion)(implicit traceContext: TraceContext): Option[ParsingResult[PossiblyIgnoredProtocolEvent]]
    Annotations
    @VisibleForTesting()
  29. def findMessages(synchronizerAlias: SynchronizerAlias, from: Option[Instant], to: Option[Instant], limit: Option[Int])(implicit traceContext: TraceContext): Seq[ParsingResult[PossiblyIgnoredProtocolEvent]]
  30. def findReceivedCommitments(synchronizerAlias: SynchronizerAlias, start: CantonTimestamp, end: CantonTimestamp, counterParticipant: Option[ParticipantId] = None)(implicit traceContext: TraceContext): Iterable[SignedProtocolMessage[AcsCommitment]]
  31. def getAcsInspection(synchronizerId: SynchronizerId): Option[AcsInspection]
  32. final def getClass(): Class[_ <: AnyRef]
    Definition Classes
    AnyRef → Any
    Annotations
    @IntrinsicCandidate() @native()
  33. def getConfigsForSlowCounterParticipants()(implicit traceContext: TraceContext): FutureUnlessShutdown[(Seq[ConfigForSlowCounterParticipants], Seq[ConfigForSynchronizerThresholds])]
  34. def getIntervalsBehindForParticipants(synchronizers: Seq[SynchronizerId], participants: Seq[ParticipantId])(implicit traceContext: TraceContext): FutureUnlessShutdown[Iterable[CounterParticipantIntervalsBehind]]
  35. def getOffsetByTime(pruneUpTo: CantonTimestamp)(implicit traceContext: TraceContext): FutureUnlessShutdown[Option[Long]]
  36. def getProtocolVersion(synchronizerAlias: SynchronizerAlias)(implicit traceContext: TraceContext): FutureUnlessShutdown[ProtocolVersion]
  37. def getSequencerChannelClient(synchronizerId: SynchronizerId): Option[SequencerChannelClient]
  38. def hashCode(): Int
    Definition Classes
    AnyRef → Any
    Annotations
    @IntrinsicCandidate() @native()
  39. final def isInstanceOf[T0]: Boolean
    Definition Classes
    Any
  40. def lastSynchronizerOffset(synchronizerId: SynchronizerId)(implicit traceContext: TraceContext): Option[SynchronizerOffset]
  41. def logger: TracedLogger
    Attributes
    protected
    Definition Classes
    NamedLogging
  42. val loggerFactory: NamedLoggerFactory
    Attributes
    protected
    Definition Classes
    SyncStateInspection → NamedLogging
  43. def lookupCleanSequencerCounter(synchronizerAlias: SynchronizerAlias)(implicit traceContext: TraceContext): Either[String, FutureUnlessShutdown[Option[SequencerCounter]]]
  44. def lookupCleanSynchronizerIndex(synchronizerAlias: SynchronizerAlias)(implicit traceContext: TraceContext): Either[String, FutureUnlessShutdown[Option[SynchronizerIndex]]]
  45. def lookupCleanTimeOfRequest(synchronizerAlias: SynchronizerAlias)(implicit traceContext: TraceContext): Either[String, FutureUnlessShutdown[Option[TimeOfRequest]]]

    Returns the last clean time of request of the specified synchronizer from the indexer's point of view.

    Returns the last clean time of request of the specified synchronizer from the indexer's point of view.

    Annotations
    @VisibleForTesting()
  46. def lookupContractSynchronizers(contractIds: Set[LfContractId])(implicit traceContext: TraceContext): FutureUnlessShutdown[Map[SynchronizerId, SortedMap[LfContractId, Seq[(CantonTimestamp, ActivenessChangeDetail)]]]]

    Look up all unpruned state changes of a set of contracts on all synchronizers.

    Look up all unpruned state changes of a set of contracts on all synchronizers. If a contract is not found in an available ACS it will be omitted from the response.

  47. def lookupPublicationTime(ledgerOffset: Long)(implicit traceContext: TraceContext): EitherT[FutureUnlessShutdown, String, CantonTimestamp]
  48. def lookupReassignmentIds(targetSynchronizerId: SynchronizerId, sourceSynchronizerId: SynchronizerId, contractIds: Seq[LfContractId], minUnassignmentTs: Option[CantonTimestamp] = None, minCompletionTs: Option[CantonTimestamp] = None)(implicit traceContext: TraceContext): Map[LfContractId, Seq[ReassignmentId]]
  49. implicit def namedLoggingContext(implicit traceContext: TraceContext): NamedLoggingContext
    Attributes
    protected
    Definition Classes
    NamedLogging
  50. final def ne(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef
  51. def noOutstandingCommitmentsTs(synchronizerAlias: SynchronizerAlias, beforeOrAt: CantonTimestamp)(implicit traceContext: TraceContext): Option[CantonTimestamp]
  52. def noTracingLogger: Logger
    Attributes
    protected
    Definition Classes
    NamedLogging
  53. final def notify(): Unit
    Definition Classes
    AnyRef
    Annotations
    @IntrinsicCandidate() @native()
  54. final def notifyAll(): Unit
    Definition Classes
    AnyRef
    Annotations
    @IntrinsicCandidate() @native()
  55. def onlyForTestingMoveLedgerEndBackToScratch()(implicit traceContext: TraceContext): Unit
  56. def outstandingCommitments(synchronizerAlias: SynchronizerAlias, start: CantonTimestamp, end: CantonTimestamp, counterParticipant: Option[ParticipantId])(implicit traceContext: TraceContext): Iterable[(CommitmentPeriod, ParticipantId, CommitmentPeriodState)]
  57. def prunedUptoOffset(implicit traceContext: TraceContext): Option[Offset]
  58. def requestJournalSize(synchronizerAlias: SynchronizerAlias, start: CantonTimestamp = CantonTimestamp.Epoch, end: Option[CantonTimestamp] = None)(implicit traceContext: TraceContext): Option[UnlessShutdown[Int]]
  59. def requestStateInJournal(rc: RequestCounter, synchronizerAlias: SynchronizerAlias)(implicit traceContext: TraceContext): Either[String, FutureUnlessShutdown[Option[RequestData]]]
  60. final def synchronized[T0](arg0: => T0): T0
    Definition Classes
    AnyRef
  61. def toString(): String
    Definition Classes
    AnyRef → Any
  62. def verifyLapiStoreIntegrity()(implicit traceContext: TraceContext): Unit
  63. final def wait(arg0: Long, arg1: Int): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.InterruptedException])
  64. final def wait(arg0: Long): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.InterruptedException]) @native()
  65. 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

    (Since version 9)

Inherited from NamedLogging

Inherited from AnyRef

Inherited from Any

Ungrouped