class StoreBasedTopologySnapshot extends TopologySnapshotLoader with NamedLogging
Topology snapshot loader
- Alphabetic
- By Inheritance
- StoreBasedTopologySnapshot
- TopologySnapshotLoader
- NamedLogging
- SynchronizerGovernanceSnapshotLoader
- VettedPackagesSnapshotLoader
- VettedPackagesLoader
- KeyTopologySnapshotClientLoader
- ParticipantTopologySnapshotLoader
- PartyTopologySnapshotLoader
- PartyTopologySnapshotBaseClient
- TopologySnapshot
- PartyKeyTopologySnapshotClient
- MembersTopologySnapshotClient
- SynchronizerGovernanceSnapshotClient
- SequencerSynchronizerStateClient
- MediatorSynchronizerStateClient
- VettedPackagesSnapshotClient
- KeyTopologySnapshotClient
- ParticipantTopologySnapshotClient
- BaseTopologySnapshotClient
- PartyTopologySnapshotClient
- AnyRef
- Any
- Hide All
- Show All
- Public
- Protected
Instance Constructors
- new StoreBasedTopologySnapshot(timestamp: CantonTimestamp, store: TopologyStore[TopologyStoreId], packageDependencyResolver: PackageDependencyResolverUS, loggerFactory: NamedLoggerFactory)(implicit executionContext: ExecutionContext)
- timestamp
the asOf timestamp to use
- store
the db store to use
- packageDependencyResolver
provides a way determine the direct and indirect package dependencies
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
- final def activeParticipantsOf(party: LfPartyId)(implicit traceContext: TraceContext): FutureUnlessShutdown[Map[ParticipantId, ParticipantAttributes]]
Returns the set of active participants the given party is represented by as of the snapshot timestamp
Returns the set of active participants the given party is represented by as of the snapshot timestamp
Should never return a PartyParticipantRelationship where ParticipantPermission is DISABLED.
- Definition Classes
- PartyTopologySnapshotLoader → PartyTopologySnapshotClient
- def activeParticipantsOfAll(parties: List[LfPartyId])(implicit traceContext: TraceContext): EitherT[FutureUnlessShutdown, Set[LfPartyId], Set[ParticipantId]]
- Definition Classes
- PartyTopologySnapshotBaseClient
- final def activeParticipantsOfParties(parties: Seq[LfPartyId])(implicit traceContext: TraceContext): FutureUnlessShutdown[Map[LfPartyId, Set[ParticipantId]]]
Load the set of active participants for the given parties
Load the set of active participants for the given parties
- Definition Classes
- PartyTopologySnapshotLoader → PartyTopologySnapshotClient
- final def activeParticipantsOfPartiesWithInfo(parties: Seq[LfPartyId])(implicit traceContext: TraceContext): FutureUnlessShutdown[Map[LfPartyId, PartyInfo]]
- Definition Classes
- PartyTopologySnapshotLoader → PartyTopologySnapshotClient
- def allHaveActiveParticipants(parties: Set[LfPartyId], check: (ParticipantPermission) => Boolean = _ => true)(implicit traceContext: TraceContext): EitherT[FutureUnlessShutdown, Set[LfPartyId], Unit]
- Definition Classes
- PartyTopologySnapshotBaseClient
- def allHostedOn(partyIds: Set[LfPartyId], participantId: ParticipantId, permissionCheck: (ParticipantAttributes) => Boolean = _ => true)(implicit traceContext: TraceContext): FutureUnlessShutdown[Boolean]
- Definition Classes
- PartyTopologySnapshotBaseClient
- def allKeys(members: Seq[Member])(implicit traceContext: TraceContext): FutureUnlessShutdown[Map[Member, KeyCollection]]
- Definition Classes
- StoreBasedTopologySnapshot → KeyTopologySnapshotClientLoader
- def allKeys(owner: Member)(implicit traceContext: TraceContext): FutureUnlessShutdown[KeyCollection]
abstract loading function used to obtain the full key collection for a key owner
abstract loading function used to obtain the full key collection for a key owner
- Definition Classes
- StoreBasedTopologySnapshot → KeyTopologySnapshotClientLoader
- def allMembers()(implicit traceContext: TraceContext): FutureUnlessShutdown[Set[Member]]
Convenience method to determine all members with
isMemberKnown.Convenience method to determine all members with
isMemberKnown.- Definition Classes
- StoreBasedTopologySnapshot → MembersTopologySnapshotClient
- def areMembersKnown(members: Set[Member])(implicit traceContext: TraceContext): FutureUnlessShutdown[Set[Member]]
Convenience method to check
isMemberKnownfor several members.Convenience method to check
isMemberKnownfor several members.- Definition Classes
- StoreBasedTopologySnapshot → MembersTopologySnapshotClient
- final def asInstanceOf[T0]: T0
- Definition Classes
- Any
- def canConfirm(participant: ParticipantId, parties: Set[LfPartyId])(implicit traceContext: TraceContext): FutureUnlessShutdown[Set[LfPartyId]]
- Definition Classes
- PartyTopologySnapshotBaseClient
- final def canNotSubmit(participant: ParticipantId, parties: Seq[LfPartyId])(implicit traceContext: TraceContext): FutureUnlessShutdown[Iterable[LfPartyId]]
Returns the subset of parties the given participant can NOT submit on behalf of
Returns the subset of parties the given participant can NOT submit on behalf of
- Definition Classes
- PartyTopologySnapshotLoader → PartyTopologySnapshotClient
- def clone(): AnyRef
- Attributes
- protected[lang]
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.CloneNotSupportedException]) @IntrinsicCandidate() @native()
- final def consortiumThresholds(parties: Set[LfPartyId])(implicit traceContext: TraceContext): FutureUnlessShutdown[Map[LfPartyId, PositiveInt]]
Returns the consortium thresholds (how many votes from different participants that host the consortium party are required for the confirmation to become valid).
Returns the consortium thresholds (how many votes from different participants that host the consortium party are required for the confirmation to become valid). For normal parties returns 1.
- Definition Classes
- PartyTopologySnapshotLoader → PartyTopologySnapshotClient
- final def determinePackagesWithNoVettingEntry(participantId: ParticipantId, packageIds: Set[PackageId])(implicit traceContext: TraceContext): FutureUnlessShutdown[Set[PackageId]]
Checks the vetting state for the given packages and returns the packages that have no entry in the participant's VettedPackages topology transactions.
Checks the vetting state for the given packages and returns the packages that have no entry in the participant's VettedPackages topology transactions. Note: this does not check the vetted packages for their validity period, but simply for their existence in the mapping.
- participantId
the participant for which we want to check the package vettings
- packageIds
the set of packages to check
- returns
the packages that have no entry in the participant's VettedPackages mapping
- Definition Classes
- VettedPackagesSnapshotLoader → VettedPackagesSnapshotClient
- def encryptionKey(members: Seq[Member])(implicit traceContext: TraceContext): FutureUnlessShutdown[Map[Member, EncryptionPublicKey]]
returns the newest encryption public key
returns the newest encryption public key
- Definition Classes
- KeyTopologySnapshotClientLoader → KeyTopologySnapshotClient
- def encryptionKey(owner: Member)(implicit traceContext: TraceContext): FutureUnlessShutdown[Option[EncryptionPublicKey]]
returns newest encryption public key
returns newest encryption public key
- Definition Classes
- KeyTopologySnapshotClientLoader → KeyTopologySnapshotClient
- def encryptionKeys(members: Seq[Member])(implicit traceContext: TraceContext): FutureUnlessShutdown[Map[Member, Seq[EncryptionPublicKey]]]
- Definition Classes
- KeyTopologySnapshotClientLoader → KeyTopologySnapshotClient
- def encryptionKeys(owner: Member)(implicit traceContext: TraceContext): FutureUnlessShutdown[Seq[EncryptionPublicKey]]
returns all encryption keys
returns all encryption keys
- Definition Classes
- KeyTopologySnapshotClientLoader → KeyTopologySnapshotClient
- final def eq(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
- def equals(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef → Any
- implicit def errorLoggingContext(implicit traceContext: TraceContext): ErrorLoggingContext
- Attributes
- protected
- Definition Classes
- NamedLogging
- implicit val executionContext: ExecutionContext
- Definition Classes
- StoreBasedTopologySnapshot → BaseTopologySnapshotClient
- def findDynamicSequencingParameters()(implicit traceContext: TraceContext): FutureUnlessShutdown[Either[String, DynamicSequencingParametersWithValidity]]
- Definition Classes
- StoreBasedTopologySnapshot → SynchronizerGovernanceSnapshotClient
- def findDynamicSynchronizerParameters()(implicit traceContext: TraceContext): FutureUnlessShutdown[Either[String, DynamicSynchronizerParametersWithValidity]]
- Definition Classes
- StoreBasedTopologySnapshot → SynchronizerGovernanceSnapshotClient
- def findDynamicSynchronizerParametersOrDefault(protocolVersion: ProtocolVersion, warnOnUsingDefault: Boolean = true)(implicit traceContext: TraceContext): FutureUnlessShutdown[DynamicSynchronizerParameters]
- Definition Classes
- SynchronizerGovernanceSnapshotClient
- final def findParticipantState(participantId: ParticipantId)(implicit traceContext: TraceContext): FutureUnlessShutdown[Option[ParticipantAttributes]]
- Definition Classes
- ParticipantTopologySnapshotLoader
- final def findUnvettedPackagesOrDependencies(participantId: ParticipantId, packages: Set[PackageId], ledgerTime: CantonTimestamp)(implicit traceContext: TraceContext): FutureUnlessShutdown[Set[PackageId]]
Returns the set of packages that are not vetted by the given participant
Returns the set of packages that are not vetted by the given participant
- participantId
the participant for which we want to check the package vettings
- packages
the set of packages that should be vetted
- returns
Right the set of unvetted packages (which is empty if all packages are vetted) Left if a package is missing locally such that we can not verify the vetting state of the package dependencies
- Definition Classes
- VettedPackagesSnapshotLoader → VettedPackagesSnapshotClient
- final def getClass(): Class[_ <: AnyRef]
- Definition Classes
- AnyRef → Any
- Annotations
- @IntrinsicCandidate() @native()
- def hasNoConfirmer(parties: Set[LfPartyId])(implicit traceContext: TraceContext): FutureUnlessShutdown[Set[LfPartyId]]
- Definition Classes
- PartyTopologySnapshotBaseClient
- def hashCode(): Int
- Definition Classes
- AnyRef → Any
- Annotations
- @IntrinsicCandidate() @native()
- def hostedOn(partyIds: Set[LfPartyId], participantId: ParticipantId)(implicit traceContext: TraceContext): FutureUnlessShutdown[Map[LfPartyId, ParticipantAttributes]]
- Definition Classes
- PartyTopologySnapshotBaseClient
- def inspectKeys(filterOwner: String, filterOwnerType: Option[MemberCode], limit: Int)(implicit traceContext: TraceContext): FutureUnlessShutdown[Map[Member, KeyCollection]]
Returns a list of owner's keys (at most limit)
Returns a list of owner's keys (at most limit)
- Definition Classes
- StoreBasedTopologySnapshot → KeyTopologySnapshotClient
- def inspectKnownParties(filterParty: String, filterParticipant: String)(implicit traceContext: TraceContext): FutureUnlessShutdown[Set[PartyId]]
Returns a list of all known parties on this synchronizer.
Returns a list of all known parties on this synchronizer.
- Definition Classes
- StoreBasedTopologySnapshot → PartyTopologySnapshotClient
- def isHostedByAtLeastOneParticipantF(parties: Set[LfPartyId], check: (LfPartyId, ParticipantAttributes) => Boolean)(implicit traceContext: TraceContext): FutureUnlessShutdown[Set[LfPartyId]]
- Definition Classes
- PartyTopologySnapshotBaseClient
- final def isInstanceOf[T0]: Boolean
- Definition Classes
- Any
- def isMediatorActive(mediator: MediatorGroupRecipient)(implicit traceContext: TraceContext): FutureUnlessShutdown[Boolean]
- Definition Classes
- MediatorSynchronizerStateClient
- def isMediatorActive(mediatorId: MediatorId)(implicit traceContext: TraceContext): FutureUnlessShutdown[Boolean]
Returns true if
Returns true if
- the mediator is a member of a mediator group with num_active_sequencers >= threshold
- the mediator has an OwnerToKeyMapping with at least 1 signing key
- Definition Classes
- MediatorSynchronizerStateClient
- def isMemberKnown(member: Member)(implicit traceContext: TraceContext): FutureUnlessShutdown[Boolean]
Determines if a member is known on the synchronizer (through a SynchronizerTrustCertificate, MediatorSynchronizerState, or SequencerSynchronizerState).
Determines if a member is known on the synchronizer (through a SynchronizerTrustCertificate, MediatorSynchronizerState, or SequencerSynchronizerState). Note that a "known" member is not necessarily authorized to use the synchronizer.
- Definition Classes
- StoreBasedTopologySnapshot → MembersTopologySnapshotClient
- def isParticipantActive(participantId: ParticipantId)(implicit traceContext: TraceContext): FutureUnlessShutdown[Boolean]
Checks whether the provided participant exists and is active.
Checks whether the provided participant exists and is active. Active means:
- The participant has a SynchronizerTrustCertificate. 2. The synchronizer is either unrestricted or there is a ParticipantSynchronizerPermission for the participant. 3. The participant has an OwnerToKeyMapping with signing and encryption keys.
- Definition Classes
- ParticipantTopologySnapshotLoader → ParticipantTopologySnapshotClient
- def isParticipantActiveAndCanLoginAt(participantId: ParticipantId, timestamp: CantonTimestamp)(implicit traceContext: TraceContext): FutureUnlessShutdown[Boolean]
Checks whether the provided participant exists, is active and can login at the given point in time
Checks whether the provided participant exists, is active and can login at the given point in time
(loginAfter is before timestamp)
- Definition Classes
- ParticipantTopologySnapshotLoader → ParticipantTopologySnapshotClient
- def isSequencerActive(sequencerId: SequencerId)(implicit traceContext: TraceContext): FutureUnlessShutdown[Boolean]
Returns true if
Returns true if
- the sequencer is a member of the sequencer group
- the sequencer has an OwnerToKeyMapping with at least 1 signing key
- Definition Classes
- SequencerSynchronizerStateClient
- def listDynamicSynchronizerParametersChanges()(implicit traceContext: TraceContext): FutureUnlessShutdown[Seq[DynamicSynchronizerParametersWithValidity]]
List all the dynamic synchronizer parameters (past and current)
List all the dynamic synchronizer parameters (past and current)
- Definition Classes
- StoreBasedTopologySnapshot → SynchronizerGovernanceSnapshotClient
- def loadParticipantStates(participants: Seq[ParticipantId])(implicit traceContext: TraceContext): FutureUnlessShutdown[Map[ParticipantId, ParticipantAttributes]]
Loads the participant state for the given set of participant ids.
Loads the participant state for the given set of participant ids. The result covers only active participants, i.e., only participants with SynchronizerTrustCertificates, ParticipantSynchronizerPermission (if the synchronizer is restricted), and signing and encryption keys.
- Definition Classes
- StoreBasedTopologySnapshot → ParticipantTopologySnapshotLoader
- def loadVettedPackages(participants: Seq[ParticipantId])(implicit traceContext: TraceContext): FutureUnlessShutdown[Map[ParticipantId, Map[PackageId, VettedPackage]]]
- Definition Classes
- StoreBasedTopologySnapshot → VettedPackagesLoader
- def loadVettedPackages(participant: ParticipantId)(implicit traceContext: TraceContext): FutureUnlessShutdown[Map[PackageId, VettedPackage]]
- Definition Classes
- StoreBasedTopologySnapshot → VettedPackagesLoader
- def logger: TracedLogger
- Attributes
- protected
- Definition Classes
- NamedLogging
- val loggerFactory: NamedLoggerFactory
- Definition Classes
- StoreBasedTopologySnapshot → NamedLogging
- def mediatorGroup(index: MediatorGroupIndex)(implicit traceContext: TraceContext): FutureUnlessShutdown[Option[MediatorGroup]]
- Definition Classes
- MediatorSynchronizerStateClient
- def mediatorGroups()(implicit traceContext: TraceContext): FutureUnlessShutdown[Seq[MediatorGroup]]
returns the list of currently known mediator groups
returns the list of currently known mediator groups
- Definition Classes
- StoreBasedTopologySnapshot → MediatorSynchronizerStateClient
- def mediatorGroupsOfAll(groups: Seq[MediatorGroupIndex])(implicit traceContext: TraceContext): EitherT[FutureUnlessShutdown, Seq[MediatorGroupIndex], Seq[MediatorGroup]]
- Definition Classes
- MediatorSynchronizerStateClient
- def memberFirstKnownAt(member: Member)(implicit traceContext: TraceContext): FutureUnlessShutdown[Option[(SequencedTime, EffectiveTime)]]
- Definition Classes
- StoreBasedTopologySnapshot → MembersTopologySnapshotClient
- implicit def namedLoggingContext(implicit traceContext: TraceContext): NamedLoggingContext
- Attributes
- protected
- Definition Classes
- NamedLogging
- final def ne(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
- def noTracingLogger: Logger
- Attributes
- protected
- Definition Classes
- NamedLogging
- final def notify(): Unit
- Definition Classes
- AnyRef
- Annotations
- @IntrinsicCandidate() @native()
- final def notifyAll(): Unit
- Definition Classes
- AnyRef
- Annotations
- @IntrinsicCandidate() @native()
- def partyAuthorization(party: PartyId)(implicit traceContext: TraceContext): FutureUnlessShutdown[Option[PartyAuthorizationInfo]]
returns party authorization info for a party
returns party authorization info for a party
- Definition Classes
- StoreBasedTopologySnapshot → PartyKeyTopologySnapshotClient
- def referenceTime: CantonTimestamp
Internally used reference time (representing when the last change happened that affected this snapshot)
Internally used reference time (representing when the last change happened that affected this snapshot)
- Definition Classes
- BaseTopologySnapshotClient
- def sequencerGroup()(implicit traceContext: TraceContext): FutureUnlessShutdown[Option[SequencerGroup]]
The returned sequencer group contains all sequencers that
The returned sequencer group contains all sequencers that
- are mentioned in the SequencerSynchronizerState topology transaction and
- have at least 1 signing key
- Definition Classes
- StoreBasedTopologySnapshot → SequencerSynchronizerStateClient
- def signingKeys(members: Seq[Member], filterUsage: NonEmpty[Set[SigningKeyUsage]])(implicit traceContext: TraceContext): FutureUnlessShutdown[Map[Member, Seq[SigningPublicKey]]]
- Definition Classes
- KeyTopologySnapshotClientLoader → KeyTopologySnapshotClient
- def signingKeys(owner: Member, filterUsage: NonEmpty[Set[SigningKeyUsage]])(implicit traceContext: TraceContext): FutureUnlessShutdown[Seq[SigningPublicKey]]
Retrieves the signing keys for a given owner, filtering them based on the provided usage set.
Retrieves the signing keys for a given owner, filtering them based on the provided usage set.
- owner
The owner whose signing keys are being queried.
- filterUsage
A non-empty set of usages to filter the signing keys by. At least one usage from this set must match with the key's usage.
- Definition Classes
- KeyTopologySnapshotClientLoader → KeyTopologySnapshotClient
- final def synchronized[T0](arg0: => T0): T0
- Definition Classes
- AnyRef
- val timestamp: CantonTimestamp
The official timestamp corresponding to this snapshot
The official timestamp corresponding to this snapshot
- Definition Classes
- StoreBasedTopologySnapshot → BaseTopologySnapshotClient
- def toString(): String
- Definition Classes
- AnyRef → Any
- def trafficControlParameters(protocolVersion: ProtocolVersion, warnOnUsingDefault: Boolean = true)(implicit tc: TraceContext): FutureUnlessShutdown[Option[TrafficControlParameters]]
- Definition Classes
- SynchronizerGovernanceSnapshotClient
- 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])