trait CircuitBreakerTelemetry extends AnyRef
Service Provider Interface (SPI) for collecting metrics from Circuit Breaker.
Implementations must include a single constructor with two arguments: Circuit Breaker id
and ExtendedActorSystem. To setup your implementation, add a setting in your application.conf
:
akka.circuit-breaker.telemetry.implementations += com.example.MyMetrics
- Annotations
- @InternalStableApi()
- Alphabetic
- By Inheritance
- CircuitBreakerTelemetry
- AnyRef
- Any
- Hide All
- Show All
- Public
- Protected
Abstract Value Members
- abstract def onCallBreakerOpenFailure(): Unit
Invoked for each call when the future is completed with
akka.pattern.CircuitBreakerOpenException
- abstract def onCallFailure(elapsedNanos: Long): Unit
Invoked for each call when the future is completed with exception, except for scala.concurrent.TimeoutException and akka.pattern.CircuitBreakerOpenException that are handled by separate methods.
Invoked for each call when the future is completed with exception, except for scala.concurrent.TimeoutException and akka.pattern.CircuitBreakerOpenException that are handled by separate methods.
- elapsedNanos
the elapsed duration of the call in nanoseconds
- abstract def onCallSuccess(elapsedNanos: Long): Unit
Invoked for each successful call.
Invoked for each successful call.
- elapsedNanos
the elapsed duration of the call in nanoseconds
- abstract def onCallTimeoutFailure(elapsedNanos: Long): Unit
Invoked for each call when the future is completed with
java.util.concurrent.TimeoutException
Invoked for each call when the future is completed with
java.util.concurrent.TimeoutException
- elapsedNanos
the elapsed duration of the call in nanoseconds
- abstract def onClose(): Unit
Invoked when the circuit breaker transitions to the close state.
- abstract def onHalfOpen(): Unit
Invoked when the circuit breaker transitions to the half-open state after reset timeout.
- abstract def onOpen(): Unit
Invoked when the circuit breaker transitions to the open state.
- abstract def stopped(): Unit
Called when the circuit breaker is removed, e.g.
Called when the circuit breaker is removed, e.g. expired due to inactivity. It is also called if the circuit breaker is re-configured, before calling CircuitBreakerTelemetryProvider#start.
Concrete Value Members
- final def !=(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
- final def ##: Int
- Definition Classes
- AnyRef → Any
- final def ==(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
- final def asInstanceOf[T0]: T0
- Definition Classes
- Any
- def clone(): AnyRef
- Attributes
- protected[lang]
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.CloneNotSupportedException]) @IntrinsicCandidate() @native()
- final def eq(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
- def equals(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef → Any
- final def getClass(): Class[_ <: AnyRef]
- Definition Classes
- AnyRef → Any
- Annotations
- @IntrinsicCandidate() @native()
- def hashCode(): Int
- Definition Classes
- AnyRef → Any
- Annotations
- @IntrinsicCandidate() @native()
- final def isInstanceOf[T0]: Boolean
- Definition Classes
- Any
- final def ne(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
- final def notify(): Unit
- Definition Classes
- AnyRef
- Annotations
- @IntrinsicCandidate() @native()
- final def notifyAll(): Unit
- Definition Classes
- AnyRef
- Annotations
- @IntrinsicCandidate() @native()
- final def synchronized[T0](arg0: => T0): T0
- Definition Classes
- AnyRef
- def toString(): String
- Definition Classes
- AnyRef → Any
- final def wait(arg0: Long, arg1: Int): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.InterruptedException])
- final def wait(arg0: Long): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.InterruptedException])
- final def wait(): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.InterruptedException])
Deprecated Value Members
- def finalize(): Unit
- Attributes
- protected[lang]
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.Throwable]) @Deprecated
- Deprecated
(Since version 9)