Package org.apache.pekko.pattern.internal

Class CircuitBreakerNoopTelemetry$

java.lang.Object
org.apache.pekko.pattern.internal.CircuitBreakerNoopTelemetry$
All Implemented Interfaces:
CircuitBreakerTelemetry
public class CircuitBreakerNoopTelemetry$ extends Object implements CircuitBreakerTelemetry
INTERNAL API

  • Field Summary

    Fields
    Modifier and Type
    Field
    Description
    static final CircuitBreakerNoopTelemetry$
    MODULE$
    Static reference to the singleton instance of this Scala object.

  • Constructor Summary

    Constructors
    Constructor
    Description
    CircuitBreakerNoopTelemetry$()
     

  • Method Summary

    Modifier and Type
    Method
    Description
    void
    onCallBreakerOpenFailure()
    Invoked for each call when the future is completed with org.apache.pekko.pattern.CircuitBreakerOpenException
    void
    onCallFailure(long elapsedNanos)
    Invoked for each call when the future is completed with exception, except for scala.concurrent.TimeoutException and pekko.pattern.CircuitBreakerOpenException that are handled by separate methods.
    void
    onCallSuccess(long elapsedNanos)
    Invoked for each successful call.
    void
    onCallTimeoutFailure(long elapsedNanos)
    Invoked for each call when the future is completed with java.util.concurrent.TimeoutException
    void
    onClose()
    Invoked when the circuit breaker transitions to the close state.
    void
    onHalfOpen()
    Invoked when the circuit breaker transitions to the half-open state after reset timeout.
    void
    onOpen()
    Invoked when the circuit breaker transitions to the open state.
    void
    stopped()
    Called when the circuit breaker is removed, e.g.

    Methods inherited from class java.lang.Object

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

  • Field Details

  • Constructor Details

    • CircuitBreakerNoopTelemetry$

      public CircuitBreakerNoopTelemetry$()

  • Method Details

    • onOpen

      public void onOpen()
      Description copied from interface: CircuitBreakerTelemetry
      Invoked when the circuit breaker transitions to the open state.
      Specified by:
      onOpen in interface CircuitBreakerTelemetry

    • onClose

      public void onClose()
      Description copied from interface: CircuitBreakerTelemetry
      Invoked when the circuit breaker transitions to the close state.
      Specified by:
      onClose in interface CircuitBreakerTelemetry

    • onHalfOpen

      public void onHalfOpen()
      Description copied from interface: CircuitBreakerTelemetry
      Invoked when the circuit breaker transitions to the half-open state after reset timeout.
      Specified by:
      onHalfOpen in interface CircuitBreakerTelemetry

    • onCallSuccess

      public void onCallSuccess(long elapsedNanos)
      Description copied from interface: CircuitBreakerTelemetry
      Invoked for each successful call.

      Specified by:
      onCallSuccess in interface CircuitBreakerTelemetry
      Parameters:
      elapsedNanos - the elapsed duration of the call in nanoseconds

    • onCallFailure

      public void onCallFailure(long elapsedNanos)
      Description copied from interface: CircuitBreakerTelemetry
      Invoked for each call when the future is completed with exception, except for scala.concurrent.TimeoutException and pekko.pattern.CircuitBreakerOpenException that are handled by separate methods.

      Specified by:
      onCallFailure in interface CircuitBreakerTelemetry
      Parameters:
      elapsedNanos - the elapsed duration of the call in nanoseconds

    • onCallTimeoutFailure

      public void onCallTimeoutFailure(long elapsedNanos)
      Description copied from interface: CircuitBreakerTelemetry
      Invoked for each call when the future is completed with java.util.concurrent.TimeoutException

      Specified by:
      onCallTimeoutFailure in interface CircuitBreakerTelemetry
      Parameters:
      elapsedNanos - the elapsed duration of the call in nanoseconds

    • onCallBreakerOpenFailure

      public void onCallBreakerOpenFailure()
      Description copied from interface: CircuitBreakerTelemetry
      Invoked for each call when the future is completed with org.apache.pekko.pattern.CircuitBreakerOpenException
      Specified by:
      onCallBreakerOpenFailure in interface CircuitBreakerTelemetry

    • stopped

      public void stopped()
      Description copied from interface: CircuitBreakerTelemetry
      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.
      Specified by:
      stopped in interface CircuitBreakerTelemetry