| Modifier and Type | Method and Description | 
|---|---|
<T> CircuitBreaker | 
CircuitBreaker.executeAndReport(Promise<T> resultPromise,
                Handler<Promise<T>> command)
Same as  
CircuitBreaker.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. 
 | 
| Modifier and Type | Method and Description | 
|---|---|
<T> Future<T> | 
CircuitBreaker.execute(Handler<Promise<T>> command)
Same as  
CircuitBreaker.executeWithFallback(Handler, Function) but using the circuit breaker default fallback. | 
default <T> void | 
CircuitBreaker.execute(Handler<Promise<T>> command,
       Handler<AsyncResult<T>> handler)
Same as  
CircuitBreaker.executeWithFallback(Handler, Function) but using the circuit breaker default fallback. | 
default <T> CircuitBreaker | 
CircuitBreaker.executeAndReport(Future<T> resultFuture,
                Handler<Promise<T>> command)
Deprecated. 
 
 | 
<T> CircuitBreaker | 
CircuitBreaker.executeAndReport(Promise<T> resultPromise,
                Handler<Promise<T>> command)
Same as  
CircuitBreaker.executeAndReportWithFallback(Promise, Handler, Function) but using the circuit breaker default
 fallback. | 
default <T> CircuitBreaker | 
CircuitBreaker.executeAndReportWithFallback(Future<T> resultFuture,
                            Handler<Promise<T>> command,
                            java.util.function.Function<Throwable,T> fallback)
Deprecated. 
 
 | 
<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> void | 
CircuitBreaker.executeCommand(Handler<Promise<T>> command,
              Handler<AsyncResult<T>> handler)
Deprecated. 
 
instead use  
CircuitBreaker.execute(Handler, Handler) | 
default <T> void | 
CircuitBreaker.executeCommandWithFallback(Handler<Promise<T>> command,
                          java.util.function.Function<Throwable,T> fallback,
                          Handler<AsyncResult<T>> handler)
Deprecated. 
 
 | 
<T> Future<T> | 
CircuitBreaker.executeWithFallback(Handler<Promise<T>> command,
                   java.util.function.Function<Throwable,T> fallback)
Executes the given operation with the circuit breaker control. 
 | 
default <T> void | 
CircuitBreaker.executeWithFallback(Handler<Promise<T>> command,
                   java.util.function.Function<Throwable,T> fallback,
                   Handler<AsyncResult<T>> handler)
Same as  
CircuitBreaker.executeWithFallback(Handler, Function) but using a callback. | 
| Modifier and Type | Method and Description | 
|---|---|
static <T> Promise<T> | 
Promise.promise()
Create a promise that hasn't completed yet 
 | 
| Modifier and Type | Method and Description | 
|---|---|
default void | 
Verticle.start(Promise<Void> startPromise)
Start the verticle instance. 
 | 
default void | 
Verticle.stop(Promise<Void> stopPromise)
Stop the verticle instance. 
 | 
| Modifier and Type | Method and Description | 
|---|---|
<T> void | 
Context.executeBlocking(Handler<Promise<T>> blockingCodeHandler,
               boolean ordered,
               Handler<AsyncResult<T>> resultHandler)
Safely execute some blocking code. 
 | 
<T> void | 
Vertx.executeBlocking(Handler<Promise<T>> blockingCodeHandler,
               boolean ordered,
               Handler<AsyncResult<T>> resultHandler)
Safely execute some blocking code. 
 | 
<T> void | 
WorkerExecutor.executeBlocking(Handler<Promise<T>> blockingCodeHandler,
               boolean ordered,
               Handler<AsyncResult<T>> resultHandler)
Safely execute some blocking code. 
 | 
<T> void | 
Context.executeBlocking(Handler<Promise<T>> blockingCodeHandler,
               Handler<AsyncResult<T>> resultHandler)
Invoke  
Context.executeBlocking(Handler, boolean, Handler) with order = true. | 
<T> void | 
Vertx.executeBlocking(Handler<Promise<T>> blockingCodeHandler,
               Handler<AsyncResult<T>> resultHandler)
Like  
Vertx.executeBlocking(Handler, boolean, Handler) called with ordered = true. | 
default <T> void | 
WorkerExecutor.executeBlocking(Handler<Promise<T>> blockingCodeHandler,
               Handler<AsyncResult<T>> resultHandler)
Like  
WorkerExecutor.executeBlocking(Handler, boolean, Handler) called with ordered = true. | 
static <T> Future<T> | 
Future.future(Handler<Promise<T>> handler)
Create a future that hasn't completed yet and that is passed to the  
handler before it is returned. | 
| Modifier and Type | Method and Description | 
|---|---|
<T> Promise<T> | 
FutureFactory.promise()  | 
| Modifier and Type | Method and Description | 
|---|---|
default void | 
VerticleFactory.resolve(String identifier,
       DeploymentOptions deploymentOptions,
       ClassLoader classLoader,
       Promise<String> resolution)
Some verticle factories can "resolve" the identifer to another identifier which is then used to look up the real
 verticle factory. 
 | 
| Modifier and Type | Interface and Description | 
|---|---|
interface  | 
BaseBridgeEvent
Represents an event that occurs on the event bus bridge. 
 | 
| Modifier and Type | Method and Description | 
|---|---|
static Handler<Promise<Status>> | 
ClusterHealthCheck.createProcedure(Vertx vertx)
 | 
static Handler<Promise<Status>> | 
ClusterHealthCheck.createProcedure(Vertx vertx,
               boolean detailed)
