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
- Alphabetic
- By Inheritance
- SyncDomainPersistentStateManager
- SyncDomainPersistentStateLookup
- AutoCloseable
- AnyRef
- Any
- Hide All
- Show All
- Public
- Protected
Abstract Value Members
- abstract def aliasForDomainId(domainId: DomainId): Option[DomainAlias]
- abstract def close(): Unit
- Definition Classes
- AutoCloseable
- Annotations
- @throws(classOf[java.lang.Exception])
- abstract def domainIdForAlias(domainAlias: DomainAlias): Option[DomainId]
- abstract def domainTopologyStateInitFor(domainId: DomainId, participantId: ParticipantId)(implicit traceContext: TraceContext): EitherT[Future, DomainRegistryError, Option[DomainTopologyInitializationCallback]]
- abstract def get(domainId: DomainId): Option[SyncDomainPersistentState]
- abstract def getAll: Map[DomainId, SyncDomainPersistentState]
- Definition Classes
- SyncDomainPersistentStateLookup
- abstract def getByAlias(domainAlias: DomainAlias): Option[SyncDomainPersistentState]
- abstract def getStatusOf(domainId: DomainId): Option[Status]
- abstract def indexedDomainId(domainId: DomainId): Future[IndexedDomain]
- 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.
- 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.
- abstract def protocolVersionFor(domainId: DomainId): Option[ProtocolVersion]
- abstract def topologyFactoryFor(domainId: DomainId): Option[TopologyComponentFactory]
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
- final def asInstanceOf[T0]: T0
- Definition Classes
- Any
- 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
- 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])