abstract class TopologyStoreX[+StoreID <: TopologyStoreId] extends AutoCloseable with TopologyStoreCommon[StoreID, GenericValidatedTopologyTransactionX, GenericStoredTopologyTransactionX, GenericSignedTopologyTransactionX]

Ordering
  1. Alphabetic
  2. By Inheritance
Inherited
  1. TopologyStoreX
  2. TopologyStoreCommon
  3. AutoCloseable
  4. AnyRef
  5. Any
  1. Hide All
  2. Show All
Visibility
  1. Public
  2. Protected

Instance Constructors

  1. new TopologyStoreX()(implicit ec: ExecutionContext)

Abstract Value Members

  1. abstract def bootstrap(snapshot: GenericStoredTopologyTransactionsX)(implicit traceContext: TraceContext): Future[Unit]

    store an initial set of topology transactions as given into the store

  2. abstract def close(): Unit
    Definition Classes
    AutoCloseable
    Annotations
    @throws(classOf[java.lang.Exception])
  3. abstract def currentDispatchingWatermark(implicit traceContext: TraceContext): Future[Option[CantonTimestamp]]

    returns the current dispatching watermark

    returns the current dispatching watermark

    for topology transaction dispatching, we keep track up to which point in time we have mirrored the authorized store to the remote store

    the timestamp always refers to the timestamp of the authorized store!

    Definition Classes
    TopologyStoreCommon
  4. abstract def dumpStoreContent()(implicit traceContext: TraceContext): Unit
  5. abstract def findDispatchingTransactionsAfter(timestampExclusive: CantonTimestamp, limit: Option[Int])(implicit traceContext: TraceContext): Future[GenericStoredTopologyTransactionsX]
  6. abstract def findEssentialStateForMember(member: Member, asOfInclusive: CantonTimestamp)(implicit traceContext: TraceContext): Future[GenericStoredTopologyTransactionsX]
  7. abstract def findFirstMediatorStateForMediator(mediatorId: MediatorId)(implicit traceContext: TraceContext): Future[Option[StoredTopologyTransactionX[Replace, MediatorDomainStateX]]]
  8. abstract def findFirstTrustCertificateForParticipant(participant: ParticipantId)(implicit traceContext: TraceContext): Future[Option[StoredTopologyTransactionX[Replace, DomainTrustCertificateX]]]
  9. abstract def findParticipantOnboardingTransactions(participantId: ParticipantId, domainId: DomainId)(implicit traceContext: TraceContext): FutureUnlessShutdown[Seq[GenericSignedTopologyTransactionX]]

    returns initial set of onboarding transactions that should be dispatched to the domain

  10. abstract def findPositiveTransactions(asOf: CantonTimestamp, asOfInclusive: Boolean, isProposal: Boolean, types: Seq[Code], filterUid: Option[Seq[UniqueIdentifier]], filterNamespace: Option[Seq[Namespace]])(implicit traceContext: TraceContext): Future[PositiveStoredTopologyTransactionsX]

    returns the set of positive transactions

    returns the set of positive transactions

    this function is used by the topology processor to determine the set of transaction, such that we can perform cascading updates if there was a certificate revocation

    asOfInclusive

    whether the search interval should include the current timepoint or not. the state at t is defined as "exclusive" of t, whereas for updating the state, we need to be able to query inclusive.

  11. abstract def findProposalsByTxHash(asOfExclusive: EffectiveTime, hashes: NonEmpty[Set[TxHash]])(implicit traceContext: TraceContext): Future[Seq[GenericSignedTopologyTransactionX]]
  12. abstract def findStored(transaction: GenericSignedTopologyTransactionX)(implicit traceContext: TraceContext): Future[Option[GenericStoredTopologyTransactionX]]
    Definition Classes
    TopologyStoreCommon
  13. abstract def findStoredForVersion(transaction: GenericTopologyTransactionX, protocolVersion: ProtocolVersion)(implicit traceContext: TraceContext): Future[Option[GenericStoredTopologyTransactionX]]
  14. abstract def findTransactionsForMapping(asOfExclusive: EffectiveTime, hashes: NonEmpty[Set[MappingHash]])(implicit traceContext: TraceContext): Future[Seq[GenericSignedTopologyTransactionX]]
  15. abstract def findUpcomingEffectiveChanges(asOfInclusive: CantonTimestamp)(implicit traceContext: TraceContext): Future[Seq[Change]]

    fetch the effective time updates greater than or equal to a certain timestamp

    fetch the effective time updates greater than or equal to a certain timestamp

    this function is used to recover the future effective timestamp such that we can reschedule "pokes" of the topology client and updates of the acs commitment processor on startup

    Definition Classes
    TopologyStoreCommon
  16. abstract def inspect(proposals: Boolean, timeQuery: TimeQueryX, recentTimestampO: Option[CantonTimestamp], op: Option[TopologyChangeOpX], typ: Option[Code], idFilter: String, namespaceOnly: Boolean)(implicit traceContext: TraceContext): Future[StoredTopologyTransactionsX[TopologyChangeOpX, TopologyMappingX]]

    query optimized for inspection

    query optimized for inspection

    proposals

    if true, query only for proposals instead of approved transaction mappings

    recentTimestampO

    if exists, use this timestamp for the head state to prevent race conditions on the console

  17. abstract def inspectKnownParties(timestamp: CantonTimestamp, filterParty: String, filterParticipant: String, limit: Int)(implicit traceContext: TraceContext): Future[Set[PartyId]]
  18. abstract def maxTimestamp()(implicit traceContext: TraceContext): Future[Option[(SequencedTime, EffectiveTime)]]
    Definition Classes
    TopologyStoreCommon
  19. abstract def storeId: StoreID
    Definition Classes
    TopologyStoreCommon
  20. abstract def update(sequenced: SequencedTime, effective: EffectiveTime, removeMapping: Set[MappingHash], removeTxs: Set[TxHash], additions: Seq[GenericValidatedTopologyTransactionX], expiredAdditions: Set[TxHash])(implicit traceContext: TraceContext): Future[Unit]

    add validated topology transaction as is to the topology transaction table

  21. abstract def updateDispatchingWatermark(timestamp: CantonTimestamp)(implicit traceContext: TraceContext): Future[Unit]

    update the dispatching watermark for this target store

    update the dispatching watermark for this target store

    Definition Classes
    TopologyStoreCommon