Creates a ready-to-use Vert.x cluster  
HealthChecks procedure. | 
| Modifier and Type | Interface and Description | 
|---|---|
interface  | 
BridgeEvent
Represents an event that occurs on the event bus bridge. 
 | 
| Modifier and Type | Method and Description | 
|---|---|
HealthChecks | 
HealthChecks.register(String name,
        Handler<Promise<Status>> procedure)
Registers a health check procedure. 
 | 
HealthCheckHandler | 
HealthCheckHandler.register(String name,
        Handler<Promise<Status>> procedure)
Registers a health check procedure. 
 | 
HealthChecks | 
HealthChecks.register(String name,
        long timeout,
        Handler<Promise<Status>> procedure)
Registers a health check procedure. 
 | 
HealthCheckHandler | 
HealthCheckHandler.register(String name,
        long timeout,
        Handler<Promise<Status>> procedure)
Registers a health check procedure. 
 | 
| Modifier and Type | Method and Description | 
|---|---|
void | 
HttpServiceFactory.resolve(String identifier,
       DeploymentOptions deploymentOptions,
       ClassLoader classLoader,
       Promise<String> resolution)  | 
| Modifier and Type | Method and Description | 
|---|---|
void | 
ShellVerticle.start(Promise<Void> startFuture)  | 
| Modifier and Type | Method and Description | 
|---|---|
void | 
SyncVerticle.start(Promise<Void> startFuture)  | 
void | 
SyncVerticle.stop(Promise<Void> stopFuture)  | 
| Modifier and Type | Method and Description | 
|---|---|
void | 
Completion.resolve(Promise<T> future)
Completes the future upon completion, otherwise fails it. 
 | 
| Constructor and Description | 
|---|
VertxBatchLoader(TriConsumer<List<K>,org.dataloader.BatchLoaderEnvironment,Promise<List<V>>> batchLoader)
Create a new batch loader. 
 | 
VertxDataFetcher(java.util.function.BiConsumer<graphql.schema.DataFetchingEnvironment,Promise<T>> dataFetcher)
Create a new data fetcher. 
 | 
VertxMappedBatchLoader(TriConsumer<Set<K>,org.dataloader.BatchLoaderEnvironment,Promise<Map<K,V>>> batchLoader)
Create a new batch loader. 
 | 
| Modifier and Type | Method and Description | 
|---|---|
void | 
MavenVerticleFactory.resolve(String identifier,
       DeploymentOptions deploymentOptions,
       ClassLoader classLoader,
       Promise<String> resolution)  | 
| Modifier and Type | Method and Description | 
|---|---|
Promise | 
Promise.getDelegate()  | 
| Modifier and Type | Method and Description | 
|---|---|
static <T> Promise<T> | 
Promise.newInstance(Promise arg)  | 
static <T> Promise<T> | 
Promise.newInstance(Promise arg,
           io.vertx.lang.rx.TypeArg<T> __typeArg_T)  | 
| Constructor and Description | 
|---|
Promise(Promise delegate)  | 
| Modifier and Type | Method and Description | 
|---|---|
Promise | 
Promise.getDelegate()  | 
| Modifier and Type | Method and Description | 
|---|---|
static <T> Promise<T> | 
Promise.newInstance(Promise arg)  | 
static <T> Promise<T> | 
Promise.newInstance(Promise arg,
           io.vertx.lang.rx.TypeArg<T> __typeArg_T)  | 
| Constructor and Description | 
|---|
Promise(Promise delegate)  | 
| Modifier and Type | Method and Description | 
|---|---|
void | 
ServiceVerticleFactory.resolve(String identifier,
       DeploymentOptions deploymentOptions,
       ClassLoader classLoader,
       Promise<String> resolution)  | 
| Modifier and Type | Method and Description | 
|---|---|
ImportedConsulService | 
ImportedConsulService.register(ServicePublisher publisher,
        Promise<ImportedConsulService> completion)
Registers the service and completes the given future when done. 
 | 
void | 
ConsulServiceImporter.start(Vertx vertx,
     ServicePublisher publisher,
     JsonObject configuration,
     Promise<Void> completion)  | 
void | 
ImportedConsulService.unregister(ServicePublisher publiher,
          Promise<Void> completion)
Unregisters the service and completes the given future when done, if not  
null | 
| Modifier and Type | Method and Description | 
|---|---|
void | 
DockerLinksServiceImporter.start(Vertx vertx,
     ServicePublisher publisher,
     JsonObject configuration,
     Promise<Void> completion)  | 
| Modifier and Type | Method and Description | 
|---|---|
void | 
KubernetesServiceImporter.start(Vertx vertx,
     ServicePublisher publisher,
     JsonObject configuration,
     Promise<Void> completion)  | 
| Modifier and Type | Method and Description | 
|---|---|
void | 
ServiceExporter.init(Vertx vertx,
    ServicePublisher publisher,
    JsonObject configuration,
    Promise<Void> future)
Starts the exporter. 
 | 
void | 
ServiceImporter.start(Vertx vertx,
     ServicePublisher publisher,
     JsonObject configuration,
     Promise<Void> future)
Starts the importer. 
 | 
| Modifier and Type | Method and Description | 
|---|---|
static Handler<Promise<Status>> | 
ClusterHealthCheck.createProcedure(Vertx vertx)
Creates a ready-to-use Vert.x cluster  
HealthChecks procedure. | 
Copyright © 2020 Eclipse. All rights reserved.