AppendQueueOptions

class AppendQueueOptions @InternalWowApi constructor(val maxBatch: Int = DEFAULT_MAX_BATCH, val mergers: Int = DEFAULT_MERGERS, val mergeMax: Int = DEFAULT_MERGE_MAX)

How a PartitionAppendQueue groups appends: the most appends one partition's EventLog.appendAll takes (maxBatch). The queue is always on, for every backend (measured 2026-10-23): a group is one statement on PostgreSQL and one insertMany per collection on MongoDB, which carry more under load than single appends and cost a few per cent at low concurrency. These are the backends' constants, not settings.

A log that takes several partitions at once (EventLog.appendsAcrossPartitions) gets the partitions' groups merged: mergers committers, each taking what the partitions handed it meanwhile, at most mergeMax streams, into one call; a log that does not take them is called per partition.

Fields may be added: Wow builds it from the host's configuration, so the constructor is internal to Wow.

Constructors

Link copied to clipboard
constructor(maxBatch: Int = DEFAULT_MAX_BATCH, mergers: Int = DEFAULT_MERGERS, mergeMax: Int = DEFAULT_MERGE_MAX)

Types

Link copied to clipboard
object Companion

Properties

Link copied to clipboard
Link copied to clipboard
Link copied to clipboard

Functions

Link copied to clipboard
open operator override fun equals(other: Any?): Boolean
Link copied to clipboard
open override fun hashCode(): Int
Link copied to clipboard
open override fun toString(): String