Class CircuitBreaker

java.lang.Object

org.episteme.server.server.resilience.CircuitBreaker

public class CircuitBreaker
extends Object

Circuit Breaker implementation for fault tolerance. States: - CLOSED: Normal operation, requests flow through - OPEN: Failures exceeded threshold, requests fail fast - HALF_OPEN: Testing if service recovered Thread-safe implementation using atomic primitives.

Since:

1.0

Author:

Silvere Martin-Michiellot, Gemini AI (Google DeepMind)

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	CircuitBreaker.CircuitBreakerOpenException	Exception thrown when circuit breaker is open.
static enum	CircuitBreaker.State

Constructor Summary

Constructors

Constructor	Description
CircuitBreaker(String name)	Create a circuit breaker with default settings. - 5 failures to open - 3 successes to close - 30 seconds open duration
CircuitBreaker(String name, int failureThreshold, int successThreshold, Duration openDuration)	Create a circuit breaker with custom settings.

Method Summary

Modifier and Type	Method	Description
boolean	allowRequest()	Check if a request should be allowed through.
void	execute(Runnable action)	Execute a runnable with circuit breaker protection.
<T> T	execute(Supplier<T> action)	Execute a supplier with circuit breaker protection.
int	getFailureCount()
String	getName()
CircuitBreaker.State	getState()
int	getSuccessCount()
void	recordFailure()	Record a failed call.
void	recordSuccess()	Record a successful call.
void	reset()	Force the circuit breaker to reset to CLOSED state.

Methods inherited from class Object

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

Constructor Details

CircuitBreaker

public CircuitBreaker(String name)

Create a circuit breaker with default settings. - 5 failures to open - 3 successes to close - 30 seconds open duration

CircuitBreaker

public CircuitBreaker(String name,
 int failureThreshold,
 int successThreshold,
 Duration openDuration)

Create a circuit breaker with custom settings.

Method Details

execute

public <T> T execute(Supplier<T> action)
              throws CircuitBreaker.CircuitBreakerOpenException

Execute a supplier with circuit breaker protection.

Throws:

CircuitBreaker.CircuitBreakerOpenException

execute

public void execute(Runnable action)
             throws CircuitBreaker.CircuitBreakerOpenException

Execute a runnable with circuit breaker protection.

Throws:

CircuitBreaker.CircuitBreakerOpenException

allowRequest

public boolean allowRequest()

Check if a request should be allowed through.

recordSuccess

public void recordSuccess()

Record a successful call.

recordFailure

public void recordFailure()

Record a failed call.

reset

public void reset()

Force the circuit breaker to reset to CLOSED state.

getName

public String getName()

getState

public CircuitBreaker.State getState()

getFailureCount

public int getFailureCount()

getSuccessCount

public int getSuccessCount()