t

com.digitalasset.canton.participant.sync

SyncDomainPersistentStateManager

trait SyncDomainPersistentStateManager extends AutoCloseable with SyncDomainPersistentStateLookup

Manages domain state that needs to survive reconnects

Factory for com.digitalasset.canton.participant.store.SyncDomainPersistentState. Tries to discover existing persistent states or create new ones and checks consistency of domain parameters and unique contract key domains

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

Abstract Value Members

  1. abstract def aliasForDomainId(domainId: DomainId): Option[DomainAlias]
  2. abstract def close(): Unit
    Definition Classes
    AutoCloseable
    Annotations
    @throws(classOf[java.lang.Exception])
  3. abstract def domainIdForAlias(domainAlias: DomainAlias): Option[DomainId]
  4. abstract def get(domainId: DomainId): Option[SyncDomainPersistentState]
  5. abstract def getAll: Map[DomainId, SyncDomainPersistentState]
  6. abstract def getByAlias(domainAlias: DomainAlias): Option[SyncDomainPersistentState]
  7. abstract def getStatusOf(domainId: DomainId): Option[Status]
  8. abstract def indexedDomainId(domainId: DomainId): Future[IndexedDomain]
  9. abstract def initializePersistentStates()(implicit traceContext: TraceContext): Future[Unit]

    Creates com.digitalasset.canton.participant.store.SyncDomainPersistentStates for all known domain aliases provided that the domain parameters and a sequencer offset are known.

    Creates com.digitalasset.canton.participant.store.SyncDomainPersistentStates for all known domain aliases provided that the domain parameters and a sequencer offset are known. Does not check for unique contract key domain constraints. Must not be called concurrently with itself or other methods of this class.

  10. abstract def lookupOrCreatePersistentState(domainAlias: DomainAlias, domainId: IndexedDomain, domainParameters: StaticDomainParameters, participantSettings: Eval[ParticipantSettingsLookup])(implicit traceContext: TraceContext): EitherT[Future, DomainRegistryError, SyncDomainPersistentState]

    Retrieves the com.digitalasset.canton.participant.store.SyncDomainPersistentState from the com.digitalasset.canton.participant.sync.SyncDomainPersistentStateManager for the given domain if there is one.

    Retrieves the com.digitalasset.canton.participant.store.SyncDomainPersistentState from the com.digitalasset.canton.participant.sync.SyncDomainPersistentStateManager for the given domain if there is one. Otherwise creates a new com.digitalasset.canton.participant.store.SyncDomainPersistentState for the domain and registers it with the com.digitalasset.canton.participant.sync.SyncDomainPersistentStateManager. Checks that the com.digitalasset.canton.protocol.StaticDomainParameters are the same as what has been persisted (if so) and enforces the unique contract key domain constraints.

    Must not be called concurrently with itself or other methods of this class.

  11. abstract def protocolVersionFor(domainId: DomainId): Option[ProtocolVersion]
  12. abstract def topologyFactoryFor(domainId: DomainId): Option[TopologyComponentFactory]

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() @IntrinsicCandidate()
  6. final def eq(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef
  7. def equals(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef → Any
  8. final def getClass(): Class[_ <: AnyRef]
    Definition Classes
    AnyRef → Any
    Annotations
    @native() @IntrinsicCandidate()
  9. def hashCode(): Int
    Definition Classes
    AnyRef → Any
    Annotations
    @native() @IntrinsicCandidate()
  10. final def isInstanceOf[T0]: Boolean
    Definition Classes
    Any
  11. final def ne(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef
  12. final def notify(): Unit
    Definition Classes
    AnyRef
    Annotations
    @native() @IntrinsicCandidate()
  13. final def notifyAll(): Unit
    Definition Classes
    AnyRef
    Annotations
    @native() @IntrinsicCandidate()
  14. final def synchronized[T0](arg0: => T0): T0
    Definition Classes
    AnyRef
  15. def toString(): String
    Definition Classes
    AnyRef → Any
  16. final def wait(arg0: Long, arg1: Int): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.InterruptedException])
  17. final def wait(arg0: Long): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.InterruptedException]) @native()
  18. 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

Inherited from AutoCloseable

Inherited from AnyRef

Inherited from Any

Ungrouped