Package | Description |
---|---|
io.vertx.reactivex.circuitbreaker |
Modifier and Type | Field and Description |
---|---|
static io.vertx.lang.rx.TypeArg<CircuitBreaker> |
CircuitBreaker.__TYPE_ARG |
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(Promise<T> resultPromise,
Handler<Promise<T>> command)
Same as
executeAndReportWithFallback(io.vertx.reactivex.core.Promise<T>, io.vertx.core.Handler<io.vertx.reactivex.core.Promise<T>>, java.util.function.Function<java.lang.Throwable, T>) but using the circuit breaker default
fallback. |
<T> CircuitBreaker |
CircuitBreaker.executeAndReportWithFallback(Promise<T> resultPromise,
Handler<Promise<T>> command,
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).
|
CircuitBreaker |
CircuitBreaker.retryPolicy(java.util.function.Function<Integer,Long> retryPolicy)
Deprecated.
|
CircuitBreaker |
CircuitBreaker.retryPolicy(RetryPolicy retryPolicy)
Set a
RetryPolicy which computes a delay before retry execution. |
Copyright © 2023 Eclipse. All rights reserved.