Class CircuitBreakerNoopTelemetry$
java.lang.Object
org.apache.pekko.pattern.internal.CircuitBreakerNoopTelemetry$
- All Implemented Interfaces:
CircuitBreakerTelemetry
INTERNAL API
-
Field Summary
FieldsModifier and TypeFieldDescriptionstatic final CircuitBreakerNoopTelemetry$Static reference to the singleton instance of this Scala object. -
Constructor Summary
Constructors -
Method Summary
Modifier and TypeMethodDescriptionvoidInvoked for each call when the future is completed withorg.apache.pekko.pattern.CircuitBreakerOpenExceptionvoidonCallFailure(long elapsedNanos) Invoked for each call when the future is completed with exception, except forscala.concurrent.TimeoutExceptionandpekko.pattern.CircuitBreakerOpenExceptionthat are handled by separate methods.voidonCallSuccess(long elapsedNanos) Invoked for each successful call.voidonCallTimeoutFailure(long elapsedNanos) Invoked for each call when the future is completed withjava.util.concurrent.TimeoutExceptionvoidonClose()Invoked when the circuit breaker transitions to the close state.voidInvoked when the circuit breaker transitions to the half-open state after reset timeout.voidonOpen()Invoked when the circuit breaker transitions to the open state.voidstopped()Called when the circuit breaker is removed, e.g.
-
Field Details
-
MODULE$
Static reference to the singleton instance of this Scala object.
-
-
Constructor Details
-
CircuitBreakerNoopTelemetry$
public CircuitBreakerNoopTelemetry$()
-
-
Method Details
-
onOpen
public void onOpen()Description copied from interface:CircuitBreakerTelemetryInvoked when the circuit breaker transitions to the open state.- Specified by:
onOpenin interfaceCircuitBreakerTelemetry
-
onClose
public void onClose()Description copied from interface:CircuitBreakerTelemetryInvoked when the circuit breaker transitions to the close state.- Specified by:
onClosein interfaceCircuitBreakerTelemetry
-
onHalfOpen
public void onHalfOpen()Description copied from interface:CircuitBreakerTelemetryInvoked when the circuit breaker transitions to the half-open state after reset timeout.- Specified by:
onHalfOpenin interfaceCircuitBreakerTelemetry
-
onCallSuccess
public void onCallSuccess(long elapsedNanos) Description copied from interface:CircuitBreakerTelemetryInvoked for each successful call.- Specified by:
onCallSuccessin interfaceCircuitBreakerTelemetry- Parameters:
elapsedNanos- the elapsed duration of the call in nanoseconds
-
onCallFailure
public void onCallFailure(long elapsedNanos) Description copied from interface:CircuitBreakerTelemetryInvoked for each call when the future is completed with exception, except forscala.concurrent.TimeoutExceptionandpekko.pattern.CircuitBreakerOpenExceptionthat are handled by separate methods.- Specified by:
onCallFailurein interfaceCircuitBreakerTelemetry- Parameters:
elapsedNanos- the elapsed duration of the call in nanoseconds
-
onCallTimeoutFailure
public void onCallTimeoutFailure(long elapsedNanos) Description copied from interface:CircuitBreakerTelemetryInvoked for each call when the future is completed withjava.util.concurrent.TimeoutException- Specified by:
onCallTimeoutFailurein interfaceCircuitBreakerTelemetry- Parameters:
elapsedNanos- the elapsed duration of the call in nanoseconds
-
onCallBreakerOpenFailure
public void onCallBreakerOpenFailure()Description copied from interface:CircuitBreakerTelemetryInvoked for each call when the future is completed withorg.apache.pekko.pattern.CircuitBreakerOpenException- Specified by:
onCallBreakerOpenFailurein interfaceCircuitBreakerTelemetry
-
stopped
public void stopped()Description copied from interface:CircuitBreakerTelemetryCalled when the circuit breaker is removed, e.g. expired due to inactivity. It is also called if the circuit breaker is re-configured, before callingCircuitBreakerTelemetryProvider.start(java.lang.String, org.apache.pekko.actor.ExtendedActorSystem).- Specified by:
stoppedin interfaceCircuitBreakerTelemetry
-