com.digitalasset.canton.domain.sequencing.EnterpriseSequencerConfig
EnterpriseSequencerReaderConfig
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.
- 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.
- Alphabetic
- By Inheritance
- EnterpriseSequencerReaderConfig
- Serializable
- Product
- Equals
- SequencerReaderConfig
- AnyRef
- Any
- Hide All
- Show All
- Public
- Protected
Instance Constructors
- new EnterpriseSequencerReaderConfig(readBatchSize: Int = SequencerReaderConfig.defaultReadBatchSize, checkpointInterval: NonNegativeFiniteDuration = SequencerReaderConfig.defaultCheckpointInterval, pollingInterval: NonNegativeFiniteDuration = NonNegativeFiniteDuration.ofMillis(100))
- 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.
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
- val checkpointInterval: NonNegativeFiniteDuration
how frequently to checkpoint state
how frequently to checkpoint state
- Definition Classes
- EnterpriseSequencerReaderConfig → SequencerReaderConfig
- 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
- final def getClass(): Class[_ <: AnyRef]
- 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()
- val pollingInterval: NonNegativeFiniteDuration
- def productElementNames: Iterator[String]
- Definition Classes
- Product
- val readBatchSize: Int
max number of events to fetch from the datastore in one page
max number of events to fetch from the datastore in one page
- Definition Classes
- EnterpriseSequencerReaderConfig → SequencerReaderConfig
- final def synchronized[T0](arg0: => T0): T0
- Definition Classes
- AnyRef
- 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])