object SequencerConfig
- Alphabetic
- By Inheritance
- SequencerConfig
- AnyRef
- Any
- Hide All
- Show All
- Public
- Protected
Type Members
- final case class BftSequencer(block: BlockSequencerConfig = BlockSequencerConfig(), config: BftBlockOrdererConfig = BftBlockOrdererConfig()) extends SequencerConfig with UniformCantonConfigValidation with Product with Serializable
- final case class Database(writer: SequencerWriterConfig = SequencerWriterConfig.LowLatency(), reader: SequencerReaderConfig = SequencerReaderConfig(), highAvailability: Option[SequencerHighAvailabilityConfig] = None, testingInterceptor: Option[TestingInterceptor] = None, pruning: SequencerPruningConfig = SequencerPruningConfig()) extends SequencerConfig with DatabaseSequencerConfig with UniformCantonConfigValidation with Product with Serializable
- final case class DatabaseSequencerExclusiveStorageConfig(connectionPool: DbLockedConnectionPoolConfig = DbLockedConnectionPoolConfig(healthCheckPeriod =
// 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 EnterpriseOnlyCantonConfigValidation with 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 External(sequencerType: String, block: BlockSequencerConfig, config: ConfigCursor) extends SequencerConfig with UniformCantonConfigValidation with Product with Serializable
- final case class SequencerHighAvailabilityConfig(enabled: Option[Boolean] = None, totalNodeCount: PositiveInt = PositiveInt.tryCreate(10), keepAliveInterval: NonNegativeFiniteDuration = NonNegativeFiniteDuration.ofMillis(50L), onlineCheckInterval: NonNegativeFiniteDuration = NonNegativeFiniteDuration.ofSeconds(5L), offlineDuration: NonNegativeFiniteDuration = NonNegativeFiniteDuration.ofSeconds(8L), connectionPool: DbLockedConnectionPoolConfig = DbLockedConnectionPoolConfig(), exclusiveStorage: DatabaseSequencerExclusiveStorageConfig = DatabaseSequencerExclusiveStorageConfig()) extends EnterpriseOnlyCantonConfigValidation with Product with Serializable
Configuration for how many sequencers are concurrently operating within the synchronizer.
Configuration for how many sequencers are concurrently operating within the synchronizer.
- 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 synchronizer. 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
- 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()
- def default: SequencerConfig
- 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()
- implicit val sequencerConfigCantonConfigValidator: CantonConfigValidator[SequencerConfig]
- 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 BftSequencer extends Serializable
- object DatabaseSequencerExclusiveStorageConfig extends Serializable
- object External extends Serializable
- object SequencerHighAvailabilityConfig extends Serializable