class InMemorySynchronizerConnectionConfigStore extends SynchronizerConnectionConfigStore with NamedLogging
- Alphabetic
- By Inheritance
- InMemorySynchronizerConnectionConfigStore
- NamedLogging
- SynchronizerConnectionConfigStore
- AutoCloseable
- AnyRef
- Any
- Hide All
- Show All
- Public
- Protected
Instance Constructors
- new InMemorySynchronizerConnectionConfigStore(aliasResolution: SynchronizerAliasResolution, loggerFactory: NamedLoggerFactory)
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
- val aliasResolution: SynchronizerAliasResolution
- Definition Classes
- InMemorySynchronizerConnectionConfigStore → SynchronizerConnectionConfigStore
- 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
- InMemorySynchronizerConnectionConfigStore → AutoCloseable
- implicit val ec: ExecutionContext
- Attributes
- protected
- Definition Classes
- InMemorySynchronizerConnectionConfigStore → SynchronizerConnectionConfigStore
- 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): Either[UnknownPSId, StoredSynchronizerConnectionConfig]
Retrieves the config for a given id.
Retrieves the config for a given id. Will return an SynchronizerConnectionConfigStore.UnknownPSId error if there is no config for id.
- Definition Classes
- InMemorySynchronizerConnectionConfigStore → SynchronizerConnectionConfigStore
- def get(alias: SynchronizerAlias, configuredPSId: ConfiguredPhysicalSynchronizerId): Either[MissingConfigForSynchronizer, StoredSynchronizerConnectionConfig]
Retrieves the config for a given alias and id.
Retrieves the config for a given alias and id. Will return an SynchronizerConnectionConfigStore.MissingConfigForSynchronizer error if there is no config for the pair (alias, id).
- Definition Classes
- InMemorySynchronizerConnectionConfigStore → SynchronizerConnectionConfigStore
- def getActive(id: SynchronizerId): Either[Error, StoredSynchronizerConnectionConfig]
Retrieves the active connection for
id.Retrieves the active connection for
id. Return an SynchronizerConnectionConfigStore.Error if the id is unknown or if no connection is active. If several active configs are found, return the one with the highest com.digitalasset.canton.topology.PhysicalSynchronizerId.- Definition Classes
- SynchronizerConnectionConfigStore
- def getActive(alias: SynchronizerAlias): Either[Error, StoredSynchronizerConnectionConfig]
Retrieves the active connection for
alias.Retrieves the active connection for
alias. Return an SynchronizerConnectionConfigStore.Error if the alias is unknown or if no connection is active. If several active configs are found, return the one with the highest com.digitalasset.canton.topology.PhysicalSynchronizerId.- Definition Classes
- SynchronizerConnectionConfigStore
- def getAll(): Seq[StoredSynchronizerConnectionConfig]
Retrieves all configured synchronizers connection configs
Retrieves all configured synchronizers connection configs
- Definition Classes
- InMemorySynchronizerConnectionConfigStore → SynchronizerConnectionConfigStore
- def getAllFor(alias: SynchronizerAlias): Either[UnknownAlias, NonEmpty[Seq[StoredSynchronizerConnectionConfig]]]
- Definition Classes
- InMemorySynchronizerConnectionConfigStore → SynchronizerConnectionConfigStore
- def getAllFor(id: SynchronizerId): Either[UnknownId, NonEmpty[Seq[StoredSynchronizerConnectionConfig]]]
- Definition Classes
- SynchronizerConnectionConfigStore
- def getAllForAliasInternal(alias: SynchronizerAlias)(implicit traceContext: TraceContext): FutureUnlessShutdown[Seq[StoredSynchronizerConnectionConfig]]
- Attributes
- protected
- Definition Classes
- InMemorySynchronizerConnectionConfigStore → SynchronizerConnectionConfigStore
- def getAllStatusesFor(id: SynchronizerId): Either[UnknownId, NonEmpty[Seq[Status]]]
- Definition Classes
- SynchronizerConnectionConfigStore
- final def getClass(): Class[_ <: AnyRef]
- Definition Classes
- AnyRef → Any
- Annotations
- @IntrinsicCandidate() @native()
- def hashCode(): Int
- Definition Classes
- AnyRef → Any
- Annotations
- @IntrinsicCandidate() @native()
- final def isInstanceOf[T0]: Boolean
- Definition Classes
- Any
- def logger: TracedLogger
- Attributes
- protected
- Definition Classes
- NamedLogging
- val loggerFactory: NamedLoggerFactory
- Attributes
- protected
- Definition Classes
- InMemorySynchronizerConnectionConfigStore → NamedLogging
- 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 predecessorCompatibilityCheck(configuredPSId: ConfiguredPhysicalSynchronizerId, synchronizerPredecessor: Option[SynchronizerPredecessor]): Either[Error, Unit]
Ensures a configured PSId can be the successor of another one.
Ensures a configured PSId can be the successor of another one.
- Attributes
- protected
- Definition Classes
- SynchronizerConnectionConfigStore
- def put(config: SynchronizerConnectionConfig, status: Status, configuredPSId: ConfiguredPhysicalSynchronizerId, synchronizerPredecessor: Option[SynchronizerPredecessor])(implicit traceContext: TraceContext): EitherT[FutureUnlessShutdown, Error, Unit]
Stores a synchronizer connection config together with the status.
Stores a synchronizer connection config together with the status. Primary identifier is the (synchronizer alias, physical synchronizer id). Will return an SynchronizerConnectionConfigStore.ConfigAlreadyExists error if a config for that alias and physical synchronizer id already exists.
- Definition Classes
- InMemorySynchronizerConnectionConfigStore → SynchronizerConnectionConfigStore
- def refreshCache()(implicit traceContext: TraceContext): FutureUnlessShutdown[Unit]
We have no cache so is effectively a noop.
We have no cache so is effectively a noop.
- Definition Classes
- InMemorySynchronizerConnectionConfigStore → SynchronizerConnectionConfigStore
- def replace(configuredPSId: ConfiguredPhysicalSynchronizerId, config: SynchronizerConnectionConfig)(implicit traceContext: TraceContext): EitherT[FutureUnlessShutdown, Error, Unit]
Replaces the config for the given alias and physical synchronizer id.
Replaces the config for the given alias and physical synchronizer id. Will return an SynchronizerConnectionConfigStore.MissingConfigForSynchronizer error if there is no config for the (alias, physicalSynchronizerId).
- Definition Classes
- InMemorySynchronizerConnectionConfigStore → SynchronizerConnectionConfigStore
- def setPhysicalSynchronizerId(alias: SynchronizerAlias, psid: PhysicalSynchronizerId)(implicit traceContext: TraceContext): EitherT[FutureUnlessShutdown, Error, Unit]
- Definition Classes
- InMemorySynchronizerConnectionConfigStore → SynchronizerConnectionConfigStore
- def setStatus(alias: SynchronizerAlias, configuredPSId: ConfiguredPhysicalSynchronizerId, status: Status)(implicit traceContext: TraceContext): EitherT[FutureUnlessShutdown, Error, Unit]
Set the synchronizer configuration status
Set the synchronizer configuration status
- Definition Classes
- InMemorySynchronizerConnectionConfigStore → SynchronizerConnectionConfigStore
- 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])
- final def wait(): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.InterruptedException])