class SyncPersistentStateManager extends SyncPersistentStateLookup with StaticSynchronizerParametersGetter 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
- StaticSynchronizerParametersGetter
- 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, synchronizerConnectionConfigStore: SynchronizerConnectionConfigStore, synchronizerCryptoFactory: (StaticSynchronizerParameters) => SynchronizerCrypto, 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 acsCommitmentStore(synchronizerId: SynchronizerId): Option[AcsCommitmentStore]
- Definition Classes
- SyncPersistentStateManager → SyncPersistentStateLookup
- def acsCommitmentStore(synchronizerAlias: SynchronizerAlias): Option[AcsCommitmentStore]
- Definition Classes
- SyncPersistentStateLookup
- def acsInspection(synchronizerId: SynchronizerId): Option[AcsInspection]
- Definition Classes
- SyncPersistentStateManager → SyncPersistentStateLookup
- def acsInspection(synchronizerAlias: SynchronizerAlias): Option[AcsInspection]
- Definition Classes
- SyncPersistentStateLookup
- def activeContractStore(synchronizerId: SynchronizerId): Option[ActiveContractStore]
- Definition Classes
- SyncPersistentStateManager → SyncPersistentStateLookup
- def activeContractStore(synchronizerAlias: SynchronizerAlias): Option[ActiveContractStore]
- Definition Classes
- SyncPersistentStateLookup
- def aliasForSynchronizerId(synchronizerId: SynchronizerId): Option[SynchronizerAlias]
- Definition Classes
- SyncPersistentStateManager → SyncPersistentStateLookup
- def allKnownLSIds: Set[SynchronizerId]
- Definition Classes
- SyncPersistentStateLookup
- 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
- def connectionConfig(psid: PhysicalSynchronizerId): Option[StoredSynchronizerConnectionConfig]
- Definition Classes
- SyncPersistentStateManager → SyncPersistentStateLookup
- 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(psid: PhysicalSynchronizerId): Option[SyncPersistentState]
- Definition Classes
- SyncPersistentStateManager → SyncPersistentStateLookup
- def getAll: Map[PhysicalSynchronizerId, SyncPersistentState]
- Definition Classes
- SyncPersistentStateManager → SyncPersistentStateLookup
- def getAllFor(id: SynchronizerId): Seq[SyncPersistentState]
- Definition Classes
- SyncPersistentStateManager → SyncPersistentStateLookup
- def getAllLatest: Map[SynchronizerId, SyncPersistentState]
Return the latest com.digitalasset.canton.participant.store.SyncPersistentState (wrt to com.digitalasset.canton.topology.PhysicalSynchronizerId) for each com.digitalasset.canton.topology.SynchronizerId
Return the latest com.digitalasset.canton.participant.store.SyncPersistentState (wrt to com.digitalasset.canton.topology.PhysicalSynchronizerId) for each com.digitalasset.canton.topology.SynchronizerId
- Definition Classes
- SyncPersistentStateLookup
- def getAllLogical: Map[SynchronizerId, LogicalSyncPersistentState]
Return the com.digitalasset.canton.participant.store.LogicalSyncPersistentState for all com.digitalasset.canton.topology.SynchronizerId
Return the com.digitalasset.canton.participant.store.LogicalSyncPersistentState for all com.digitalasset.canton.topology.SynchronizerId
- Definition Classes
- SyncPersistentStateManager → SyncPersistentStateLookup
- final def getClass(): Class[_ <: AnyRef]
- Definition Classes
- AnyRef → Any
- Annotations
- @IntrinsicCandidate() @native()
- def getLatest(synchronizerAlias: SynchronizerAlias): Option[SyncPersistentState]
Return the latest com.digitalasset.canton.participant.store.SyncPersistentState (wrt to com.digitalasset.canton.topology.PhysicalSynchronizerId) for
synchronizerAliasReturn the latest com.digitalasset.canton.participant.store.SyncPersistentState (wrt to com.digitalasset.canton.topology.PhysicalSynchronizerId) for
synchronizerAlias- Definition Classes
- SyncPersistentStateLookup
- def getPhysicalSynchronizerIdx(synchronizerId: PhysicalSynchronizerId): FutureUnlessShutdown[IndexedPhysicalSynchronizer]
- def getSynchronizerIdx(synchronizerId: SynchronizerId): FutureUnlessShutdown[IndexedSynchronizer]
- def hashCode(): Int
- Definition Classes
- AnyRef → Any
- Annotations
- @IntrinsicCandidate() @native()
- val indexedStringStore: IndexedStringStore
- 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 latestKnownPSId(synchronizerId: SynchronizerId): Option[PhysicalSynchronizerId]
Return the latest com.digitalasset.canton.topology.PhysicalSynchronizerId known for the given com.digitalasset.canton.topology.SynchronizerId.
Return the latest com.digitalasset.canton.topology.PhysicalSynchronizerId known for the given com.digitalasset.canton.topology.SynchronizerId.
Use cases are:
- submission of a transaction (phase 1)
- repair service
- inspection services
- Definition Classes
- SyncPersistentStateManager → StaticSynchronizerParametersGetter → SyncPersistentStateLookup
- def latestKnownProtocolVersion(synchronizerId: SynchronizerId): Option[ProtocolVersion]
Return the latest com.digitalasset.canton.version.ProtocolVersion known for the given com.digitalasset.canton.topology.SynchronizerId.
Return the latest com.digitalasset.canton.version.ProtocolVersion known for the given com.digitalasset.canton.topology.SynchronizerId.
Use cases are:
- submission of a transaction (phase 1)
- repair service
- inspection services
- Definition Classes
- StaticSynchronizerParametersGetter
- def logger: TracedLogger
- Attributes
- protected
- Definition Classes
- NamedLogging
- val loggerFactory: NamedLoggerFactory
- Attributes
- protected
- Definition Classes
- SyncPersistentStateManager → NamedLogging
- def lookupOrCreatePersistentState(synchronizerAlias: SynchronizerAlias, physicalSynchronizerIdx: IndexedPhysicalSynchronizer, synchronizerIdx: 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 reassignmentStore(synchronizerId: SynchronizerId): Option[ReassignmentStore]
- Definition Classes
- SyncPersistentStateManager → SyncPersistentStateLookup
- def reassignmentStore(synchronizerAlias: SynchronizerAlias): Option[ReassignmentStore]
- Definition Classes
- SyncPersistentStateLookup
- def staticSynchronizerParameters(synchronizerId: PhysicalSynchronizerId): Option[StaticSynchronizerParameters]
- Definition Classes
- SyncPersistentStateManager → StaticSynchronizerParametersGetter
- final def synchronized[T0](arg0: => T0): T0
- Definition Classes
- AnyRef
- def synchronizerIdForAlias(synchronizerAlias: SynchronizerAlias): Option[SynchronizerId]
- Definition Classes
- SyncPersistentStateManager → SyncPersistentStateLookup
- def synchronizerIdsForAlias(synchronizerAlias: SynchronizerAlias): Option[NonEmpty[Set[PhysicalSynchronizerId]]]
- Definition Classes
- SyncPersistentStateManager → SyncPersistentStateLookup
- def synchronizerTopologyStateInitFor(synchronizerId: PhysicalSynchronizerId, participantId: ParticipantId)(implicit traceContext: TraceContext): EitherT[FutureUnlessShutdown, SynchronizerRegistryError, Option[SynchronizerTopologyInitializationCallback]]
- def toString(): String
- Definition Classes
- AnyRef → Any
- def topologyFactoryFor(psid: PhysicalSynchronizerId): Option[TopologyComponentFactory]
- Definition Classes
- SyncPersistentStateManager → SyncPersistentStateLookup
- 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])
- final def wait(): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.InterruptedException])