Package com.lucimber.dbus.util

Class ErrorRecoveryManager.CircuitBreaker

java.lang.Object

com.lucimber.dbus.util.ErrorRecoveryManager.CircuitBreaker

Enclosing class:

ErrorRecoveryManager

public static class ErrorRecoveryManager.CircuitBreaker
extends Object

Circuit breaker implementation for preventing cascading failures.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static enum	ErrorRecoveryManager.CircuitBreaker.State

Method Summary

Modifier and Type	Method	Description
<T> CompletableFuture<T>	execute(Supplier<CompletableFuture<T>> operation)	Executes an operation through the circuit breaker.
int	getFailureCount()	Gets the current failure count.
ErrorRecoveryManager.CircuitBreaker.State	getState()	Gets the current state of the circuit breaker.
void	reset()	Resets the circuit breaker to CLOSED state.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Method Details

execute

public <T> CompletableFuture<T> execute(Supplier<CompletableFuture<T>> operation)

Executes an operation through the circuit breaker.

Type Parameters:

T - the result type

Parameters:

operation - the operation to execute

Returns:

CompletableFuture that completes with the operation result

getState

public ErrorRecoveryManager.CircuitBreaker.State getState()

Gets the current state of the circuit breaker.

getFailureCount

public int getFailureCount()

Gets the current failure count.

reset

public void reset()

Resets the circuit breaker to CLOSED state.