| Package | Description | 
|---|---|
| io.vertx.rxjava.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.rxjava.core.Promise<T>, io.vertx.core.Handler<io.vertx.rxjava.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)  | 
Copyright © 2020 Eclipse. All rights reserved.