com.digitalasset.canton.synchronizer.sequencer
SequencerReaderConfig
Companion object SequencerReaderConfig
final case class SequencerReaderConfig(readBatchSize: Int = SequencerReaderConfig.defaultReadBatchSize, checkpointInterval: NonNegativeFiniteDuration = SequencerReaderConfig.defaultCheckpointInterval, pollingInterval: Option[NonNegativeFiniteDuration] = None, payloadBatchSize: Int = SequencerReaderConfig.defaultPayloadBatchSize, payloadBatchWindow: NonNegativeFiniteDuration = SequencerReaderConfig.defaultPayloadBatchWindow, payloadFetchParallelism: Int = SequencerReaderConfig.defaultPayloadFetchParallelism, eventGenerationParallelism: Int = SequencerReaderConfig.defaultEventGenerationParallelism) extends CustomCantonConfigValidation with Product with Serializable
Configuration for the database based sequence reader.
- readBatchSize
max number of events to fetch from the datastore in one page
- checkpointInterval
how frequently to checkpoint state
- pollingInterval
how frequently to poll for new events from the database. only used in the enterprise edition if high availability has been configured, otherwise will rely on local writes performed by this sequencer to indicate that new events are available.
- payloadBatchSize
max number of payloads to fetch from the datastore in one page
- payloadBatchWindow
max time window to wait for more payloads before fetching the current batch from the datastore
- payloadFetchParallelism
how many batches of payloads will be fetched in parallel
- eventGenerationParallelism
how many events will be generated from the fetched payloads in parallel
- Alphabetic
- By Inheritance
- SequencerReaderConfig
- Serializable
- Product
- Equals
- CustomCantonConfigValidation
- CantonConfigValidation
- AnyRef
- Any
- Hide All
- Show All
- Public
- Protected
Instance Constructors
- new SequencerReaderConfig(readBatchSize: Int = SequencerReaderConfig.defaultReadBatchSize, checkpointInterval: NonNegativeFiniteDuration = SequencerReaderConfig.defaultCheckpointInterval, pollingInterval: Option[NonNegativeFiniteDuration] = None, payloadBatchSize: Int = SequencerReaderConfig.defaultPayloadBatchSize, payloadBatchWindow: NonNegativeFiniteDuration = SequencerReaderConfig.defaultPayloadBatchWindow, payloadFetchParallelism: Int = SequencerReaderConfig.defaultPayloadFetchParallelism, eventGenerationParallelism: Int = SequencerReaderConfig.defaultEventGenerationParallelism)
- readBatchSize
max number of events to fetch from the datastore in one page
- checkpointInterval
how frequently to checkpoint state
- pollingInterval
how frequently to poll for new events from the database. only used in the enterprise edition if high availability has been configured, otherwise will rely on local writes performed by this sequencer to indicate that new events are available.
- payloadBatchSize
max number of payloads to fetch from the datastore in one page
- payloadBatchWindow
max time window to wait for more payloads before fetching the current batch from the datastore
- payloadFetchParallelism
how many batches of payloads will be fetched in parallel
- eventGenerationParallelism
how many events will be generated from the fetched payloads in parallel
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
- def clone(): AnyRef
- Attributes
- protected[lang]
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.CloneNotSupportedException]) @IntrinsicCandidate() @native()
- def doValidate(edition: CantonEdition): Seq[CantonConfigValidationError]
Returns all validation errors that are specific to this Canton configuration class.
Returns all validation errors that are specific to this Canton configuration class. Successful validation should return an empty sequence.
Validation errors of subconfigurations should not be reported by this method, but via the type class derivation.
- Attributes
- protected
- Definition Classes
- SequencerReaderConfig → CustomCantonConfigValidation
- final def eq(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
- val eventGenerationParallelism: Int
- final def getClass(): Class[_ <: AnyRef]
- 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()
- val payloadBatchSize: Int
- val payloadBatchWindow: NonNegativeFiniteDuration
- val payloadFetchParallelism: Int
- val pollingInterval: Option[NonNegativeFiniteDuration]
- def productElementNames: Iterator[String]
- Definition Classes
- Product
- val readBatchSize: Int
- final def synchronized[T0](arg0: => T0): T0
- Definition Classes
- AnyRef
- final def validate[T >: SequencerReaderConfig.this.type](edition: CantonEdition)(implicit validator: CantonConfigValidator[T]): Either[NonEmpty[Seq[CantonConfigValidationError]], Unit]
- Definition Classes
- CantonConfigValidation
- 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])