Class CircuitBreakerStateMachine.HalfOpenState

java.lang.Object

io.github.resilience4j.circuitbreaker.internal.CircuitBreakerStateMachine.HalfOpenState

All Implemented Interfaces:

CircuitBreakerStateMachine.CircuitBreakerState

Enclosing class:

CircuitBreakerStateMachine

private class CircuitBreakerStateMachine.HalfOpenState
extends Object
implements CircuitBreakerStateMachine.CircuitBreakerState

Field Summary

Fields

Modifier and Type	Field	Description
private final int	attempts
private final CircuitBreakerMetrics	circuitBreakerMetrics
private final AtomicBoolean	isHalfOpen
private final AtomicInteger	permittedNumberOfCalls
private final ScheduledFuture<?>	transitionToOpenFuture

Constructor Summary

Constructors

Constructor	Description
HalfOpenState(int attempts)

Method Summary

Modifier and Type	Method	Description
void	acquirePermission()
int	attempts()
private void	cancelAutomaticTransitionToOpen()
private void	checkIfThresholdsExceeded(CircuitBreakerMetrics.Result result)	Transitions to open state when thresholds have been exceeded.
CircuitBreakerMetrics	getMetrics()
CircuitBreaker.State	getState()	Get the state of the CircuitBreaker
void	handlePossibleTransition(CircuitBreakerConfig.TransitionCheckResult result)
void	onError(long duration, TimeUnit durationUnit, Throwable throwable)
void	onSuccess(long duration, TimeUnit durationUnit)
void	preTransitionHook()	This method is invoked before transit to other CircuitBreakerState.
void	releasePermission()
private void	toOpenState()
boolean	tryAcquirePermission()	Checks if test request is allowed.

Methods inherited from class Object

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

Methods inherited from interface CircuitBreakerStateMachine.CircuitBreakerState

shouldPublishEvents

Field Details

permittedNumberOfCalls

private final AtomicInteger permittedNumberOfCalls

isHalfOpen

private final AtomicBoolean isHalfOpen

attempts

private final int attempts

circuitBreakerMetrics

private final CircuitBreakerMetrics circuitBreakerMetrics

transitionToOpenFuture

@Nullable
private final ScheduledFuture<?> transitionToOpenFuture

Constructor Details

HalfOpenState

HalfOpenState(int attempts)

Method Details

tryAcquirePermission

public boolean tryAcquirePermission()

Checks if test request is allowed.

Returns true, if test request counter is not zero. Returns false, if test request counter is zero.

Specified by:

tryAcquirePermission in interface CircuitBreakerStateMachine.CircuitBreakerState

Returns:

true, if test request counter is not zero.

acquirePermission

public void acquirePermission()

Specified by:

acquirePermission in interface CircuitBreakerStateMachine.CircuitBreakerState

preTransitionHook

public void preTransitionHook()

Description copied from interface: CircuitBreakerStateMachine.CircuitBreakerState

This method is invoked before transit to other CircuitBreakerState.

Specified by:

preTransitionHook in interface CircuitBreakerStateMachine.CircuitBreakerState

cancelAutomaticTransitionToOpen

private void cancelAutomaticTransitionToOpen()

toOpenState

private void toOpenState()

releasePermission

public void releasePermission()

Specified by:

releasePermission in interface CircuitBreakerStateMachine.CircuitBreakerState

onError

public void onError(long duration,
 TimeUnit durationUnit,
 Throwable throwable)

Specified by:

onError in interface CircuitBreakerStateMachine.CircuitBreakerState

onSuccess

public void onSuccess(long duration,
 TimeUnit durationUnit)

Specified by:

onSuccess in interface CircuitBreakerStateMachine.CircuitBreakerState

handlePossibleTransition

public void handlePossibleTransition(CircuitBreakerConfig.TransitionCheckResult result)

Specified by:

handlePossibleTransition in interface CircuitBreakerStateMachine.CircuitBreakerState

attempts

public int attempts()

Specified by:

attempts in interface CircuitBreakerStateMachine.CircuitBreakerState

checkIfThresholdsExceeded

private void checkIfThresholdsExceeded(CircuitBreakerMetrics.Result result)

Transitions to open state when thresholds have been exceeded. Transitions to closed state when thresholds have not been exceeded.

Parameters:

result - the result

getState

public CircuitBreaker.State getState()

Get the state of the CircuitBreaker

Specified by:

getState in interface CircuitBreakerStateMachine.CircuitBreakerState

getMetrics

public CircuitBreakerMetrics getMetrics()

Specified by:

getMetrics in interface CircuitBreakerStateMachine.CircuitBreakerState