kresil-lib/kresil.circuitbreaker.state.reducer/CircuitBreakerStateReducer

CircuitBreakerStateReducer

internal class CircuitBreakerStateReducer<T>(val slidingWindow: FailureRateSlidingWindow<T>, val config: CircuitBreakerConfig, val events: MutableSharedFlow<CircuitBreakerEvent>) : Reducer<CircuitBreakerState, CircuitBreakerReducerEvent, CircuitBreakerReducerEffect> (source)

A thread-safe state machine that acts as a reducer for a CircuitBreaker. Using the dispatch method, events can be dispatched to the state machine to trigger state transitions. The current state can be consulted using the currentState method.

Parameters

slidingWindow

the sliding window used to record the result (success or failure) of operations and calculate the failure rate.

config

the configuration of the circuit breaker.

events

the shared flow to emit circuit breaker events to.

Constructors

CircuitBreakerStateReducer

constructor(slidingWindow: FailureRateSlidingWindow<T>, config: CircuitBreakerConfig, events: MutableSharedFlow<CircuitBreakerEvent>)

Properties

_state

private var _state: CircuitBreakerState

config

val config: CircuitBreakerConfig

events

val events: MutableSharedFlow<CircuitBreakerEvent>

isAboveThreshold

private val isAboveThreshold: Boolean

isToWaitIndefinitelyInHalfOpenState

private val isToWaitIndefinitelyInHalfOpenState: Boolean

lock

private val lock: Mutex

slidingWindow

val slidingWindow: FailureRateSlidingWindow<T>

Functions

createHalfOpenState

private fun createHalfOpenState(state: CircuitBreakerState): CircuitBreakerState

createOpenState

private suspend fun createOpenState(state: CircuitBreakerState): CircuitBreakerState

currentState

open suspend override fun currentState(): CircuitBreakerState

Returns the current state of the reducer.

dispatch

open suspend override fun dispatch(event: CircuitBreakerReducerEvent)

Dispatches an event to the reducer to trigger a state transition.

hasExceededDurationInHalfOpenState

private fun hasExceededDurationInHalfOpenState(state: CircuitBreakerState): Boolean

hasExceededDurationInOpenState

private fun hasExceededDurationInOpenState(state: CircuitBreakerState): Boolean

recordFailure

private suspend fun recordFailure()

recordSuccess

private suspend fun recordSuccess()

reducer

protected open suspend override fun reducer(state: CircuitBreakerState, event: CircuitBreakerReducerEvent): Pair<CircuitBreakerState, List<CircuitBreakerReducerEffect>>

Given the current state and an event, reduces the event to a new state and a list of effects.

reset

private suspend fun reset(): CircuitBreakerState