com.digitalasset.canton.domain.sequencing
EnterpriseSequencerConfig
Companion trait EnterpriseSequencerConfig
object EnterpriseSequencerConfig
- Alphabetic
- By Inheritance
- EnterpriseSequencerConfig
- AnyRef
- Any
- Hide All
- Show All
- Public
- Protected
Type Members
- final case class BftSequencer(config: Config) extends EnterpriseSequencerConfig with Product with Serializable
- 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
- 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.
- 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.
- final case class External(sequencerType: String, config: ConfigCursor) extends EnterpriseSequencerConfig with Product with Serializable
- 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.
- 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
- 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]) @native() @HotSpotIntrinsicCandidate()
- 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
- @native() @HotSpotIntrinsicCandidate()
- def hashCode(): Int
- Definition Classes
- AnyRef → Any
- Annotations
- @native() @HotSpotIntrinsicCandidate()
- 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
- @native() @HotSpotIntrinsicCandidate()
- final def notifyAll(): Unit
- Definition Classes
- AnyRef
- Annotations
- @native() @HotSpotIntrinsicCandidate()
- 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])