com.digitalasset.canton.synchronizer.sequencer
DatabaseSequencerConfig
Companion trait DatabaseSequencerConfig
object DatabaseSequencerConfig
- Alphabetic
- By Inheritance
- DatabaseSequencerConfig
- AnyRef
- Any
- Hide All
- Show All
- Public
- Protected
Type Members
- final case class SequencerPruningConfig(maxPruningBatchSize: PositiveInt = PositiveInt.tryCreate(50000), pruningMetricUpdateInterval: Option[PositiveDurationSeconds] = PositiveDurationSeconds.ofHours(1L).some, trafficPurchasedRetention: NonNegativeFiniteDuration = NonNegativeFiniteDuration.ofHours(1)) extends UniformCantonConfigValidation with Product with Serializable
Configuration for database sequencer pruning
Configuration for database 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-agepruning progress metric in the background. A setting of None disables background metric updating.- trafficPurchasedRetention
Retention duration on how long to retain traffic purchased entry updates for each member
- type TestingInterceptor = (Clock) => (Sequencer) => (ExecutionContext) => Sequencer
The Postgres sequencer supports adding an interceptor within the sequencer itself for manipulating sequence behavior during tests.
The Postgres sequencer supports adding an interceptor within the sequencer itself for manipulating sequence behavior during tests. This is used for delaying and/or dropping messages to verify the behavior of transaction processing in abnormal scenarios in a deterministic way. It is not expected to be used at runtime in any capacity and is not possible to set through pureconfig.
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()
- 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()
- def hashCode(): Int
- Definition Classes
- AnyRef → Any
- Annotations
- @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
- @native()
- final def notifyAll(): Unit
- Definition Classes
- AnyRef
- Annotations
- @native()
- final def synchronized[T0](arg0: => T0): T0
- Definition Classes
- AnyRef
- def toString(): String
- Definition Classes
- AnyRef → Any
- final def wait(): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.InterruptedException])
- 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()
- object SequencerPruningConfig extends Serializable