Type Members

1.  case class HighThroughput(payloadQueueSize: Int = 1000, payloadWriteBatchMaxSize: Int = 50, payloadWriteBatchMaxDuration: NonNegativeFiniteDuration = NonNegativeFiniteDuration.ofMillis(50), payloadWriteMaxConcurrency: Int = 4, payloadToEventMargin: NonNegativeFiniteDuration = DefaultPayloadTimestampMargin, eventWriteBatchMaxSize: Int = 100, eventWriteBatchMaxDuration: NonNegativeFiniteDuration = NonNegativeFiniteDuration.ofMillis(50), commitModeValidation: Option[CommitMode] = CommitMode.Default.some, maxSqlInListSize: PositiveNumeric[Int] = DefaultMaxSqlInListSize) extends SequencerWriterConfig with Product with Serializable

   Creates batches of incoming events to minimize the number of writes to the database.

   Creates batches of incoming events to minimize the number of writes to the database. Useful for a high throughput usecase when batches will be quickly filled and written. Will be detrimental for latency if used and a lower throughput of events causes writes to always be delayed to the batch max duration.

2.  case class LowLatency(payloadQueueSize: Int = 1000, payloadWriteBatchMaxSize: Int = 1, payloadWriteBatchMaxDuration: NonNegativeFiniteDuration = NonNegativeFiniteDuration.ofMillis(10), payloadWriteMaxConcurrency: Int = 2, payloadToEventMargin: NonNegativeFiniteDuration = DefaultPayloadTimestampMargin, eventWriteBatchMaxSize: Int = 1, eventWriteBatchMaxDuration: NonNegativeFiniteDuration = NonNegativeFiniteDuration.ofMillis(20), commitModeValidation: Option[CommitMode] = CommitMode.Default.some, maxSqlInListSize: PositiveNumeric[Int] = DefaultMaxSqlInListSize) extends SequencerWriterConfig with Product with Serializable

   Use to have events immediately flushed to the database.

   Use to have events immediately flushed to the database. Useful for decreasing latency however at a high throughput a large number of writes will be detrimental for performance.