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

Package-level declarations

Types

class BatchClosedException(val coordinatorName: String) : IllegalStateException

class BatchCloseTimeoutException(val coordinatorName: String, val timeout: Duration) : IllegalStateException

class BatchCoordinator<T : Any>(val name: String, val options: BatchOptions, writer: BatchWriter<T>, keySelector: (T) -> Any = { Unit }, metrics: WowMetrics = WowMetrics.NONE) : GracefullyStoppable

Coordinates bounded, non-blocking admission and graceful shutdown for storage-independent reactive batches.

BatchItemResult

sealed interface BatchItemResult

The terminal result for one input in a storage batch.

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.

BatchOverflowException

class BatchOverflowException(val coordinatorName: String, val maxPendingItems: Int) : IllegalStateException, RecoverableException

BatchProtocolException

class BatchProtocolException(message: String) : IllegalStateException

BatchWriter

fun interface BatchWriter<T : Any>

Executes one storage batch.