shared/com.santimattius.resilient.bulkhead

Package-level declarations

Types

Bulkhead

interface Bulkhead

A Bulkhead can be used to limit the number of concurrent executions.

BulkheadConfig

class BulkheadConfig

A configuration builder for a Bulkhead.

BulkheadFullException

class BulkheadFullException : Exception

Exception thrown when the bulkhead cannot accept a new call. This occurs when both the concurrent call limit and the waiting queue are full, or when waiting for a permit exceeds the configured BulkheadConfig.timeout.

BulkheadRegistry

class BulkheadRegistry

Registry of named DefaultBulkhead instances so multiple com.santimattius.resilient.ResilientPolicy configurations can share the same bulkhead limits (e.g. one pool per downstream "payments", "db").

BulkheadSnapshot

data class BulkheadSnapshot(val activeConcurrentCalls: Int, val waitingCalls: Int, val maxConcurrentCalls: Int, val maxWaitingCalls: Int)

Point-in-time snapshot of a Bulkhead for health/readiness and metrics.

DefaultBulkhead

class DefaultBulkhead(config: BulkheadConfig, onRejected: (reason: String) -> Unit? = null) : Bulkhead

A semaphore-based implementation of the Bulkhead pattern.