Packages

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

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 (or failed 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.

Linear Supertypes
Serializable, Product, Equals, AnyRef, Any
Ordering
  1. Alphabetic
  2. By Inheritance
Inherited
  1. SequencerConnectionXPoolConfig
  2. Serializable
  3. Product
  4. Equals
  5. AnyRef
  6. Any
  1. Hide All
  2. Show All
Visibility
  1. Public
  2. Protected

Instance Constructors

  1. new SequencerConnectionXPoolConfig(connections: NonEmpty[Seq[ConnectionXConfig]], trustThreshold: PositiveInt, restartConnectionDelay: Duration = Duration.ofMillis(500), expectedSynchronizerIdO: Option[SynchronizerId] = None)

    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 (or failed 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.

Value Members

  1. final def !=(arg0: Any): Boolean
    Definition Classes
    AnyRef → Any
  2. final def ##: Int
    Definition Classes
    AnyRef → Any
  3. final def ==(arg0: Any): Boolean
    Definition Classes
    AnyRef → Any
  4. final def asInstanceOf[T0]: T0
    Definition Classes
    Any
  5. def changedConnections(newConfig: SequencerConnectionXPoolConfig): ChangedConnections
  6. def clone(): AnyRef
    Attributes
    protected[lang]
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.CloneNotSupportedException]) @IntrinsicCandidate() @native()
  7. val connections: NonEmpty[Seq[ConnectionXConfig]]
  8. final def eq(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef
  9. val expectedSynchronizerIdO: Option[SynchronizerId]
  10. final def getClass(): Class[_ <: AnyRef]
    Definition Classes
    AnyRef → Any
    Annotations
    @IntrinsicCandidate() @native()
  11. final def isInstanceOf[T0]: Boolean
    Definition Classes
    Any
  12. final def ne(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef
  13. final def notify(): Unit
    Definition Classes
    AnyRef
    Annotations
    @IntrinsicCandidate() @native()
  14. final def notifyAll(): Unit
    Definition Classes
    AnyRef
    Annotations
    @IntrinsicCandidate() @native()
  15. def productElementNames: Iterator[String]
    Definition Classes
    Product
  16. val restartConnectionDelay: Duration
  17. final def synchronized[T0](arg0: => T0): T0
    Definition Classes
    AnyRef
  18. val trustThreshold: PositiveInt
  19. def validate: Either[SequencerConnectionXPoolError, Unit]
  20. final def wait(arg0: Long, arg1: Int): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.InterruptedException])
  21. final def wait(arg0: Long): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.InterruptedException]) @native()
  22. final def wait(): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.InterruptedException])

Deprecated Value Members

  1. def finalize(): Unit
    Attributes
    protected[lang]
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.Throwable]) @Deprecated
    Deprecated

    (Since version 9)

Inherited from Serializable

Inherited from Product

Inherited from Equals

Inherited from AnyRef

Inherited from Any

Ungrouped