wow-core/me.ahoo.wow.infra.batch/BatchOptions

BatchOptions

data class BatchOptions(val maxSize: Int, val maxDelay: Duration, val maxPendingItems: Int)

Storage-independent limits for BatchCoordinator and KeyedBatchCoordinator.

Enabling batching is deliberately not part of this type. The component that owns a coordinator decides whether to compose a direct or batched writer.

Constructors

constructor(maxSize: Int, maxDelay: Duration, maxPendingItems: Int)

Properties

val maxDelay: Duration

maxPendingItems

val maxPendingItems: Int

Bounds both live submissions and physical queue slots.

val maxSize: Int