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

Package-level declarations

Types

BatchClosedException

class BatchClosedException(val coordinatorName: String) : IllegalStateException

BatchCloseTimeoutException

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

BatchCoordinator

class BatchCoordinator<T : Any> : 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.

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

Storage-independent limits for BatchCoordinator and KeyedBatchCoordinator.

BatchOverflowException

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

BatchProtocolException

class BatchProtocolException(message: String) : IllegalStateException

fun interface BatchWriter<T : Any>

Executes one storage batch.

KeyedBatchCoordinator

class KeyedBatchCoordinator<T : Any, K : Any>(val name: String, val options: BatchOptions, val laneCount: Int, keySelector: (T) -> K, writer: BatchWriter<T>) : GracefullyStoppable

Partitions submissions into a fixed number of serial batch lanes.