BatchOptions

data class BatchOptions(val maxSize: Int = DEFAULT_MAX_SIZE, val maxDelay: Duration = DEFAULT_MAX_DELAY, val maxPendingItems: Int = DEFAULT_MAX_PENDING_ITEMS, val laneCount: Int = DEFAULT_LANE_COUNT)

Storage-independent limits for BatchCoordinator.

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

Link copied to clipboard
constructor(maxSize: Int = DEFAULT_MAX_SIZE, maxDelay: Duration = DEFAULT_MAX_DELAY, maxPendingItems: Int = DEFAULT_MAX_PENDING_ITEMS, laneCount: Int = DEFAULT_LANE_COUNT)

Types

Link copied to clipboard
object Companion

Properties

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

Bounds both live submissions and physical queue slots.

Link copied to clipboard