Concrete 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. implicit val ec: ExecutionContext
    Definition Classes
    TopologyStoreX → TopologyStoreCommon
  7. final def eq(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef
  8. def equals(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef → Any
  9. final def exists(transaction: GenericSignedTopologyTransactionX)(implicit traceContext: TraceContext): Future[Boolean]
    Definition Classes
    TopologyStoreCommon
  10. final def getClass(): Class[_ <: AnyRef]
    Definition Classes
    AnyRef → Any
    Annotations
    @native() @HotSpotIntrinsicCandidate()
  11. def hashCode(): Int
    Definition Classes
    AnyRef → Any
    Annotations
    @native() @HotSpotIntrinsicCandidate()
  12. final def isInstanceOf[T0]: Boolean
    Definition Classes
    Any
  13. final def ne(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef
  14. final def notify(): Unit
    Definition Classes
    AnyRef
    Annotations
    @native() @HotSpotIntrinsicCandidate()
  15. final def notifyAll(): Unit
    Definition Classes
    AnyRef
    Annotations
    @native() @HotSpotIntrinsicCandidate()
  16. def providesAdditionalSignatures(transaction: GenericSignedTopologyTransactionX)(implicit traceContext: TraceContext): Future[Boolean]
    Definition Classes
    TopologyStoreX → TopologyStoreCommon
  17. def signedTxFromStoredTx(storedTx: GenericStoredTopologyTransactionX): SignedTopologyTransactionX[TopologyChangeOpX, TopologyMappingX]
    Attributes
    protected
    Definition Classes
    TopologyStoreX → TopologyStoreCommon
  18. final def synchronized[T0](arg0: => T0): T0
    Definition Classes
    AnyRef
  19. def toString(): String
    Definition Classes
    AnyRef → Any
  20. final def wait(arg0: Long, arg1: Int): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.InterruptedException])
  21. final def wait(arg0: Long): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.InterruptedException]) @native()
  22. 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

Ungrouped