c

com.digitalasset.canton.topology.client

StoreBasedTopologySnapshot

class StoreBasedTopologySnapshot extends TopologySnapshotLoader with NamedLogging with NoTracing

Ordering
  1. Alphabetic
  2. By Inheritance
Inherited
  1. StoreBasedTopologySnapshot
  2. NoTracing
  3. TopologySnapshotLoader
  4. NamedLogging
  5. DomainGovernanceSnapshotLoader
  6. VettedPackagesSnapshotLoader
  7. KeyTopologySnapshotClientLoader
  8. ParticipantTopologySnapshotLoader
  9. PartyTopologySnapshotLoader
  10. PartyTopologySnapshotBaseClient
  11. TopologySnapshot
  12. DomainGovernanceSnapshotClient
  13. MediatorDomainStateClient
  14. VettedPackagesSnapshotClient
  15. CertificateSnapshotClient
  16. KeyTopologySnapshotClient
  17. ParticipantTopologySnapshotClient
  18. BaseTopologySnapshotClient
  19. PartyTopologySnapshotClient
  20. AnyRef
  21. Any
  1. Hide All
  2. Show All
Visibility
  1. Public
  2. Protected

Instance Constructors

  1. new StoreBasedTopologySnapshot(timestamp: CantonTimestamp, store: TopologyStore, initKeys: Map[KeyOwner, Seq[SigningPublicKey]], useStateTxs: Boolean, packageDependencies: (PackageId) => EitherT[Future, PackageId, Set[PackageId]], loggerFactory: NamedLoggerFactory)(implicit executionContext: ExecutionContext)

    timestamp

    the asOf timestamp to use

    store

    the db store to use

    initKeys

    any additional keys to use (for bootstrapping domains)

    useStateTxs

    whether the queries should use the state or the tx store. state store means all tx are properly authorized

    packageDependencies

    lookup function to determine the direct and indirect package dependencies

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 activeParticipantsOf(party: LfPartyId): Future[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
  5. def activeParticipantsOfAll(parties: List[LfPartyId]): EitherT[Future, Set[LfPartyId], Set[ParticipantId]]
    Definition Classes
    PartyTopologySnapshotBaseClient
  6. final def activeParticipantsOfParties(parties: Seq[LfPartyId]): Future[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
  7. def allHaveActiveParticipants(parties: Set[LfPartyId], check: (ParticipantPermission) => Boolean = _.isActive): EitherT[Future, Set[LfPartyId], Unit]
    Definition Classes
    PartyTopologySnapshotBaseClient
  8. def allHostedOn(partyIds: Set[LfPartyId], participantId: ParticipantId, permissionCheck: (ParticipantAttributes) => Boolean = _.permission.isActive): Future[Boolean]
    Definition Classes
    PartyTopologySnapshotBaseClient
  9. def allKeys(owner: KeyOwner): Future[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
  10. final def asInstanceOf[T0]: T0
    Definition Classes
    Any
  11. def canConfirm(participant: ParticipantId, party: LfPartyId, requiredTrustLevel: TrustLevel = TrustLevel.Ordinary): Future[Boolean]
    Definition Classes
    PartyTopologySnapshotBaseClient
  12. def clone(): AnyRef
    Attributes
    protected[lang]
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.CloneNotSupportedException]) @native() @HotSpotIntrinsicCandidate()
  13. def encryptionKey(owner: KeyOwner): Future[Option[EncryptionPublicKey]]

    returns newest encryption public key

    returns newest encryption public key

    Definition Classes
    KeyTopologySnapshotClientLoader → KeyTopologySnapshotClient
  14. def encryptionKeys(owner: KeyOwner): Future[Seq[EncryptionPublicKey]]

    returns all signing keys

    returns all signing keys

    Definition Classes
    KeyTopologySnapshotClientLoader → KeyTopologySnapshotClient
  15. final def eq(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef
  16. def equals(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef → Any
  17. implicit val executionContext: ExecutionContext
    Definition Classes
    StoreBasedTopologySnapshot → BaseTopologySnapshotClient
  18. def findDynamicDomainParameters(implicit traceContext: TraceContext): Future[Option[DynamicDomainParameters]]
    Definition Classes
    StoreBasedTopologySnapshot → DomainGovernanceSnapshotLoader
  19. def findDynamicDomainParametersOrDefault(warnOnUsingDefault: Boolean)(implicit traceContext: TraceContext): Future[DynamicDomainParameters]
    Definition Classes
    DomainGovernanceSnapshotLoader → DomainGovernanceSnapshotClient
  20. def findParticipantCertificate(participantId: ParticipantId)(implicit traceContext: TraceContext): Future[Option[X509Cert]]
    Definition Classes
    StoreBasedTopologySnapshot → CertificateSnapshotClient
  21. def findParticipantState(participantId: ParticipantId): Future[Option[ParticipantAttributes]]
    Definition Classes
    StoreBasedTopologySnapshot → ParticipantTopologySnapshotLoader
  22. def findUnvettedPackagesOrDependencies(participantId: ParticipantId, packages: Set[PackageId]): EitherT[Future, PackageId, 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
  23. def findUnvettedPackagesOrDependenciesUsingLoader(participantId: ParticipantId, packages: Set[PackageId], loader: (ParticipantId, PackageId) => EitherT[Future, PackageId, Set[PackageId]]): EitherT[Future, PackageId, Set[PackageId]]
    Attributes
    protected
    Definition Classes
    VettedPackagesSnapshotLoader
  24. final def getClass(): Class[_ <: AnyRef]
    Definition Classes
    AnyRef → Any
    Annotations
    @native() @HotSpotIntrinsicCandidate()
  25. def hasParticipantCertificate(participantId: ParticipantId)(implicit traceContext: TraceContext): Future[Boolean]
    Definition Classes
    CertificateSnapshotClient
  26. def hashCode(): Int
    Definition Classes
    AnyRef → Any
    Annotations
    @native() @HotSpotIntrinsicCandidate()
  27. def hostedOn(partyId: LfPartyId, participantId: ParticipantId): Future[Option[ParticipantAttributes]]
    Definition Classes
    PartyTopologySnapshotBaseClient
  28. def inspectKeys(filterOwner: String, filterOwnerType: Option[KeyOwnerCode], limit: Int): Future[Map[KeyOwner, KeyCollection]]

    Returns a list of all known parties on this domain

    Returns a list of all known parties on this domain

    Definition Classes
    StoreBasedTopologySnapshot → KeyTopologySnapshotClient
  29. def inspectKnownParties(filterParty: String, filterParticipant: String, limit: Int): Future[Set[PartyId]]

    Returns a list of all known parties on this domain

    Returns a list of all known parties on this domain

    Definition Classes
    StoreBasedTopologySnapshot → PartyTopologySnapshotClient
  30. def isHostedByAtLeastOneParticipantF(party: LfPartyId, check: (ParticipantAttributes) => Boolean): Future[Boolean]
    Definition Classes
    PartyTopologySnapshotBaseClient
  31. final def isInstanceOf[T0]: Boolean
    Definition Classes
    Any
  32. def isMediatorActive(mediatorId: MediatorId): Future[Boolean]
    Definition Classes
    MediatorDomainStateClient
  33. def isParticipantActive(participantId: ParticipantId): Future[Boolean]

    Checks whether the provided participant exists and is active

    Checks whether the provided participant exists and is active

    Definition Classes
    ParticipantTopologySnapshotLoader → ParticipantTopologySnapshotClient
  34. def listDynamicDomainParametersChanges()(implicit traceContext: TraceContext): Future[Seq[WithValidity]]

    List all the dynamic domain parameters (past and current)

    List all the dynamic domain parameters (past and current)

    Definition Classes
    StoreBasedTopologySnapshot → DomainGovernanceSnapshotClient
  35. def loadParticipantStates(participants: Seq[ParticipantId]): Future[Map[ParticipantId, ParticipantAttributes]]

    abstract loading function used to load the participant state for the given set of participant-ids

    abstract loading function used to load the participant state for the given set of participant-ids

    Definition Classes
    StoreBasedTopologySnapshot → ParticipantTopologySnapshotLoader
  36. def logger: TracedLogger
    Attributes
    protected
    Definition Classes
    NamedLogging
  37. val loggerFactory: NamedLoggerFactory
    Definition Classes
    StoreBasedTopologySnapshot → NamedLogging
  38. implicit def loggingContext(implicit traceContext: TraceContext): ErrorLoggingContext
    Attributes
    protected
    Definition Classes
    NamedLogging
  39. def mediators(): Future[Seq[MediatorId]]

    returns the list of currently known mediators

    returns the list of currently known mediators

    Definition Classes
    StoreBasedTopologySnapshot → MediatorDomainStateClient
  40. final def ne(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef
  41. def noTracingLogger: Logger
    Attributes
    protected
    Definition Classes
    NamedLogging
  42. final def notify(): Unit
    Definition Classes
    AnyRef
    Annotations
    @native() @HotSpotIntrinsicCandidate()
  43. final def notifyAll(): Unit
    Definition Classes
    AnyRef
    Annotations
    @native() @HotSpotIntrinsicCandidate()
  44. def participantState(participantId: ParticipantId): Future[ParticipantAttributes]
    Definition Classes
    ParticipantTopologySnapshotLoader
  45. def participants(): Future[Seq[(ParticipantId, ParticipantPermission)]]
    Definition Classes
    StoreBasedTopologySnapshot → ParticipantTopologySnapshotClient
  46. 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
  47. def signingKey(owner: KeyOwner): Future[Option[SigningPublicKey]]

    returns newest signing public key

    returns newest signing public key

    Definition Classes
    KeyTopologySnapshotClientLoader → KeyTopologySnapshotClient
  48. def signingKeys(owner: KeyOwner): Future[Seq[SigningPublicKey]]

    returns all signing keys

    returns all signing keys

    Definition Classes
    KeyTopologySnapshotClientLoader → KeyTopologySnapshotClient
  49. final def synchronized[T0](arg0: => T0): T0
    Definition Classes
    AnyRef
  50. val timestamp: CantonTimestamp

    The official timestamp corresponding to this snapshot

    The official timestamp corresponding to this snapshot

    Definition Classes
    StoreBasedTopologySnapshot → BaseTopologySnapshotClient
  51. def toString(): String
    Definition Classes
    AnyRef → Any
  52. implicit def traceContext: TraceContext
    Attributes
    protected
    Definition Classes
    NoTracing
  53. final def wait(arg0: Long, arg1: Int): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.InterruptedException])
  54. final def wait(arg0: Long): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.InterruptedException]) @native()
  55. 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 NoTracing

Inherited from TopologySnapshotLoader

Inherited from NamedLogging

Inherited from DomainGovernanceSnapshotLoader

Inherited from VettedPackagesSnapshotLoader

Inherited from KeyTopologySnapshotClientLoader

Inherited from ParticipantTopologySnapshotLoader

Inherited from PartyTopologySnapshotLoader

Inherited from PartyTopologySnapshotBaseClient

Inherited from TopologySnapshot

Inherited from DomainGovernanceSnapshotClient

Inherited from MediatorDomainStateClient

Inherited from VettedPackagesSnapshotClient

Inherited from CertificateSnapshotClient

Inherited from KeyTopologySnapshotClient

Inherited from ParticipantTopologySnapshotClient

Inherited from BaseTopologySnapshotClient

Inherited from PartyTopologySnapshotClient

Inherited from AnyRef

Inherited from Any

Ungrouped