class SyncDomainPersistentStateFactory extends NamedLogging
Factory for 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
- SyncDomainPersistentStateFactory
- NamedLogging
- AnyRef
- Any
- Hide All
- Show All
- Public
- Protected
Instance Constructors
- new SyncDomainPersistentStateFactory(syncDomainPersistentStateManager: SyncDomainPersistentStateManager, participantSettings: Eval[ParticipantSettingsLookup], storage: Storage, pureCryptoApi: CryptoPureApi, indexedStringStore: IndexedStringStore, parameters: ParticipantNodeParameters, loggerFactory: NamedLoggerFactory)(implicit ec: ExecutionContext)
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
- implicit def errorLoggingContext(implicit traceContext: TraceContext): ErrorLoggingContext
- Attributes
- protected
- Definition Classes
- NamedLogging
- final def getClass(): Class[_ <: AnyRef]
- Definition Classes
- AnyRef → Any
- Annotations
- @native() @HotSpotIntrinsicCandidate()
- def hashCode(): Int
- Definition Classes
- AnyRef → Any
- Annotations
- @native() @HotSpotIntrinsicCandidate()
- def indexedDomainId(domainId: DomainId): Future[IndexedDomain]
- val indexedStringStore: IndexedStringStore
- def initializePersistentStates(aliasManager: DomainAliasManager)(implicit traceContext: TraceContext): Future[Unit]
Creates SyncDomainPersistentStates for all known domain aliases provided that the domain parameters and a sequencer offset are known.
Creates 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.
- final def isInstanceOf[T0]: Boolean
- Definition Classes
- Any
- def logger: TracedLogger
- Attributes
- protected
- Definition Classes
- NamedLogging
- val loggerFactory: NamedLoggerFactory
- Definition Classes
- SyncDomainPersistentStateFactory → NamedLogging
- def lookupOrCreatePersistentState(domainAlias: DomainAlias, domainId: IndexedDomain, domainParameters: StaticDomainParameters)(implicit traceContext: TraceContext): EitherT[Future, DomainRegistryError, SyncDomainPersistentState]
Retrieves the SyncDomainPersistentState from the com.digitalasset.canton.participant.sync.SyncDomainPersistentStateManager for the given domain if there is one.
Retrieves the SyncDomainPersistentState from the com.digitalasset.canton.participant.sync.SyncDomainPersistentStateManager for the given domain if there is one. Otherwise creates a new 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.
- 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() @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])