Packages

final case class SequencerHighAvailabilityConfig(enabled: Option[Boolean] = None, totalNodeCount: PositiveInt = PositiveInt.tryCreate(10), keepAliveInterval: NonNegativeFiniteDuration = NonNegativeFiniteDuration.ofMillis(100L), onlineCheckInterval: NonNegativeFiniteDuration = NonNegativeFiniteDuration.ofSeconds(5L), offlineDuration: NonNegativeFiniteDuration = NonNegativeFiniteDuration.ofSeconds(8L), connectionPool: DbLockedConnectionPoolConfig = DbLockedConnectionPoolConfig(), exclusiveStorage: DatabaseSequencerExclusiveStorageConfig = DatabaseSequencerExclusiveStorageConfig()) extends Product with Serializable

Configuration for how many sequencers are concurrently operating within the domain.

enabled

Set to Some(true) to enable HA for the sequencer. If None it will be enabled if the storage supports replication.

totalNodeCount

how many sequencer writers will there ever be in this domain. recommend setting to a value larger than the current topology to allow for expansion.

keepAliveInterval

how frequently will we ensure the sequencer watermark is updated to ensure it still appears alive

onlineCheckInterval

how frequently should this sequencer check that nodes are still online

offlineDuration

how long should a sequencer watermark be lagging for it to be flagged as offline

connectionPool

configuration of the write connection pool used by an HA sequencer instance.

Linear Supertypes
Serializable, Product, Equals, AnyRef, Any
Ordering
  1. Alphabetic
  2. By Inheritance
Inherited
  1. SequencerHighAvailabilityConfig
  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 SequencerHighAvailabilityConfig(enabled: Option[Boolean] = None, totalNodeCount: PositiveInt = PositiveInt.tryCreate(10), keepAliveInterval: NonNegativeFiniteDuration = NonNegativeFiniteDuration.ofMillis(100L), onlineCheckInterval: NonNegativeFiniteDuration = NonNegativeFiniteDuration.ofSeconds(5L), offlineDuration: NonNegativeFiniteDuration = NonNegativeFiniteDuration.ofSeconds(8L), connectionPool: DbLockedConnectionPoolConfig = DbLockedConnectionPoolConfig(), exclusiveStorage: DatabaseSequencerExclusiveStorageConfig = DatabaseSequencerExclusiveStorageConfig())

    enabled

    Set to Some(true) to enable HA for the sequencer. If None it will be enabled if the storage supports replication.

    totalNodeCount

    how many sequencer writers will there ever be in this domain. recommend setting to a value larger than the current topology to allow for expansion.

    keepAliveInterval

    how frequently will we ensure the sequencer watermark is updated to ensure it still appears alive

    onlineCheckInterval

    how frequently should this sequencer check that nodes are still online

    offlineDuration

    how long should a sequencer watermark be lagging for it to be flagged as offline

    connectionPool

    configuration of the write connection pool used by an HA sequencer instance.

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 clone(): AnyRef
    Attributes
    protected[lang]
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.CloneNotSupportedException]) @native() @HotSpotIntrinsicCandidate()
  6. val connectionPool: DbLockedConnectionPoolConfig
  7. val enabled: Option[Boolean]
  8. final def eq(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef
  9. val exclusiveStorage: DatabaseSequencerExclusiveStorageConfig
  10. final def getClass(): Class[_ <: AnyRef]
    Definition Classes
    AnyRef → Any
    Annotations
    @native() @HotSpotIntrinsicCandidate()
  11. lazy val isEnabled: Boolean
  12. final def isInstanceOf[T0]: Boolean
    Definition Classes
    Any
  13. val keepAliveInterval: NonNegativeFiniteDuration
  14. final def ne(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef
  15. final def notify(): Unit
    Definition Classes
    AnyRef
    Annotations
    @native() @HotSpotIntrinsicCandidate()
  16. final def notifyAll(): Unit
    Definition Classes
    AnyRef
    Annotations
    @native() @HotSpotIntrinsicCandidate()
  17. val offlineDuration: NonNegativeFiniteDuration
  18. val onlineCheckInterval: NonNegativeFiniteDuration
  19. def productElementNames: Iterator[String]
    Definition Classes
    Product
  20. final def synchronized[T0](arg0: => T0): T0
    Definition Classes
    AnyRef
  21. def toOnlineSequencerCheckConfig: OnlineSequencerCheckConfig
  22. val totalNodeCount: PositiveInt
  23. final def wait(arg0: Long, arg1: Int): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.InterruptedException])
  24. final def wait(arg0: Long): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.InterruptedException]) @native()
  25. 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
    Deprecated

Inherited from Serializable

Inherited from Product

Inherited from Equals

Inherited from AnyRef

Inherited from Any

Ungrouped