object EnterpriseSequencerConfig

Linear Supertypes
Ordering
  1. Alphabetic
  2. By Inheritance
Inherited
  1. EnterpriseSequencerConfig
  2. AnyRef
  3. Any
  1. Hide All
  2. Show All
Visibility
  1. Public
  2. Protected

Type Members

  1. final case class BftSequencer(config: Config) extends EnterpriseSequencerConfig with Product with Serializable
  2. final case class Database(writer: SequencerWriterConfig = SequencerWriterConfig.LowLatency(), reader: EnterpriseSequencerReaderConfig = EnterpriseSequencerReaderConfig(), highAvailability: SequencerHighAvailabilityConfig = SequencerHighAvailabilityConfig(), testingInterceptor: Option[TestingInterceptor] = None, pruning: SequencerPruningConfig = SequencerPruningConfig()) extends EnterpriseSequencerConfig with DatabaseSequencerConfig with Product with Serializable
  3. final case class DatabaseSequencerExclusiveStorageConfig(connectionPool: DbLockedConnectionPoolConfig = DbLockedConnectionPoolConfig(checkPeriod = // high default check period to reduce overhead as liveness is less critical for pruning and config changes PositiveFiniteDuration.ofSeconds(60) ), maxConnections: PositiveInt = PositiveInt.tryCreate(2)) extends Product with Serializable

    Configuration for exclusive database sequencer storage

    Configuration for exclusive database sequencer storage

    connectionPool

    configuration of the exclusive write connection pool.

    maxConnections

    maximum read plus write connections.

  4. final case class EnterpriseSequencerReaderConfig(readBatchSize: Int = SequencerReaderConfig.defaultReadBatchSize, checkpointInterval: NonNegativeFiniteDuration = SequencerReaderConfig.defaultCheckpointInterval, pollingInterval: NonNegativeFiniteDuration = NonNegativeFiniteDuration.ofMillis(100)) extends SequencerReaderConfig with Product with Serializable

    Configuration for the database based sequence reader in enterprise.

    Configuration for the database based sequence reader in enterprise.

    pollingInterval

    how frequently to poll for new events from the database. only used if high availability has been configured, otherwise will rely on local writes performed by this sequencer to indicate that new events are available.

  5. final case class External(sequencerType: String, config: ConfigCursor) extends EnterpriseSequencerConfig with Product with Serializable
  6. 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.

    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.

  7. final case class SequencerPruningConfig(maxPruningBatchSize: PositiveInt = PositiveInt.tryCreate(50000), pruningMetricUpdateInterval: Option[PositiveDurationSeconds] = PositiveDurationSeconds.ofHours(1L).some, unauthenticatedMemberRetention: NonNegativeFiniteDuration = NonNegativeFiniteDuration.ofHours(1)) extends Product with Serializable

    Configuration for enterprise sequencer pruning

    Configuration for enterprise sequencer pruning

    maxPruningBatchSize

    maximum number of events to prune from a sequencer at a time, used to break up batches internally

    pruningMetricUpdateInterval

    How frequently to update the max-event-age pruning progress metric in the background. A setting of None disables background metric updating.

    unauthenticatedMemberRetention

    retention duration on how long to retain unauthenticated sequencer members that would otherwise block sequencer pruning. Unauthenticated members older than the specified retention will be automatically disabled.

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. final def eq(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef
  7. def equals(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef → Any
  8. final def getClass(): Class[_ <: AnyRef]
    Definition Classes
    AnyRef → Any
    Annotations
    @native() @HotSpotIntrinsicCandidate()
  9. def hashCode(): Int
    Definition Classes
    AnyRef → Any
    Annotations
    @native() @HotSpotIntrinsicCandidate()
  10. final def isInstanceOf[T0]: Boolean
    Definition Classes
    Any
  11. final def ne(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef
  12. final def notify(): Unit
    Definition Classes
    AnyRef
    Annotations
    @native() @HotSpotIntrinsicCandidate()
  13. final def notifyAll(): Unit
    Definition Classes
    AnyRef
    Annotations
    @native() @HotSpotIntrinsicCandidate()
  14. final def synchronized[T0](arg0: => T0): T0
    Definition Classes
    AnyRef
  15. def toString(): String
    Definition Classes
    AnyRef → Any
  16. final def wait(arg0: Long, arg1: Int): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.InterruptedException])
  17. final def wait(arg0: Long): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.InterruptedException]) @native()
  18. 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 AnyRef

Inherited from Any

Ungrouped