public class CircuitBreakerManager extends Object implements PluginInfoInitialized
Constructor and Description |
---|
CircuitBreakerManager(boolean enableCircuitBreakerManager) |
Modifier and Type | Method and Description |
---|---|
static CircuitBreakerManager |
build(PluginInfo pluginInfo)
Register default circuit breakers and return a constructed CircuitBreakerManager
instance which serves the given circuit breakers.
|
static CircuitBreaker.CircuitBreakerConfig |
buildCBConfig(PluginInfo pluginInfo) |
boolean |
checkAnyTripped()
Returns true if *any* circuit breaker has triggered, false if none have triggered.
|
List<CircuitBreaker> |
checkTripped()
Check and return circuit breakers that have triggered
|
void |
deregisterAll() |
List<CircuitBreaker> |
getRegisteredCircuitBreakers() |
void |
init(PluginInfo pluginInfo) |
boolean |
isEnabled() |
void |
register(CircuitBreaker circuitBreaker) |
static String |
toErrorMessage(List<CircuitBreaker> circuitBreakerList)
Construct the final error message to be printed when circuit breakers trip.
|
public CircuitBreakerManager(boolean enableCircuitBreakerManager)
public void init(PluginInfo pluginInfo)
init
in interface PluginInfoInitialized
public void register(CircuitBreaker circuitBreaker)
public void deregisterAll()
public List<CircuitBreaker> checkTripped()
public boolean checkAnyTripped()
NOTE: This method short circuits the checking of circuit breakers -- the method will return as soon as it finds a circuit breaker that is enabled and has triggered.
public static String toErrorMessage(List<CircuitBreaker> circuitBreakerList)
circuitBreakerList
- Input list for circuit breakers.public static CircuitBreakerManager build(PluginInfo pluginInfo)
public static CircuitBreaker.CircuitBreakerConfig buildCBConfig(PluginInfo pluginInfo)
public boolean isEnabled()
public List<CircuitBreaker> getRegisteredCircuitBreakers()
Copyright © 2000-2021 Apache Software Foundation. All Rights Reserved.