| 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.failedPromise(String failureMessage)
Create a failed promise with the specified
failureMessage. |
static <T> Promise<T> |
Promise.failedPromise(Throwable cause)
Create a failed promise with the specified failure
cause. |
static <T> Promise<T> |
Promise.promise()
Create a promise that hasn't completed yet
|
static <T> Promise<T> |
Promise.succeededPromise()
Create a succeeded promise with a
null result |
static <T> Promise<T> |
Promise.succeededPromise(T result)
Created a succeeded promise with the specified
result. |
| 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 |
|---|---|
void |
ServerWebSocket.setHandshake(Promise<Integer> future)
Set an asynchronous result for the handshake, upon completion of the specified
future, the
WebSocket will either be
accepted when the future succeeds with the HTTP 101 status code
rejected when the future is succeeds with an HTTP status code different than 101
rejected when the future fails with the HTTP status code 500
The provided future might be completed by the WebSocket itself, e.g calling the ServerWebSocket.close() method
will try to accept the handshake and close the WebSocket afterward. |
| Modifier and Type | Method and Description |
|---|---|
<T> Promise<T> |
FutureFactory.failedPromise(Throwable t) |
<T> Promise<T> |
FutureFactory.failurePromise(String failureMessage) |
<T> Promise<T> |
FutureFactory.promise() |
<T> Promise<T> |
FutureFactory.succeededPromise() |
<T> Promise<T> |
FutureFactory.succeededPromise(T result) |
| 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.
|
| 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) |
Promise(Promise delegate,
io.vertx.lang.rx.TypeArg<T> typeArg_0) |
| 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) |
Promise(Promise delegate,
io.vertx.lang.rx.TypeArg<T> typeArg_0) |
| 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 © 2019 Eclipse. All rights reserved.