Package org.elasticsearch.common.util

Class LimitedBreaker

java.lang.Object

org.elasticsearch.common.breaker.NoopCircuitBreaker

org.elasticsearch.common.util.LimitedBreaker

All Implemented Interfaces:

CircuitBreaker

public class LimitedBreaker
extends NoopCircuitBreaker

A simple CircuitBreaker that throws when incremented above its limit.

Nested Class Summary

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

CircuitBreaker.Durability, CircuitBreaker.Type

Field Summary

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

LIMIT

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

FIELDDATA, IN_FLIGHT_REQUESTS, PARENT, REQUEST

Constructor Summary

Constructors

Constructor	Description
LimitedBreaker(String name, ByteSizeValue max)

Method Summary

Modifier and Type	Method	Description
void	addEstimateBytesAndMaybeBreak(long bytes, String label)
void	addWithoutBreaking(long bytes)
long	getUsed()
static CircuitBreakerService	service(String name, ByteSizeValue max)	A CircuitBreakerService that always returns a limited breaker.
String	toString()

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

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

Methods inherited from class java.lang.Object

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

Constructor Details

LimitedBreaker

public LimitedBreaker(String name,
 ByteSizeValue max)

Method Details

service

public static CircuitBreakerService service(String name,
 ByteSizeValue max)

A CircuitBreakerService that always returns a limited breaker.

addEstimateBytesAndMaybeBreak

public void addEstimateBytesAndMaybeBreak(long bytes,
 String label)
                                   throws CircuitBreakingException

Specified by:

addEstimateBytesAndMaybeBreak in interface CircuitBreaker

Overrides:

addEstimateBytesAndMaybeBreak in class NoopCircuitBreaker

Throws:

CircuitBreakingException

addWithoutBreaking

public void addWithoutBreaking(long bytes)

Specified by:

addWithoutBreaking in interface CircuitBreaker

Overrides:

addWithoutBreaking in class NoopCircuitBreaker

getUsed

public long getUsed()

Specified by:

getUsed in interface CircuitBreaker

Overrides:

getUsed in class NoopCircuitBreaker

toString

public String toString()

Overrides:

toString in class Object