Class TestCircuitBreaker

java.lang.Object
org.opensearch.common.breaker.NoopCircuitBreaker
org.opensearch.common.breaker.TestCircuitBreaker
All Implemented Interfaces:
org.opensearch.common.breaker.CircuitBreaker

public class TestCircuitBreaker
extends org.opensearch.common.breaker.NoopCircuitBreaker
  • Nested Class Summary

    Nested classes/interfaces inherited from interface org.opensearch.common.breaker.CircuitBreaker

    org.opensearch.common.breaker.CircuitBreaker.Durability, org.opensearch.common.breaker.CircuitBreaker.Type
  • Field Summary

    Fields inherited from class org.opensearch.common.breaker.NoopCircuitBreaker

    LIMIT

    Fields inherited from interface org.opensearch.common.breaker.CircuitBreaker

    ACCOUNTING, FIELDDATA, IN_FLIGHT_REQUESTS, PARENT, REQUEST
  • Constructor Summary

    Constructors 
    Constructor Description
    TestCircuitBreaker()  
  • Method Summary

    Modifier and Type Method Description
    double addEstimateBytesAndMaybeBreak​(long bytes, java.lang.String label)  
    void startBreaking()  
    void stopBreaking()  

    Methods inherited from class org.opensearch.common.breaker.NoopCircuitBreaker

    addWithoutBreaking, circuitBreak, getDurability, getLimit, getName, getOverhead, getTrippedCount, getUsed, setLimitAndOverhead

    Methods inherited from class java.lang.Object

    clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
  • Constructor Details

  • Method Details

    • addEstimateBytesAndMaybeBreak

      public double addEstimateBytesAndMaybeBreak​(long bytes, java.lang.String label) throws org.opensearch.common.breaker.CircuitBreakingException
      Specified by:
      addEstimateBytesAndMaybeBreak in interface org.opensearch.common.breaker.CircuitBreaker
      Overrides:
      addEstimateBytesAndMaybeBreak in class org.opensearch.common.breaker.NoopCircuitBreaker
      Throws:
      org.opensearch.common.breaker.CircuitBreakingException
    • startBreaking

      public void startBreaking()
    • stopBreaking

      public void stopBreaking()