abstract class SyncDomainPersistentStateManagerImpl[S <: SyncDomainPersistentState] extends SyncDomainPersistentStateManager with NamedLogging
- Alphabetic
- By Inheritance
- SyncDomainPersistentStateManagerImpl
- NamedLogging
- SyncDomainPersistentStateManager
- SyncDomainPersistentStateLookup
- AutoCloseable
- AnyRef
- Any
- Hide All
- Show All
- Public
- Protected
Instance Constructors
- new SyncDomainPersistentStateManagerImpl(aliasResolution: DomainAliasResolution, storage: Storage, indexedStringStore: IndexedStringStore, parameters: ParticipantNodeParameters, loggerFactory: NamedLoggerFactory)(implicit executionContext: ExecutionContext)
Abstract Value Members
- abstract def mkPersistentState(alias: DomainAlias, domainId: IndexedDomain, protocolVersion: ProtocolVersion): S
- Attributes
- protected
- abstract def topologyFactoryFor(domainId: DomainId): Option[TopologyComponentFactory]
- Definition Classes
- SyncDomainPersistentStateManager
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
- def aliasForDomainId(domainId: DomainId): Option[DomainAlias]
- Definition Classes
- SyncDomainPersistentStateManagerImpl → SyncDomainPersistentStateManager
- final def asInstanceOf[T0]: T0
- Definition Classes
- Any
- def clone(): AnyRef
- Attributes
- protected[lang]
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.CloneNotSupportedException]) @native() @IntrinsicCandidate()
- def close(): Unit
- Definition Classes
- SyncDomainPersistentStateManagerImpl → AutoCloseable
- def domainIdForAlias(domainAlias: DomainAlias): Option[DomainId]
- Definition Classes
- SyncDomainPersistentStateManagerImpl → SyncDomainPersistentStateManager
- 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
- def get(domainId: DomainId): Option[S]
- Definition Classes
- SyncDomainPersistentStateManagerImpl → SyncDomainPersistentStateManager
- def getAll: Map[DomainId, S]
- Definition Classes
- SyncDomainPersistentStateManagerImpl → SyncDomainPersistentStateLookup
- def getByAlias(domainAlias: DomainAlias): Option[S]
- Definition Classes
- SyncDomainPersistentStateManagerImpl → SyncDomainPersistentStateManager
- final def getClass(): Class[_ <: AnyRef]
- Definition Classes
- AnyRef → Any
- Annotations
- @native() @IntrinsicCandidate()
- def getStatusOf(domainId: DomainId): Option[Status]
- Definition Classes
- SyncDomainPersistentStateManagerImpl → SyncDomainPersistentStateManager
- def hashCode(): Int
- Definition Classes
- AnyRef → Any
- Annotations
- @native() @IntrinsicCandidate()
- def indexedDomainId(domainId: DomainId): Future[IndexedDomain]
- Definition Classes
- SyncDomainPersistentStateManagerImpl → SyncDomainPersistentStateManager
- val indexedStringStore: IndexedStringStore
- 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.
- Definition Classes
- SyncDomainPersistentStateManagerImpl → SyncDomainPersistentStateManager
- final def isInstanceOf[T0]: Boolean
- Definition Classes
- Any
- def logger: TracedLogger
- Attributes
- protected
- Definition Classes
- NamedLogging
- val loggerFactory: NamedLoggerFactory
- Attributes
- protected
- Definition Classes
- SyncDomainPersistentStateManagerImpl → NamedLogging
- 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.
- Definition Classes
- SyncDomainPersistentStateManagerImpl → SyncDomainPersistentStateManager
- 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
- @native() @IntrinsicCandidate()
- final def notifyAll(): Unit
- Definition Classes
- AnyRef
- Annotations
- @native() @IntrinsicCandidate()
- def protocolVersionFor(domainId: DomainId): Option[ProtocolVersion]
- Definition Classes
- SyncDomainPersistentStateManagerImpl → SyncDomainPersistentStateManager
- 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])