class SyncPersistentStateManager extends SyncPersistentStateLookup with AutoCloseable with NamedLogging
Manages participant-relevant state for a synchronizer that needs to survive reconnects
Factory for com.digitalasset.canton.participant.store.SyncPersistentState. Tries to discover existing persistent states or create new ones and checks consistency of synchronizer parameters and unique contract key synchronizers
- Alphabetic
- By Inheritance
- SyncPersistentStateManager
- NamedLogging
- AutoCloseable
- SyncPersistentStateLookup
- AnyRef
- Any
- Hide All
- Show All
- Public
- Protected
Instance Constructors
- new SyncPersistentStateManager(participantId: ParticipantId, aliasResolution: SynchronizerAliasResolution, storage: Storage, indexedStringStore: IndexedStringStore, acsCounterParticipantConfigStore: AcsCounterParticipantConfigStore, parameters: ParticipantNodeParameters, crypto: Crypto, clock: Clock, packageDependencyResolver: PackageDependencyResolver, ledgerApiStore: Eval[LedgerApiStore], contractStore: Eval[ContractStore], futureSupervisor: FutureSupervisor, loggerFactory: NamedLoggerFactory)(implicit executionContext: 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
- def aliasForSynchronizerId(synchronizerId: SynchronizerId): Option[SynchronizerAlias]
- final def asInstanceOf[T0]: T0
- Definition Classes
- Any
- def clone(): AnyRef
- Attributes
- protected[lang]
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.CloneNotSupportedException]) @IntrinsicCandidate() @native()
- def close(): Unit
- Definition Classes
- SyncPersistentStateManager → AutoCloseable
- val contractStore: Eval[ContractStore]
- 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(synchronizerId: SynchronizerId): Option[SyncPersistentState]
- def getAll: Map[SynchronizerId, SyncPersistentState]
- Definition Classes
- SyncPersistentStateManager → SyncPersistentStateLookup
- def getByAlias(synchronizerAlias: SynchronizerAlias): Option[SyncPersistentState]
- final def getClass(): Class[_ <: AnyRef]
- Definition Classes
- AnyRef → Any
- Annotations
- @IntrinsicCandidate() @native()
- def hashCode(): Int
- Definition Classes
- AnyRef → Any
- Annotations
- @IntrinsicCandidate() @native()
- val indexedStringStore: IndexedStringStore
- def indexedSynchronizerId(synchronizerId: SynchronizerId): FutureUnlessShutdown[IndexedSynchronizer]
- def initializePersistentStates()(implicit traceContext: TraceContext): FutureUnlessShutdown[Unit]
Creates com.digitalasset.canton.participant.store.SyncPersistentStates for all known synchronizer aliases provided that the synchronizer parameters and a sequencer offset are known.
Creates com.digitalasset.canton.participant.store.SyncPersistentStates for all known synchronizer aliases provided that the synchronizer parameters and a sequencer offset are known. Does not check for unique contract key synchronizer 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
- Attributes
- protected
- Definition Classes
- SyncPersistentStateManager → NamedLogging
- def lookupOrCreatePersistentState(synchronizerAlias: SynchronizerAlias, indexedSynchronizer: IndexedSynchronizer, synchronizerParameters: StaticSynchronizerParameters)(implicit traceContext: TraceContext): EitherT[FutureUnlessShutdown, SynchronizerRegistryError, SyncPersistentState]
Retrieves the com.digitalasset.canton.participant.store.SyncPersistentState from the com.digitalasset.canton.participant.sync.SyncPersistentStateManager for the given synchronizer if there is one.
Retrieves the com.digitalasset.canton.participant.store.SyncPersistentState from the com.digitalasset.canton.participant.sync.SyncPersistentStateManager for the given synchronizer if there is one. Otherwise creates a new com.digitalasset.canton.participant.store.SyncPersistentState for the synchronizer and registers it with the com.digitalasset.canton.participant.sync.SyncPersistentStateManager. Checks that the com.digitalasset.canton.protocol.StaticSynchronizerParameters are the same as what has been persisted (if so) and enforces the unique contract key synchronizer 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
- @IntrinsicCandidate() @native()
- final def notifyAll(): Unit
- Definition Classes
- AnyRef
- Annotations
- @IntrinsicCandidate() @native()
- def protocolVersionFor(synchronizerId: SynchronizerId): Option[ProtocolVersion]
- def staticSynchronizerParameters(synchronizerId: SynchronizerId): Option[StaticSynchronizerParameters]
- final def synchronized[T0](arg0: => T0): T0
- Definition Classes
- AnyRef
- def synchronizerIdForAlias(synchronizerAlias: SynchronizerAlias): Option[SynchronizerId]
- def synchronizerTopologyStateInitFor(synchronizerId: SynchronizerId, participantId: ParticipantId)(implicit traceContext: TraceContext): EitherT[FutureUnlessShutdown, SynchronizerRegistryError, Option[SynchronizerTopologyInitializationCallback]]
- def toString(): String
- Definition Classes
- AnyRef → Any
- def topologyFactoryFor(synchronizerId: SynchronizerId, protocolVersion: ProtocolVersion): Option[TopologyComponentFactory]
- 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])