com.digitalasset.canton.sequencing
SequencerConnectionXPool
Companion trait SequencerConnectionXPool
object SequencerConnectionXPool
- Alphabetic
- By Inheritance
- SequencerConnectionXPool
- AnyRef
- Any
- Hide All
- Show All
- Public
- Protected
Type Members
- final case class SequencerConnectionXPoolConfig(connections: NonEmpty[Seq[ConnectionXConfig]], trustThreshold: PositiveInt, restartConnectionDelay: Duration = Duration.ofMillis(500), expectedSynchronizerIdO: Option[SynchronizerId] = None) extends Product with Serializable
Sequencer pool configuration
Sequencer pool configuration
- connections
Configurations for the individual connections.
- trustThreshold
Number of connections that need to be validated and agree on bootstrap information in order for the pool to initialize and start serving connections. After initialization, if the number of connections in the pool goes below the threshold, the pool's health will transition to
degraded
(orfailed
if it reaches 0).- restartConnectionDelay
The duration after which a failed connection is restarted.
- expectedSynchronizerIdO
If provided, defines the synchronizer to which the connections are expected to connect. If empty, the synchronizer will be determined as soon as trustThreshold-many connections are validated and agree on bootstrap information.
- sealed trait SequencerConnectionXPoolError extends AnyRef
- class SequencerConnectionXPoolHealth extends AtomicHealthComponent
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]) @IntrinsicCandidate() @native()
- final def eq(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
- def equals(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef → Any
- 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
- final def ne(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
- final def notify(): Unit
- Definition Classes
- AnyRef
- Annotations
- @IntrinsicCandidate() @native()
- final def notifyAll(): Unit
- Definition Classes
- AnyRef
- Annotations
- @IntrinsicCandidate() @native()
- 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])
- object SequencerConnectionXPoolConfig extends Serializable
- object SequencerConnectionXPoolError