abstract class TopologyStore extends AutoCloseable
- Alphabetic
- By Inheritance
- TopologyStore
- AutoCloseable
- AnyRef
- Any
- Hide All
- Show All
- Public
- Protected
Instance Constructors
- new TopologyStore()(implicit ec: ExecutionContext)
Abstract Value Members
- abstract def allTransactions(implicit traceContext: TraceContext): Future[StoredTopologyTransactions[TopologyChangeOp]]
- Annotations
- @VisibleForTesting()
- abstract def close(): Unit
- Definition Classes
- AutoCloseable
- Annotations
- @throws(classOf[java.lang.Exception])
- 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!
- abstract def exists(transaction: SignedTopologyTransaction[TopologyChangeOp])(implicit traceContext: TraceContext): Future[Boolean]
- abstract def findActiveTransactionsForMapping(mapping: TopologyMapping)(implicit traceContext: TraceContext): Future[Seq[SignedTopologyTransaction[Add]]]
- abstract def findDispatchingTransactionsAfter(timestamp: CantonTimestamp)(implicit traceContext: TraceContext): Future[StoredTopologyTransactions[TopologyChangeOp]]
returns transactions that should be dispatched to the domain
- abstract def findEffectiveTimestampsSince(timestamp: CantonTimestamp)(implicit traceContext: TraceContext): Future[Seq[CantonTimestamp]]
fetch the effective time updates greater than a certain timestamp
fetch the effective time updates greater than 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
- abstract def findInitialState(uid: UniqueIdentifier)(implicit traceContext: TraceContext): Future[Map[KeyOwner, Seq[PublicKey]]]
query interface used by DomainIdentityManager to find the set of initial keys
- abstract def findPositiveTransactions(asOf: CantonTimestamp, asOfInclusive: Boolean, includeSecondary: Boolean, types: Seq[DomainTopologyTransactionType], filterUid: Option[Seq[UniqueIdentifier]], filterNamespace: Option[Seq[Namespace]])(implicit traceContext: TraceContext): Future[PositiveStoredTopologyTransactions]
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.
- includeSecondary
some topology transactions have an "secondary" uid. currently, this only applies to the party to participant mapping where the secondary uid is the participant uid. we need this information during cascading updates of participant certificates.
- abstract def findRemovalTransactionForMappings(mappings: Set[TopologyStateElement[TopologyMapping]])(implicit traceContext: TraceContext): Future[Seq[SignedTopologyTransaction[Remove]]]
finds transactions in the local store that would remove the topology state elements
- abstract def findStateTransactions(asOf: CantonTimestamp, asOfInclusive: Boolean, includeSecondary: Boolean, types: Seq[DomainTopologyTransactionType], filterUid: Option[Seq[UniqueIdentifier]], filterNamespace: Option[Seq[Namespace]])(implicit traceContext: TraceContext): Future[PositiveStoredTopologyTransactions]
find active topology transactions
find active topology transactions
active / state means that for the key authorizing the transaction, there is a connected path to reach the root certificate this function is used for updating and by the lookup client com.digitalasset.canton.topology.client.StoreBasedTopologySnapshot
- 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.
- includeSecondary
some topology transactions have an "secondary" uid. currently, this only applies to the party to participant mapping where the secondary uid is the participant uid. we need this information during cascading updates of participant certificates.
- abstract def findTransactionsInRange(asOfExclusive: CantonTimestamp, upToExclusive: CantonTimestamp)(implicit traceContext: TraceContext): Future[StoredTopologyTransactions[TopologyChangeOp]]
Returns an ordered list of transactions from the transaction store within a certain range
- abstract def findTsOfParticipantStateChangesBefore(beforeExclusive: CantonTimestamp, participantId: ParticipantId, limit: Int)(implicit traceContext: TraceContext): Future[Seq[CantonTimestamp]]
returns an descending ordered list of timestamps of when participant state changes occurred before a certain point in time
- abstract def headTransactions(implicit traceContext: TraceContext): Future[StoredTopologyTransactions[Positive]]
set of topology transactions which are active
- abstract def inspect(stateStore: Boolean, timeQuery: TimeQuery, recentTimestampO: Option[CantonTimestamp], ops: Option[TopologyChangeOp], typ: Option[DomainTopologyTransactionType], idFilter: String, namespaceOnly: Boolean)(implicit traceContext: TraceContext): Future[StoredTopologyTransactions[TopologyChangeOp]]
query optimized for inspection
query optimized for inspection
- recentTimestampO
if exists, use this timestamp for the head state to prevent race conditions on the console
- abstract def inspectKnownParties(timestamp: CantonTimestamp, filterParty: String, filterParticipant: String, limit: Int)(implicit traceContext: TraceContext): Future[Set[PartyId]]
- abstract def timestamp(implicit traceContext: TraceContext): Future[Option[CantonTimestamp]]
- abstract def updateDispatchingWatermark(timestamp: CantonTimestamp)(implicit traceContext: TraceContext): Future[Unit]
update the dispatching watermark for this target store
- abstract def updateState(timestamp: CantonTimestamp, deactivate: Seq[UniquePath], positive: Seq[SignedTopologyTransaction[Positive]])(implicit traceContext: TraceContext): Future[Unit]
update active topology transaction to the active topology transaction table
update active topology transaction to the active topology transaction table
active means that for the key authorizing the transaction, there is a connected path to reach the root certificate
Concrete 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
- def append(timestamp: CantonTimestamp, transactions: Seq[ValidatedTopologyTransaction])(implicit traceContext: TraceContext): Future[Unit]
add validated topology transaction as is to the topology transaction table
- final def asInstanceOf[T0]: T0
- Definition Classes
- Any
- def bootstrap(collection: StoredTopologyTransactions[Positive])(implicit traceContext: TraceContext): Future[Unit]
bootstrap a sequencer node state from a topology transaction collection
- def clone(): AnyRef
- Attributes
- protected[lang]
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.CloneNotSupportedException]) @native() @HotSpotIntrinsicCandidate()
- final def eq(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
- def equals(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef → Any
- final def getClass(): Class[_ <: AnyRef]
- Definition Classes
- AnyRef → Any
- Annotations
- @native() @HotSpotIntrinsicCandidate()
- def hashCode(): Int
- Definition Classes
- AnyRef → Any
- Annotations
- @native() @HotSpotIntrinsicCandidate()
- final def isInstanceOf[T0]: Boolean
- Definition Classes
- Any
- def monotonicityTimeCheckUpdate(ts: CantonTimestamp): Option[CantonTimestamp]
- Attributes
- protected
- final def ne(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
- final def notify(): Unit
- Definition Classes
- AnyRef
- Annotations
- @native() @HotSpotIntrinsicCandidate()
- final def notifyAll(): Unit
- Definition Classes
- AnyRef
- Annotations
- @native() @HotSpotIntrinsicCandidate()
- 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])