Package | Description |
---|---|
io.vertx.rxjava.circuitbreaker |
Modifier and Type | Method and Description |
---|---|
CircuitBreaker |
CircuitBreaker.close()
Closes the circuit breaker.
|
CircuitBreaker |
CircuitBreaker.closeHandler(Handler<Void> handler)
Sets a invoked when the circuit breaker state switches to close.
|
static CircuitBreaker |
CircuitBreaker.create(String name,
Vertx vertx)
Creates a new instance of
CircuitBreaker , with default options. |
static CircuitBreaker |
CircuitBreaker.create(String name,
Vertx vertx,
CircuitBreakerOptions options)
Creates a new instance of
CircuitBreaker . |
<T> CircuitBreaker |
CircuitBreaker.executeAndReport(Future<T> resultFuture,
Handler<Future<T>> operation)
Same as
executeAndReportWithFallback(io.vertx.rxjava.core.Future<T>, io.vertx.core.Handler<io.vertx.rxjava.core.Future<T>>, java.util.function.Function<java.lang.Throwable, T>) but using the circuit breaker default
fallback. |
<T> CircuitBreaker |
CircuitBreaker.executeAndReportWithFallback(Future<T> resultFuture,
Handler<Future<T>> operation,
java.util.function.Function<Throwable,T> fallback)
Executes the given operation with the circuit breaker control.
|
<T> CircuitBreaker |
CircuitBreaker.fallback(java.util.function.Function<Throwable,T> handler)
Sets a default invoked when the bridge is open to handle the "request", or on failure
if
CircuitBreakerOptions is enabled. |
CircuitBreaker |
CircuitBreaker.halfOpenHandler(Handler<Void> handler)
Sets a invoked when the circuit breaker state switches to half-open.
|
static CircuitBreaker |
CircuitBreaker.newInstance(CircuitBreaker arg) |
CircuitBreaker |
CircuitBreaker.open()
Explicitly opens the circuit.
|
CircuitBreaker |
CircuitBreaker.openHandler(Handler<Void> handler)
Sets a invoked when the circuit breaker state switches to open.
|
CircuitBreaker |
CircuitBreaker.reset()
Resets the circuit breaker state (number of failure set to 0 and state set to closed).
|
Copyright © 2016. All rights reserved.