Package | Description |
---|---|
io.vertx.circuitbreaker | |
io.vertx.reactivex.circuitbreaker | |
io.vertx.rxjava.circuitbreaker | |
io.vertx.rxjava3.circuitbreaker |
Modifier and Type | Method and Description |
---|---|
CircuitBreaker |
CircuitBreaker.close()
Closes the circuit breaker.
|
CircuitBreaker |
CircuitBreaker.closeHandler(Handler<Void> handler)
Sets a
Handler 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(Promise, Handler, Function) 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.
|
default <T> CircuitBreaker |
CircuitBreaker.failurePolicy(FailurePolicy<T> failurePolicy)
Configures the failure policy for this circuit-breaker.
|
<T> CircuitBreaker |
CircuitBreaker.fallback(java.util.function.Function<Throwable,T> handler)
Sets a default
Function invoked when the bridge is open to handle the "request", or on failure
if CircuitBreakerOptions.isFallbackOnFailure() is enabled. |
CircuitBreaker |
CircuitBreaker.halfOpenHandler(Handler<Void> handler)
Sets a
Handler invoked when the circuit breaker state switches to half-open. |
CircuitBreaker |
CircuitBreaker.open()
Explicitly opens the circuit.
|
CircuitBreaker |
CircuitBreaker.openHandler(Handler<Void> handler)
Sets a
Handler 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.
use
retryPolicy(RetryPolicy) instead |
CircuitBreaker |
CircuitBreaker.retryPolicy(RetryPolicy retryPolicy)
Set a
RetryPolicy which computes a delay before retry execution. |
Modifier and Type | Method and Description |
---|---|
CircuitBreaker |
CircuitBreaker.getDelegate() |
Modifier and Type | Method and Description |
---|---|
static CircuitBreaker |
CircuitBreaker.newInstance(CircuitBreaker arg) |
Constructor and Description |
---|
CircuitBreaker(CircuitBreaker delegate) |
Modifier and Type | Method and Description |
---|---|
CircuitBreaker |
CircuitBreaker.getDelegate() |
Modifier and Type | Method and Description |
---|---|
static CircuitBreaker |
CircuitBreaker.newInstance(CircuitBreaker arg) |
Constructor and Description |
---|
CircuitBreaker(CircuitBreaker delegate) |
Modifier and Type | Method and Description |
---|---|
CircuitBreaker |
CircuitBreaker.getDelegate() |
Modifier and Type | Method and Description |
---|---|
static CircuitBreaker |
CircuitBreaker.newInstance(CircuitBreaker arg) |
Constructor and Description |
---|
CircuitBreaker(CircuitBreaker delegate) |
Copyright © 2024 Eclipse. All rights reserved.