c

com.digitalasset.canton.topology.client

CachingTopologySnapshot

class CachingTopologySnapshot extends TopologySnapshotLoader with NamedLogging with NoTracing

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

Instance Constructors

  1. new CachingTopologySnapshot(parent: TopologySnapshotLoader, cachingConfigs: CachingConfigs, batchingConfig: BatchingConfig, loggerFactory: NamedLoggerFactory)(implicit executionContext: 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. 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. final def activeParticipantsOfPartiesWithAttributes(parties: Seq[LfPartyId]): Future[Map[LfPartyId, Map[ParticipantId, ParticipantAttributes]]]
    Definition Classes
    PartyTopologySnapshotLoader → PartyTopologySnapshotClient
  8. def allHaveActiveParticipants(parties: Set[LfPartyId], check: (ParticipantPermission) => Boolean = _.isActive): EitherT[Future, Set[LfPartyId], Unit]
    Definition Classes
    PartyTopologySnapshotBaseClient
  9. def allHostedOn(partyIds: Set[LfPartyId], participantId: ParticipantId, permissionCheck: (ParticipantAttributes) => Boolean = _.permission.isActive): Future[Boolean]
    Definition Classes
    PartyTopologySnapshotBaseClient
  10. 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
    CachingTopologySnapshot → KeyTopologySnapshotClientLoader
  11. def allMembers(): Future[Set[Member]]

    returns the set of all known members

    returns the set of all known members

    Definition Classes
    CachingTopologySnapshotMembersTopologySnapshotClient
  12. final def asInstanceOf[T0]: T0
    Definition Classes
    Any
  13. def authorityOf(parties: Set[LfPartyId]): Future[AuthorityOfResponse]

    Returns the Authority-Of delegations for consortium parties.

    Returns the Authority-Of delegations for consortium parties. Non-consortium parties delegate to themselves with threshold one

    Definition Classes
    CachingTopologySnapshotPartyTopologySnapshotClient
  14. def canConfirm(participant: ParticipantId, party: LfPartyId, requiredTrustLevel: TrustLevel = TrustLevel.Ordinary): Future[Boolean]
    Definition Classes
    PartyTopologySnapshotBaseClient
  15. def clone(): AnyRef
    Attributes
    protected[lang]
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.CloneNotSupportedException]) @native() @IntrinsicCandidate()
  16. final def consortiumThresholds(parties: Set[LfPartyId]): Future[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
  17. def encryptionKey(owner: KeyOwner): Future[Option[EncryptionPublicKey]]

    returns newest encryption public key

    returns newest encryption public key

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

    returns all encryption keys

    returns all encryption keys

    Definition Classes
    KeyTopologySnapshotClientLoader → KeyTopologySnapshotClient
  19. final def eq(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef
  20. def equals(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef → Any
  21. implicit def errorLoggingContext(implicit traceContext: TraceContext): ErrorLoggingContext
    Attributes
    protected
    Definition Classes
    NamedLogging
  22. implicit val executionContext: ExecutionContext
  23. def findDynamicDomainParameters()(implicit traceContext: TraceContext): Future[Either[String, DynamicDomainParametersWithValidity]]
  24. def findDynamicDomainParametersOrDefault(protocolVersion: ProtocolVersion, warnOnUsingDefault: Boolean = true)(implicit traceContext: TraceContext): Future[DynamicDomainParameters]
  25. def findParticipantCertificate(participantId: ParticipantId)(implicit traceContext: TraceContext): Future[Option[X509Cert]]
  26. def findParticipantState(participantId: ParticipantId): Future[Option[ParticipantAttributes]]
    Definition Classes
    CachingTopologySnapshot → ParticipantTopologySnapshotLoader
  27. def findUnvettedPackagesOrDependencies(participantId: ParticipantId, packages: Set[PackageId]): EitherT[FutureUnlessShutdown, 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
    CachingTopologySnapshotVettedPackagesSnapshotLoaderVettedPackagesSnapshotClient
  28. def findUnvettedPackagesOrDependenciesUsingLoader(participantId: ParticipantId, packages: Set[PackageId], loader: (ParticipantId, PackageId) => EitherT[FutureUnlessShutdown, PackageId, Set[PackageId]]): EitherT[FutureUnlessShutdown, PackageId, Set[PackageId]]
    Attributes
    protected
    Definition Classes
    VettedPackagesSnapshotLoader
  29. final def getClass(): Class[_ <: AnyRef]
    Definition Classes
    AnyRef → Any
    Annotations
    @native() @IntrinsicCandidate()
  30. def hasParticipantCertificate(participantId: ParticipantId)(implicit traceContext: TraceContext): Future[Boolean]
    Definition Classes
    CertificateSnapshotClient
    Annotations
    @Deprecated
  31. def hashCode(): Int
    Definition Classes
    AnyRef → Any
    Annotations
    @native() @IntrinsicCandidate()
  32. def hostedOn(partyId: LfPartyId, participantId: ParticipantId): Future[Option[ParticipantAttributes]]
    Definition Classes
    PartyTopologySnapshotBaseClient
  33. 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
    CachingTopologySnapshotKeyTopologySnapshotClient
  34. 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
    CachingTopologySnapshotPartyTopologySnapshotClient
  35. def isHostedByAtLeastOneParticipantF(party: LfPartyId, check: (ParticipantAttributes) => Boolean): Future[Boolean]
    Definition Classes
    PartyTopologySnapshotBaseClient
  36. final def isInstanceOf[T0]: Boolean
    Definition Classes
    Any
  37. def isMediatorActive(mediator: MediatorRef): Future[Boolean]
    Definition Classes
    MediatorDomainStateClient
  38. def isMediatorActive(mediatorId: MediatorId): Future[Boolean]
    Definition Classes
    MediatorDomainStateClient
  39. def isMemberKnown(member: Member): Future[Boolean]
  40. 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
  41. def listDynamicDomainParametersChanges()(implicit traceContext: TraceContext): Future[Seq[DynamicDomainParametersWithValidity]]

    List all the dynamic domain parameters (past and current)

    List all the dynamic domain parameters (past and current)

    Definition Classes
    CachingTopologySnapshotDomainGovernanceSnapshotClient
  42. def loadActiveParticipantsOf(party: PartyId, participantStates: (Seq[ParticipantId]) => Future[Map[ParticipantId, ParticipantAttributes]]): Future[PartyInfo]
    Definition Classes
    CachingTopologySnapshot → PartyTopologySnapshotLoader
  43. 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
    CachingTopologySnapshot → ParticipantTopologySnapshotLoader
  44. def logger: TracedLogger
    Attributes
    protected
    Definition Classes
    NamedLogging
  45. val loggerFactory: NamedLoggerFactory
  46. def mediatorGroups(): Future[Seq[MediatorGroup]]

    returns the list of currently known mediators

    returns the list of currently known mediators

    Definition Classes
    CachingTopologySnapshotMediatorDomainStateClient
  47. implicit def namedLoggingContext(implicit traceContext: TraceContext): NamedLoggingContext
    Attributes
    protected
    Definition Classes
    NamedLogging
  48. final def ne(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef
  49. def noTracingLogger: Logger
    Attributes
    protected
    Definition Classes
    NamedLogging
  50. final def notify(): Unit
    Definition Classes
    AnyRef
    Annotations
    @native() @IntrinsicCandidate()
  51. final def notifyAll(): Unit
    Definition Classes
    AnyRef
    Annotations
    @native() @IntrinsicCandidate()
  52. def participantState(participantId: ParticipantId): Future[ParticipantAttributes]
    Definition Classes
    ParticipantTopologySnapshotLoader
  53. def participants(): Future[Seq[(ParticipantId, ParticipantPermission)]]
  54. 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
  55. def sequencerGroup(): Future[Option[SequencerGroup]]

    returns the sequencer group if known

    returns the sequencer group if known

    Definition Classes
    CachingTopologySnapshotSequencerDomainStateClient
  56. def signingKey(owner: KeyOwner): Future[Option[SigningPublicKey]]

    returns newest signing public key

    returns newest signing public key

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

    returns all signing keys

    returns all signing keys

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

    The official timestamp corresponding to this snapshot

    The official timestamp corresponding to this snapshot

    Definition Classes
    CachingTopologySnapshotBaseTopologySnapshotClient
  60. def toString(): String
    Definition Classes
    AnyRef → Any
  61. implicit def traceContext: TraceContext
    Attributes
    protected
    Definition Classes
    NoTracing
  62. def trafficControlStatus(members: Seq[Member]): Future[Map[Member, Option[MemberTrafficControlState]]]

    Return the traffic control states for the members specified

    Return the traffic control states for the members specified

    members

    for which to return the traffic state

    returns

    all input members with their optional traffic state

    Definition Classes
    CachingTopologySnapshotDomainTrafficControlStateClient
  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
    Deprecated
  2. final def mediators(): Future[Seq[MediatorId]]

    returns the list of currently known mediators

    returns the list of currently known mediators

    Definition Classes
    MediatorDomainStateClient
    Annotations
    @deprecated
    Deprecated

    (Since version 2.7) Use mediatorGroups instead.

Inherited from NoTracing

Inherited from TopologySnapshotLoader

Inherited from NamedLogging

Inherited from KeyTopologySnapshotClientLoader

Inherited from ParticipantTopologySnapshotLoader

Inherited from PartyTopologySnapshotLoader

Inherited from PartyTopologySnapshotBaseClient

Inherited from TopologySnapshot

Inherited from AnyRef

Inherited from Any

Ungrouped