Uses of Interface
io.vertx.core.Future
Packages that use Future
Package
Description
-
Uses of Future in io.vertx.amqp
Methods in io.vertx.amqp that return FutureModifier and TypeMethodDescriptionAmqpClient.close()Closes the client.AmqpConnection.close()Closes the AMQP connection, i.e. allows the Close frame to be emitted.AmqpReceiver.close()Closes the receiver.AmqpSender.close()Closes the sender.AmqpConnection.closeFuture()AmqpClient.connect()Connects to the AMQP broker or router.AmqpConnection.createAnonymousSender()Creates an anonymous sender.AmqpConnection.createDynamicReceiver()Creates a dynamic receiver.AmqpClient.createReceiver(String address) Creates a receiver used to consume messages from the given address.AmqpClient.createReceiver(String address, AmqpReceiverOptions receiverOptions) Creates a receiver used to consumer messages from the given address.AmqpConnection.createReceiver(String address) Creates a receiver used to consume messages from the given address.AmqpConnection.createReceiver(String address, AmqpReceiverOptions receiverOptions) Creates a receiver used to consumer messages from the given address.AmqpClient.createSender(String address) Creates a sender used to send messages to the given address.AmqpClient.createSender(String address, AmqpSenderOptions options) Creates a sender used to send messages to the given address.AmqpConnection.createSender(String address) Creates a sender used to send messages to the given address.AmqpConnection.createSender(String address, AmqpSenderOptions options) Creates a sender used to send messages to the given address.AmqpSender.sendWithAck(AmqpMessage message) Sends an AMQP message and waits for an acknowledgement. -
Uses of Future in io.vertx.camel
Methods in io.vertx.camel that return Future -
Uses of Future in io.vertx.cassandra
Methods in io.vertx.cassandra that return FutureModifier and TypeMethodDescriptionResultSet.all()The method should not be used concurrently with others likeResultSet.fetchNextPage()orResultSet.one().CassandraClient.close()Closes this client.CassandraClient.execute(com.datastax.oss.driver.api.core.cql.Statement statement) Execute the statement and provide a handler for consuming results.<R> Future<R> CassandraClient.execute(com.datastax.oss.driver.api.core.cql.Statement statement, Collector<com.datastax.oss.driver.api.core.cql.Row, ?, R> collector) Execute a statement and produce a result by applying a collector to result set rows.Execute the query and provide a handler for consuming results.<R> Future<R> CassandraClient.execute(String query, Collector<com.datastax.oss.driver.api.core.cql.Row, ?, R> collector) Execute a query and produce a result by applying a collector to result set rows.CassandraClient.executeWithFullFetch(com.datastax.oss.driver.api.core.cql.Statement statement) Execute the query and provide a handler for consuming results.CassandraClient.executeWithFullFetch(String query) Execute the query and provide a handler for consuming results.ResultSet.fetchNextPage()Future<com.datastax.oss.driver.api.core.metadata.Metadata> CassandraClient.metadata()GetMetadatafor the session.CassandraRowStream.pipeTo(WriteStream<com.datastax.oss.driver.api.core.cql.Row> dst) Future<com.datastax.oss.driver.api.core.cql.PreparedStatement> CassandraClient.prepare(com.datastax.oss.driver.api.core.cql.SimpleStatement statement) Prepares the provided aSimpleStatement.Future<com.datastax.oss.driver.api.core.cql.PreparedStatement> Prepares the provided query string.CassandraClient.queryStream(com.datastax.oss.driver.api.core.cql.Statement statement) Executes the given SQL statement which returns the results of the query as a read stream.CassandraClient.queryStream(String sql) Executes the given SQLSELECTstatement which returns the results of the query as a read stream. -
Uses of Future in io.vertx.circuitbreaker
Subinterfaces with type arguments of type Future in io.vertx.circuitbreakerMethods in io.vertx.circuitbreaker that return FutureModifier and TypeMethodDescription<T> Future<T> Same asCircuitBreaker.executeWithFallback(Handler, Function)but using the circuit breaker default fallback.<T> Future<T> Same asCircuitBreaker.executeWithFallback(Supplier, Function)but using the circuit breaker default fallback.<T> Future<T> CircuitBreaker.executeWithFallback(Handler<Promise<T>> command, Function<Throwable, T> fallback) Executes the given operation with the circuit breaker control.<T> Future<T> CircuitBreaker.executeWithFallback(Supplier<Future<T>> command, Function<Throwable, T> fallback) Executes the given operation with the circuit breaker control.Methods in io.vertx.circuitbreaker with parameters of type FutureModifier and TypeMethodDescriptionbooleanInvoked by theCircuitBreakerwhen an operation completes.Method parameters in io.vertx.circuitbreaker with type arguments of type FutureModifier and TypeMethodDescription<T> Future<T> Same asCircuitBreaker.executeWithFallback(Supplier, Function)but using the circuit breaker default fallback.<T> Future<T> CircuitBreaker.executeWithFallback(Supplier<Future<T>> command, Function<Throwable, T> fallback) Executes the given operation with the circuit breaker control. -
Uses of Future in io.vertx.config
Methods in io.vertx.config that return FutureModifier and TypeMethodDescriptionConfigRetriever.close()Closes the retriever.ConfigRetriever.getConfig()Reads the configuration from the differentConfigStoreand computes the final configuration. -
Uses of Future in io.vertx.config.consul
Methods in io.vertx.config.consul that return Future -
Uses of Future in io.vertx.config.git
Methods in io.vertx.config.git that return Future -
Uses of Future in io.vertx.config.hocon
Methods in io.vertx.config.hocon that return FutureModifier and TypeMethodDescriptionHoconProcessor.process(Vertx vertx, JsonObject configuration, Buffer input) -
Uses of Future in io.vertx.config.kubernetes
Methods in io.vertx.config.kubernetes that return Future -
Uses of Future in io.vertx.config.redis
Methods in io.vertx.config.redis that return Future -
Uses of Future in io.vertx.config.spi
Methods in io.vertx.config.spi that return FutureModifier and TypeMethodDescriptionConfigStore.close()Closes the configuration store.ConfigStore.get()Retrieves the configuration store in this store.ConfigProcessor.process(Vertx vertx, JsonObject configuration, Buffer input) Transforms the giveninputinto aJsonObject. -
Uses of Future in io.vertx.config.vault
Methods in io.vertx.config.vault that return Future -
Uses of Future in io.vertx.config.vault.client
Methods in io.vertx.config.vault.client that return FutureModifier and TypeMethodDescriptionSlimVaultClient.createToken(TokenRequest tokenRequest) SlimVaultClient.loginWithAppRole(String roleId, String secretId) SlimVaultClient.loginWithCert()SlimVaultClient.loginWithUserCredentials(String username, String password) SlimVaultClient.lookupSelf()SlimVaultClient.renewSelf(long leaseDurationInSecond) SlimVaultClient.write(String path, JsonObject secrets) -
Uses of Future in io.vertx.config.yaml
Methods in io.vertx.config.yaml that return FutureModifier and TypeMethodDescriptionYamlProcessor.process(Vertx vertx, JsonObject configuration, Buffer input) -
Uses of Future in io.vertx.config.zookeeper
Methods in io.vertx.config.zookeeper that return Future -
Uses of Future in io.vertx.core
Subinterfaces of Future in io.vertx.coreModifier and TypeInterfaceDescriptioninterfaceThe composite future wraps a list offutures, it is useful when several futures needs to be coordinated.interfaceA timer task that can be used as a future.Methods in io.vertx.core that return FutureModifier and TypeMethodDescriptionFuture.andThen(Completable<? super T> handler) Invokes the givenhandlerupon completion.Future.andThen(Handler<AsyncResult<T>> handler) Invokes the givenhandlerupon completion.VertxBuilder.buildClustered()Creates a clustered instance.Vertx.close()Stop the Vertx instance and release any resources held by it.WorkerExecutor.close()Close the executor.Vertx.clusteredVertx(VertxOptions options) Creates a clustered instance using the specified options.default <U> Future<U> Compose this future with amapperfunction.<U> Future<U> Future.compose(Function<? super T, Future<U>> successMapper, Function<Throwable, Future<U>> failureMapper) Compose this future with asuccessMapperandfailureMapperfunctions.final Future<?> Future<?> Start the deployable.final Future<?> Vertx.deployVerticle(Deployable verticle) Deploy a verticle instance that you have created yourself.Vertx.deployVerticle(Deployable verticle, DeploymentOptions options) LikeVertx.deployVerticle(Deployable)butDeploymentOptionsare provided to configure the deployment.Vertx.deployVerticle(Class<? extends Deployable> verticleClass, DeploymentOptions options) LikeVertx.deployVerticle(Deployable, DeploymentOptions)butDeployableinstance is created by invoking the default constructor ofverticleClass.Vertx.deployVerticle(String name) Deploy a verticle instance given a name.Vertx.deployVerticle(String name, DeploymentOptions options) LikeVertx.deployVerticle(Deployable)butDeploymentOptionsare provided to configure the deployment.Vertx.deployVerticle(Supplier<? extends Deployable> supplier, DeploymentOptions options) LikeVertx.deployVerticle(Deployable, DeploymentOptions)butDeployableinstance is created by invoking theverticleSupplier.Future.eventually(Supplier<Future<U>> mapper) Compose this future with amapperthat will be always be called.default <T> Future<T> Context.executeBlocking(Callable<T> blockingCodeHandler) InvokeContext.executeBlocking(Callable, boolean)with order = true.<T> Future<T> Context.executeBlocking(Callable<T> blockingCodeHandler, boolean ordered) Safely execute some blocking code.default <T> Future<T> Vertx.executeBlocking(Callable<T> blockingCodeHandler) LikeVertx.executeBlocking(Callable, boolean)called with ordered = true.default <T> Future<T> Vertx.executeBlocking(Callable<T> blockingCodeHandler, boolean ordered) Safely execute some blocking code.default <T> Future<T> WorkerExecutor.executeBlocking(Callable<T> blockingCodeHandler) LikeWorkerExecutor.executeBlocking(Callable, boolean)called with ordered = true.<T> Future<T> WorkerExecutor.executeBlocking(Callable<T> blockingCodeHandler, boolean ordered) Safely execute some blocking code.Future.expecting(Expectation<? super T> expectation) Guard the control flow of this future with an expectation.static <T> Future<T> Future.failedFuture(String failureMessage) Create a failed future with the specified failure message.static <T> Future<T> Future.failedFuture(Throwable t) Create a failed future with the specified failure cause.default <U> Future<U> Alias forFuture.compose(Function).static <T> Future<T> Future.fromCompletionStage(CompletionStage<T> completionStage) Bridges aCompletionStageobject to a Vert.x future instance.static <T> Future<T> Future.fromCompletionStage(CompletionStage<T> completionStage, Context context) Bridges aCompletionStageobject to a Vert.x future instance.static <T> Future<T> Create a promise and pass it to thehandler, and then returns this future's promise.Promise.future()<U> Future<U> Apply amapperfunction on this future.<V> Future<V> Future.map(V value) Map the result of a future to a specificvalue.default <V> Future<V> Future.mapEmpty()Map the result of a future tonull.Future.onComplete(Completable<? super T> handler) Add handlers to be notified on succeeded result and failed result.Future.onComplete(Handler<? super T> successHandler, Handler<? super Throwable> failureHandler) Add handlers to be notified on succeeded result and failed result.Future.onComplete(Handler<AsyncResult<T>> handler) Add a handler to be notified of the result.Add a handler to be notified of the failed result.Add a handler to be notified of the succeeded result.Apply amapperfunction on this future.Map the failure of a future to a specificvalue.Future.otherwiseEmpty()Map the failure of a future tonull.Handles a failure of this Future by returning the result of another Future.Future<?> VerticleBase.start()Start the verticle.Future<?> VerticleBase.stop()Stop the verticle.static <T> Future<T> Future.succeededFuture()Create a succeeded future with a null resultstatic <T> Future<T> Future.succeededFuture(T result) Created a succeeded future with the specified result.Returns a future succeeded or failed with the outcome of this future when it happens before the timeout fires.default <U> Future<U> Future.transform(BiFunction<? super T, ? super Throwable, Future<U>> mapper) Transform this future with amapperfunction.<U> Future<U> Future.transform(Function<AsyncResult<T>, Future<U>> mapper) Transform this future with amapperfunction.final Future<?> default Future<?> Stop the deployable.final Future<?> Undeploy a verticle deployment.Methods in io.vertx.core with parameters of type FutureModifier and TypeMethodDescriptionstatic CompositeFutureLikeFuture.all(Future, Future)but with a variable number of futures.static CompositeFutureReturn a composite future, succeeded when all futures are succeeded, failed when any future is failed.static CompositeFutureLikeFuture.all(Future, Future)but with 3 futures.static CompositeFutureLikeFuture.all(Future, Future)but with 4 futures.static CompositeFutureLikeFuture.all(Future, Future)but with 5 futures.static CompositeFutureLikeFuture.all(Future, Future)but with 6 futures.static CompositeFutureLikeFuture.any(Future, Future)but with a variable number of futures.static CompositeFutureReturn a composite future, succeeded when any futures is succeeded, failed when all futures are failed.static CompositeFutureLikeFuture.any(Future, Future)but with 3 futures.static CompositeFutureLikeFuture.any(Future, Future)but with 4 futures.static CompositeFutureLikeFuture.any(Future, Future)but with 5 futures.static CompositeFutureLikeFuture.any(Future, Future)but with 6 futures.static <T> TCallsFuture.await()onfuture.static CompositeFutureLikeFuture.join(Future, Future)but with a variable number of futures.static CompositeFutureReturn a composite future, succeeded when all futures are succeeded, failed when any future is failed.static CompositeFutureLikeFuture.join(Future, Future)but with 3 futures.static CompositeFutureLikeFuture.join(Future, Future)but with 4 futures.static CompositeFutureLikeFuture.join(Future, Future)but with 5 futures.static CompositeFutureLikeFuture.join(Future, Future)but with 6 futures.Method parameters in io.vertx.core with type arguments of type FutureModifier and TypeMethodDescriptionstatic CompositeFutureLikeFuture.all(Future, Future)but with a list of futures.static CompositeFutureLikeFuture.any(Future, Future)but with a list of futures.default <U> Future<U> Compose this future with amapperfunction.<U> Future<U> Future.compose(Function<? super T, Future<U>> successMapper, Function<Throwable, Future<U>> failureMapper) Compose this future with asuccessMapperandfailureMapperfunctions.Future.eventually(Supplier<Future<U>> mapper) Compose this future with amapperthat will be always be called.default <U> Future<U> Alias forFuture.compose(Function).static CompositeFutureLikeFuture.join(Future, Future)but with a list of futures.Handles a failure of this Future by returning the result of another Future.default <U> Future<U> Future.transform(BiFunction<? super T, ? super Throwable, Future<U>> mapper) Transform this future with amapperfunction.<U> Future<U> Future.transform(Function<AsyncResult<T>, Future<U>> mapper) Transform this future with amapperfunction. -
Uses of Future in io.vertx.core.datagram
Methods in io.vertx.core.datagram that return FutureModifier and TypeMethodDescriptionDatagramSocket.blockMulticastGroup(String multicastAddress, String sourceToBlock) Block the given address for the given multicast address and notifies theHandleronce the operation completes.DatagramSocket.blockMulticastGroup(String multicastAddress, String networkInterface, String sourceToBlock) Block the given address for the given multicast address on the given network interface and notifies theHandleronce the operation completes.DatagramSocket.close()Closes theDatagramSocketimplementation asynchronous and notifies the handler once done.Start listening on the given port and host.DatagramSocket.listenMulticastGroup(String multicastAddress) Joins a multicast group and listens for packets send to it.DatagramSocket.listenMulticastGroup(String multicastAddress, String networkInterface, String source) Joins a multicast group and listens for packets send to it on the given network interface.Write the givenBufferto theSocketAddress.Write the givenStringto theSocketAddressusing UTF8 encoding.Write the givenStringto theSocketAddressusing the given encoding.DatagramSocket.unlistenMulticastGroup(String multicastAddress) Leaves a multicast group and stops listening for packets send to it.DatagramSocket.unlistenMulticastGroup(String multicastAddress, String networkInterface, String source) Leaves a multicast group and stops listening for packets send to it on the given network interface. -
Uses of Future in io.vertx.core.dns
Methods in io.vertx.core.dns that return FutureModifier and TypeMethodDescriptionDnsClient.close()Close the client.Try to lookup the A (ipv4) or AAAA (ipv6) record for the given name.Try to lookup the A (ipv4) record for the given name.Try to lookup the AAAA (ipv6) record for the given name.Try to resolve all A (ipv4) records for the given name.DnsClient.resolveAAAA(String name) Try to resolve all AAAA (ipv6) records for the given name.DnsClient.resolveCNAME(String name) Try to resolve the CNAME record for the given name.Try to resolve the MX records for the given name.Try to resolve the NS records for the given name.DnsClient.resolvePTR(String name) Try to resolve the PTR record for the given name.DnsClient.resolveSRV(String name) Try to resolve the SRV records for the given name.DnsClient.resolveTXT(String name) Try to resolve the TXT records for the given name.DnsClient.reverseLookup(String ipaddress) Try to do a reverse lookup of an IP address. -
Uses of Future in io.vertx.core.eventbus
Methods in io.vertx.core.eventbus that return FutureModifier and TypeMethodDescriptionMessageProducer.close()Closes the producer, this method should be called when the message producer is not used anymore.MessageConsumer.completion()Message.replyAndRequest(Object message) Reply to this message, specifying areplyHandlerfor the reply - i.e. to receive the reply to the reply.Message.replyAndRequest(Object message, DeliveryOptions options) LikeMessage.replyAndRequest(Object)but specifyingoptionsthat can be used to configure the delivery.Sends a message and specify areplyHandlerthat will be called if the recipient subsequently replies to the message.EventBus.request(String address, Object message, DeliveryOptions options) LikeEventBus.request(String, Object)but specifyingoptionsthat can be used to configure the delivery.MessageConsumer.unregister()Unregisters the handler which created this registrationWrite a message to the event-bus, either sending or publishing. -
Uses of Future in io.vertx.core.file
Methods in io.vertx.core.file that return FutureModifier and TypeMethodDescriptionChange the permissions on the file represented bypathtoperms, asynchronously.FileSystem.chmodRecursive(String path, String perms, String dirPerms) Change the permissions on the file represented bypathtoperms, asynchronously.Change the ownership on the file represented bypathtouserand {code group}, asynchronously.AsyncFile.close()Close the file.Copy a file from the pathfromto pathto, asynchronously.FileSystem.copy(String from, String to, CopyOptions options) Copy a file from the pathfromto pathto, asynchronously.FileSystem.copyRecursive(String from, String to, boolean recursive) Copy a file from the pathfromto pathto, asynchronously.FileSystem.createFile(String path) Creates an empty file with the specifiedpath, asynchronously.FileSystem.createFile(String path, String perms) Creates an empty file with the specifiedpathand permissionsperms, asynchronously.FileSystem.createTempDirectory(String prefix) Creates a new directory in the default temporary-file directory, using the given prefix to generate its name, asynchronously.FileSystem.createTempDirectory(String prefix, String perms) Creates a new directory in the default temporary-file directory, using the given prefix to generate its name, asynchronously.FileSystem.createTempDirectory(String dir, String prefix, String perms) Creates a new directory in the directory provided by the pathpath, using the given prefix to generate its name, asynchronously.FileSystem.createTempFile(String prefix, String suffix) Creates a new file in the default temporary-file directory, using the given prefix and suffix to generate its name, asynchronously.FileSystem.createTempFile(String prefix, String suffix, String perms) Creates a new file in the directory provided by the pathdir, using the given prefix and suffix to generate its name, asynchronously.FileSystem.createTempFile(String dir, String prefix, String suffix, String perms) Creates a new file in the directory provided by the pathdir, using the given prefix and suffix to generate its name, asynchronously.Deletes the file represented by the specifiedpath, asynchronously.FileSystem.deleteRecursive(String path) Deletes the file represented by the specifiedpath, asynchronously.Determines whether the file as specified by the pathpathexists, asynchronously.AsyncFile.flush()Flush any writes made to this file to underlying persistent storage.Returns properties of the file-system being used by the specifiedpath, asynchronously.AsyncFileLock.isValid()A lock remains valid until it is released or the file correspondingAsyncFileis closed.Create a hard link on the file system fromlinktoexisting, asynchronously.default Future<AsyncFileLock> AsyncFile.lock()Acquire a non-shared lock on the entire file.AsyncFile.lock(long position, long size, boolean shared) Acquire a lock on a portion of this file.Obtain properties for the link represented bypath, asynchronously.Create the directory represented bypath, asynchronously.Create the directory represented bypath, asynchronously.Create the directory represented bypathand any non existent parents, asynchronously.Create the directory represented bypathand any non existent parents, asynchronously.Move a file from the pathfromto pathto, asynchronously.FileSystem.move(String from, String to, CopyOptions options) Move a file from the pathfromto pathto, asynchronously.FileSystem.open(String path, OpenOptions options) Open the file represented bypath, asynchronously.Obtain properties for the file represented bypath, asynchronously.Readslengthbytes of data from the file at positionpositionin the file, asynchronously.Read the contents of the directory specified bypath, asynchronously.Read the contents of the directory specified bypath, asynchronously.Reads the entire file as represented by the pathpathas aBuffer, asynchronously.FileSystem.readSymlink(String link) Returns the path representing the file that the symbolic link specified bylinkpoints to, asynchronously.AsyncFileLock.release()Releases this lock;AsyncFile.size()Create a symbolic link on the file system fromlinktoexisting, asynchronously.Truncate the file represented bypathto lengthlenin bytes, asynchronously.Unlinks the link on the file system represented by the pathlink, asynchronously.default <T> Future<T> Acquire a lock on a portion of this file.default <T> Future<T> Acquire a non-shared lock on the entire file.Write aBufferto the file at positionpositionin the file, asynchronously.Creates the file, and writes the specifiedBuffer datato the file represented by the pathpath, asynchronously.Method parameters in io.vertx.core.file with type arguments of type Future -
Uses of Future in io.vertx.core.http
Fields in io.vertx.core.http with type parameters of type FutureModifier and TypeFieldDescriptionstatic final Function<HttpClientResponse, Future<RequestOptions>> HttpClientAgent.DEFAULT_REDIRECT_HANDLERConstant containing the default redirect handler of used by the client.Methods in io.vertx.core.http that return FutureModifier and TypeMethodDescriptionServerWebSocketHandshake.accept()Accept the WebSocket and terminate the WebSocket handshake.HttpClientResponse.body()Convenience method for receiving the entire request body in one piece.HttpServerRequest.body()Convenience method for receiving the entire request body in one piece.HttpClientRequest.cancel()Attempt to cancel the request according to the semantics of the underlying HTTP implementation.HttpServerResponse.cancel()Attempt to cancel the request according to the semantics of the underlying HTTP implementation.HttpClient.close()Close immediately (shutdown(0, TimeUnit.SECONDS).HttpClientConnection.close()HttpConnection.close()Close immediately (shutdown(0, TimeUnit.SECONDS).HttpServer.close()Close the server.ServerWebSocket.close()Close the WebSocket sending the default close frame.WebSocketBase.close()Close the WebSocket sending the default close frame.WebSocketBase.close(short statusCode) Close the WebSocket sending a close frame with specified status code.Close sending a close frame with specified status code and reason.WebSocketClient.close()Close immediately (shutdown(0, TimeUnit.SECONDS).Connect this WebSocket to the specified port, host and relative request URI.ClientWebSocket.connect(WebSocketConnectOptions options) Connect this WebSocket with the specified options.Connect this WebSocket at the relative request URI using the default host and port.Connect this WebSocket to the host and relative request URI and default port.HttpClientAgent.connect(HttpConnectOptions options) Connect to a remote HTTP server with the specificoptions, the connection is un-pooled and the management of the connection is left to the user.HttpClientRequest.connect()Create an HTTP tunnel to the server.Connect a WebSocket to the specified port, host and relative request URI.WebSocketClient.connect(WebSocketConnectOptions options) Connect a WebSocket with the specified options.Connect a WebSocket to the default client port, default client host and specified, relative request URI.Connect a WebSocket to the default client port and specified host and relative request URI.HttpClientRequest.end()Ends the request.Same asHttpClientRequest.end()but writes some data to the request body before ending.Same asHttpClientRequest.end(Buffer)but writes a String in UTF-8 encodingSame asHttpClientRequest.end(Buffer)but writes a String with the specified encodingHttpClientResponse.end()Returns a future signaling when the response has been fully received successfully or failed.HttpServerRequest.end()Returns a future signaling when the request has been fully received successfully or failed.HttpServerResponse.end()Ends the response.Same asHttpServerResponse.end()but writes some data to the response body before ending.Same asHttpServerResponse.end(Buffer)but writes a String in UTF-8 encoding before ending the response.Same asHttpServerResponse.end(Buffer)but writes a String with the specified encoding before ending the response.WebSocketBase.end()Ends the stream.HttpServer.listen()Tell the server to start listening.default Future<HttpServer> HttpServer.listen(int port) LikeHttpServer.listen(int, String)but the server will listen on host "0.0.0.0" and port specified here ignoring any value in theHttpServerOptionsthat was used when creating the server.default Future<HttpServer> Tell the server to start listening.HttpServer.listen(SocketAddress address) Tell the server to start listening on the given address supplying a handler that will be called when the server is actually listening (or has failed).Send a PING frame to the remote endpoint.default Future<HttpServerResponse> HttpServerResponse.push(HttpMethod method, HostAndPort authority, String path) LikeHttpServerResponse.push(HttpMethod, HostAndPort, String, MultiMap)with no headers.HttpServerResponse.push(HttpMethod method, HostAndPort authority, String path, MultiMap headers) Push a response to the client.default Future<HttpServerResponse> HttpServerResponse.push(HttpMethod method, String path) LikeHttpServerResponse.push(HttpMethod, HostAndPort, String, MultiMap)with the host copied from the current request.default Future<HttpServerResponse> HttpServerResponse.push(HttpMethod method, String path, MultiMap headers) LikeHttpServerResponse.push(HttpMethod, HostAndPort, String, MultiMap)with the host copied from the current request.ServerWebSocketHandshake.reject()Reject the WebSocket.ServerWebSocketHandshake.reject(int status) LikeServerWebSocketHandshake.reject()but with astatus.default Future<HttpClientRequest> HttpClient.request()Create an HTTP request to send to the server with the default host and port of the client.default Future<HttpClientRequest> HttpClient.request(HttpMethod method, int port, String host, String requestURI) Create an HTTP request to send to the server at thehostandport.default Future<HttpClientRequest> HttpClient.request(HttpMethod method, String requestURI) Create an HTTP request to send to the server at the default host and port.default Future<HttpClientRequest> HttpClient.request(HttpMethod method, String host, String requestURI) Create an HTTP request to send to the server at thehostand default port.HttpClient.request(RequestOptions options) Create an HTTP request to send to the server.HttpClientRequest.reset()Reset this stream with the error code0.HttpClientRequest.reset(long code) Reset this request:Reset this request:HttpServerResponse.reset()Equivalent to callingHttpServerResponse.reset(long)with0.HttpServerResponse.reset(long code) Reset this response:HttpClientRequest.response()default Future<HttpClientResponse> HttpClientRequest.send()Send the request with an empty body.default Future<HttpClientResponse> Send the request with a bufferbody.HttpClientRequest.send(ClientForm form) LikeHttpClientRequest.send()but with aform.default Future<HttpClientResponse> HttpClientRequest.send(ReadStream<Buffer> body) Send the request with a streambody.default Future<HttpClientResponse> Send the request with a stringbody.HttpServerResponse.send()Send the request with an empty body.Send the request with a bufferbody.HttpServerResponse.send(ReadStream<Buffer> body) Send the request with a streambody.Send the request with a stringbody.HttpServerResponse.sendFile(RandomAccessFile file) Same asHttpServerResponse.sendFile(FileChannel)withRandomAccessFileHttpServerResponse.sendFile(RandomAccessFile file, long offset) HttpServerResponse.sendFile(RandomAccessFile file, long offset, long length) Send the request with a streambody.Same asHttpServerResponse.sendFile(String, long, long)using length @code{Long.MAX_VALUE} which means until the end of the file.Ask the OS to stream a file as specified byfilenamedirectly from disk to the outgoing connection, bypassing userspace altogether (where supported by the underlying operating system.HttpServerResponse.sendFile(FileChannel channel) Same asHttpServerResponse.sendFile(FileChannel, long)using length @code{Long.MAX_VALUE} which means until the end of the file.HttpServerResponse.sendFile(FileChannel channel, long offset) Same asHttpServerResponse.sendFile(FileChannel, long, long)using length @code{Long.MAX_VALUE} which means until the end of the file.HttpServerResponse.sendFile(FileChannel channel, long offset, long length) Ask the OS to stream a file as specified bychanneldirectly from disk to the outgoing connection, bypassing userspace altogether (where supported by the underlying operating system).HttpClientRequest.sendHead()Deprecated, for removal: This API element is subject to removal in a future version.HttpClient.shutdown()Shutdown with a 30 seconds timeout (shutdown(30, TimeUnit.SECONDS)).Initiate the client shutdown sequence.HttpClientConnection.shutdown()HttpConnection.shutdown()Shutdown with a 30 seconds timeout (shutdown(30, TimeUnit.SECONDS)).Initiate a graceful connection shutdown, the connection is taken out of service and closed when all the inflight requests are processed, otherwise after atimeoutthe connection will be closed.HttpServer.shutdown()Shutdown with a 30 seconds timeout (shutdown(Duration.ofSeconds(30))).Initiate the server shutdown sequence.WebSocketBase.shutdown()LikeWebSocketBase.shutdown(long, TimeUnit, short, String)with a 30 seconds timeout, the status code1000anullreason.CallsWebSocketBase.shutdown(long, TimeUnit, short, String)with the status code1000and anullreason.CallsWebSocketBase.shutdown(long, TimeUnit, short, String)with anullreason.WebSocketBase.shutdown(short statusCode) LikeWebSocketBase.shutdown(long, TimeUnit, short, String)with a 30 seconds timeout and anullreason.LikeWebSocketBase.shutdown(long, TimeUnit, short, String)with a 30 seconds timeout.CallsWebSocketBase.shutdown(Duration, short, String)with anullreason.Initiate a graceful WebSocket shutdown, the shutdown handler is notified and shall close the WebSocket, otherwise after atimeoutthe WebSocket will be closed.WebSocketClient.shutdown()Shutdown with a 30 seconds timeout (shutdown(30, TimeUnit.SECONDS)).Initiate the client shutdown sequence.HttpServerFileUpload.streamToFileSystem(String filename) Stream the content of this upload to the given file on storage.HttpServerRequest.toNetSocket()Establish a TCP tunnel with the client.HttpServerRequest.toWebSocket()Upgrade the connection of the current request to a WebSocket.HttpConnection.updateSettings(HttpSettings settings) Send to the remote endpoint an update of this endpoint settingsHttpClientAgent.updateSSLOptions(ClientSSLOptions options) Update the client with new SSLoptions, the update happens if the options object is valid and different from the existing options object.HttpClientAgent.updateSSLOptions(ClientSSLOptions options, boolean force) Update the client with new SSLoptions, the update happens if the options object is valid and different from the existing options object.HttpServer.updateSSLOptions(ServerSSLOptions options) Update the server with new SSLoptions, the update happens if the options object is valid and different from the existing options object.HttpServer.updateSSLOptions(ServerSSLOptions options, boolean force) Update the server with new SSLoptions, the update happens if the options object is valid and different from the existing options object.WebSocketClient.updateSSLOptions(ClientSSLOptions options) Update the client with new SSLoptions, the update happens if the options object is valid and different from the existing options object.WebSocketClient.updateSSLOptions(ClientSSLOptions options, boolean force) Update the client with new SSLoptions, the update happens if the options object is valid and different from the existing options object.HttpServer.updateTrafficShapingOptions(TrafficShapingOptions options) Update the server with new trafficoptions, the update happens if the options object is valid and different from the existing options object.Write aStringto the request body, encoded as UTF-8.Write aStringto the request body, encoded using the encodingenc.Write aStringto the response body, encoded in UTF-8.Write aStringto the response body, encoded using the encodingenc.HttpServerResponse.writeAltSvc(String advertisement) Write an invalid input: '<'a href="https://datatracker.ietf.org/doc/html/rfc7838"HTTP Alternative Services advertisement for the given request and its authority, according to the underlying protocol.WebSocketBase.writeBinaryMessage(Buffer data) Writes a (potentially large) piece of binary data to the connection.HttpServerResponse.writeContinue()Used to write an interim 100 Continue response to signify that the client should send the rest of the request.HttpClientRequest.writeCustomFrame(int type, int flags, Buffer payload) Write an HTTP/2 frame to the request, allowing to extend the HTTP/2 protocol.HttpClientRequest.writeCustomFrame(HttpFrame frame) LikeHttpClientRequest.writeCustomFrame(int, int, Buffer)but with anHttpFrame.HttpServerResponse.writeCustomFrame(int type, int flags, Buffer payload) Write an HTTP/2 frame to the response, allowing to extend the HTTP/2 protocol.HttpServerResponse.writeCustomFrame(HttpFrame frame) LikeHttpServerResponse.writeCustomFrame(int, int, Buffer)but with anHttpFrame.HttpServerResponse.writeEarlyHints(MultiMap headers) Used to write an interim 103 Early Hints response to return some HTTP headers before the final HTTP message.WebSocketBase.writeFinalBinaryFrame(Buffer data) Write a final WebSocket binary frame to the connectionWebSocketBase.writeFinalTextFrame(String text) Write a final WebSocket text frame to the connectionWebSocketBase.writeFrame(WebSocketFrame frame) Write a WebSocket frame to the connectionHttpClientRequest.writeHead()Write the head of the request.HttpServerResponse.writeHead()Send the response headers.Writes a ping frame to the connection.Writes a pong frame to the connection.WebSocketBase.writeTextMessage(String text) Writes a (potentially large) piece of text data to the connection.Method parameters in io.vertx.core.http with type arguments of type FutureModifier and TypeMethodDescriptionHttpClientRequest.redirectHandler(Function<HttpClientResponse, Future<HttpClientRequest>> handler) HttpClientBuilder.withRedirectHandler(Function<HttpClientResponse, Future<RequestOptions>> handler) Set a redirect handler for the http client. -
Uses of Future in io.vertx.core.net
Methods in io.vertx.core.net that return FutureModifier and TypeMethodDescriptionQuicStream.abort(int error) Instruct the remote peer that this part of the stream is no longer interested in received data and wants it to cease transmission, aSTOP_SENDINGframe is sent to the remote peer.QuicEndpoint.bind(SocketAddress address) Binds a UDP socket at the givenaddress.NetClient.close()Close immediately (shutdown(0, TimeUnit.SECONDS).NetServer.close()Close the server.NetSocket.close()Close the socketQuicConnection.close()Close the connection, all associated streams will be closed before.QuicConnection.close(QuicConnectionClose payload) Close the connection, all associated streams will be closed before.QuicEndpoint.close()Close the endpoint and release all associated resources.StreamChannel.close()Close the channelOpen a connection to a server at the specificportandhost.Open a connection to a server at the specificportandhost.NetClient.connect(ConnectOptions connectOptions) Open a connection to a server at the specificconnectOptions.NetClient.connect(SocketAddress remoteAddress) Open a connection to a server at the specificremoteAddress.NetClient.connect(SocketAddress remoteAddress, String serverName) Open a connection to a server at the specificremoteAddress.default Future<QuicConnection> Connect to a Quic server at the specificportandhost.default Future<QuicConnection> QuicClient.connect(int port, String host, QuicConnectOptions options) Connect to a Quic server at the specificportandhost, with specificoptions.default Future<QuicConnection> QuicClient.connect(SocketAddress address) Connect to a Quic server.QuicClient.connect(SocketAddress address, QuicConnectOptions options) Connect to a Quic server with specificoptions.NetSocket.end()CallsNetSocket.close()StreamChannel.end()CallsStreamChannel.close()NetServer.listen()Start listening on the port and host as configured in theNetServerOptionsused when creating the server.NetServer.listen(int port) Start listening on the specified port and host "0.0.0.0", ignoring port and host configured in theNetServerOptionsused when creating the server.Start listening on the specified port and host, ignoring port and host configured in theNetServerOptionsused when creating the server.NetServer.listen(SocketAddress localAddress) Start listening on the specified local address, ignoring port and host configured in theNetServerOptionsused when creating the server.QuicServer.listen()Start listening on theportandhostas configured in theQuicServerConfigused when creating the server.default Future<SocketAddress> QuicServer.listen(int port) Start listening on the specified port and host "0.0.0.0".default Future<SocketAddress> Start listening on the specifiedportandhost.default Future<SocketAddress> QuicServer.listen(SocketAddress localAddress) Start listening on the specified local address.default Future<QuicStream> QuicConnection.openStream()Open a bidirectional stream to the remote endpoint.QuicConnection.openStream(boolean bidirectional) Open a stream to the remote endpoint withbidirectional parameterspecifying its directionality.QuicStream.reset(int error) Abruptly terminate the sending part of the stream with the specified application protocolerrorcode argument, aRESETframe is sent to the remote peer.Tell the operating system to stream a file as specified byfilenamedirectly from disk to the outgoing connection, bypassing userspace altogether (where supported by the underlying operating system.Tell the operating system to stream a file as specified byfilenamedirectly from disk to the outgoing connection, bypassing userspace altogether (where supported by the underlying operating system.Tell the operating system to stream a file as specified byfilenamedirectly from disk to the outgoing connection, bypassing userspace altogether (where supported by the underlying operating system.Tell the operating system to stream a file as specified byfilenamedirectly from disk to the outgoing connection, bypassing userspace altogether (where supported by the underlying operating system.Tell the operating system to stream a file as specified byfilenamedirectly from disk to the outgoing connection, bypassing userspace altogether (where supported by the underlying operating system.Tell the operating system to stream a file as specified byfilenamedirectly from disk to the outgoing connection, bypassing userspace altogether (where supported by the underlying operating system.NetClient.shutdown()Shutdown with a 30 seconds timeout (shutdown(30, TimeUnit.SECONDS)).CallsNetClient.shutdown(Duration).Initiate the client shutdown sequence.NetServer.shutdown()Shutdown with a 30 seconds timeout (shutdown(30, TimeUnit.SECONDS)).CallsNetServer.shutdown(Duration).Initiate the server shutdown sequence.QuicConnection.shutdown()Shutdown with a 30 seconds timeout.Initiate a graceful connection shutdown, the connection is taken out of service and closed when all the inflight streams are processed, otherwise after atimeoutthe connection will be closed.QuicConnection.shutdown(Duration timeout, QuicConnectionClose payload) Initiate a graceful connection shutdown, the connection is taken out of service and closed when all the inflight streams are processed, otherwise after atimeoutthe connection will be closed.QuicEndpoint.shutdown()Shutdown the endpoint with a 30 seconds grace period (shutdown(30, TimeUnit.SECONDS)).Initiate the endpoint shutdown sequence.NetClient.updateSSLOptions(ClientSSLOptions options) Update the client with new SSLoptions, the update happens if the options object is valid and different from the existing options object.NetClient.updateSSLOptions(ClientSSLOptions options, boolean force) Update the client with new SSLoptions, the update happens if the options object is valid and different from the existing options object.NetServer.updateSSLOptions(ServerSSLOptions options) Update the server with new SSLoptions, the update happens if the options object is valid and different from the existing options object.NetServer.updateSSLOptions(ServerSSLOptions options, boolean force) Update the server with new SSLoptions, the update happens if the options object is valid and different from the existing options object.QuicServer.updateSSLOptions(ServerSSLOptions options) Update the server with new SSLoptions, the update happens if the options object is valid and different from the existing options object.QuicServer.updateSSLOptions(ServerSSLOptions options, boolean force) Update the server with new SSLoptions, the update happens if the options object is valid and different from the existing options object.NetServer.updateTrafficShapingOptions(TrafficShapingOptions options) Update the server with new trafficoptions, the update happens if the options object is valid and different from the existing options object.NetSocket.upgradeToSsl()LikeNetSocket.upgradeToSsl(SSLOptions, String, Buffer)with the default SSL options, without indicating a server name, without an upgrade message.NetSocket.upgradeToSsl(Buffer msg) LikeNetSocket.upgradeToSsl(SSLOptions, String, Buffer)with the default SSL options and without indicating a server name.NetSocket.upgradeToSsl(SSLOptions sslOptions) Upgrade channel to use SSL/TLS.NetSocket.upgradeToSsl(SSLOptions sslOptions, Buffer msg) LikeNetSocket.upgradeToSsl(SSLOptions, String, Buffer)without indicating a server nameNetSocket.upgradeToSsl(SSLOptions sslOptions, String serverName) LikeNetSocket.upgradeToSsl(SSLOptions, String, Buffer)without an upgrade message.NetSocket.upgradeToSsl(SSLOptions sslOptions, String serverName, Buffer upgrade) Upgrade the channel to use SSL/TLS, in other words proceeds to the TLS handshake.NetSocket.upgradeToSsl(String serverName) LikeNetSocket.upgradeToSsl(SSLOptions, String, Buffer)with the default SSL options and without an update message.NetSocket.upgradeToSsl(String serverName, Buffer msg) LikeNetSocket.upgradeToSsl(SSLOptions, String, Buffer)with the default SSL options.Write aStringto the connection, encoded in UTF-8.Write aStringto the connection, encoded using the encodingenc.Write aStringto the connection, encoded in UTF-8.Write aStringto the connection, encoded using the encodingenc.QuicConnection.writeDatagram(Buffer buffer) Send a datagram. -
Uses of Future in io.vertx.core.net.endpoint
Methods in io.vertx.core.net.endpoint that return FutureModifier and TypeMethodDescriptionEndpointResolver.resolveEndpoint(Address address) Resolver an endpoint for the specifiedaddress -
Uses of Future in io.vertx.core.spi.dns
Methods in io.vertx.core.spi.dns that return Future -
Uses of Future in io.vertx.core.spi.endpoint
Methods in io.vertx.core.spi.endpoint that return Future -
Uses of Future in io.vertx.core.streams
Methods in io.vertx.core.streams that return FutureModifier and TypeMethodDescriptiondefault <R,A> Future <R> Apply acollectorto this stream, the obtained result is returned as a future.WriteStream.end()Ends the stream.Same asWriteStream.end()but writes some data to the stream before ending.ReadStream.pipeTo(WriteStream<T> dst) Pipe thisReadStreamto theWriteStream.Pipe.to(WriteStream<T> dst) Start to pipe the elements to the destinationWriteStream.Write some data to the stream. -
Uses of Future in io.vertx.db2client
Methods in io.vertx.db2client that return FutureModifier and TypeMethodDescriptionstatic Future<DB2Connection> DB2Connection.connect(Vertx vertx, DB2ConnectOptions connectOptions) Create a connection to DB2 server with the givenconnectOptions.static Future<DB2Connection> LikeDB2Connection.connect(Vertx, DB2ConnectOptions)with options build fromconnectionUri.DB2Connection.debug()Send a DEBUG command to dump debug information to the server's stdout.DB2Connection.ping()Send a PING command to check if the server is alive. -
Uses of Future in io.vertx.db2client.spi
Method parameters in io.vertx.db2client.spi with type arguments of type FutureModifier and TypeMethodDescriptionprotected PoolDB2Driver.newPool(io.vertx.core.internal.VertxInternal vertx, Handler<SqlConnection> connectHandler, Supplier<Future<DB2ConnectOptions>> databases, PoolOptions poolOptions, NetClientOptions transportOptions, io.vertx.core.internal.CloseFuture closeFuture) -
Uses of Future in io.vertx.ext.auth.authentication
Methods in io.vertx.ext.auth.authentication that return FutureModifier and TypeMethodDescriptionAuthenticationProvider.authenticate(Credentials credentials) Authenticate a user. -
Uses of Future in io.vertx.ext.auth.authorization
Methods in io.vertx.ext.auth.authorization that return FutureModifier and TypeMethodDescriptionAuthorizationProvider.getAuthorizations(User user) Updates the user with the set of authorizations. -
Uses of Future in io.vertx.ext.auth.mongo
Methods in io.vertx.ext.auth.mongo that return FutureModifier and TypeMethodDescriptionMongoUserUtil.createHashedUser(String username, String hash) Insert a user into a database.MongoUserUtil.createUser(String username, String password) Insert a user into a database.MongoUserUtil.createUserRolesAndPermissions(String user, List<String> roles, List<String> permissions) Insert a user role into a database. -
Uses of Future in io.vertx.ext.auth.oauth2
Methods in io.vertx.ext.auth.oauth2 that return FutureModifier and TypeMethodDescriptionOAuth2Auth.jWKSet()Retrieve the public server JSON Web Key (JWK) required to verify the authenticity of issued ID and access tokens.Refresh the current User (access token).Revoke an obtained access token.Revoke an obtained access or refresh token.Retrieve profile information and other attributes for a logged-in end-user. -
Uses of Future in io.vertx.ext.auth.oauth2.providers
Methods in io.vertx.ext.auth.oauth2.providers that return FutureModifier and TypeMethodDescriptionstatic Future<OAuth2Auth> AmazonCognitoAuth.discover(Vertx vertx, OAuth2Options config) Create a OAuth2Auth provider for OpenID Connect Discovery.static Future<OAuth2Auth> AppleIdAuth.discover(Vertx vertx, PubSecKeyOptions privateKey, OAuth2Options config) Create a OAuth2Auth provider for OpenID Connect Discovery.static Future<OAuth2Auth> AzureADAuth.discover(Vertx vertx, OAuth2Options config) Create a OAuth2Auth provider for OpenID Connect Discovery.static Future<OAuth2Auth> GoogleAuth.discover(Vertx vertx, OAuth2Options config) Create a OAuth2Auth provider for OpenID Connect Discovery.static Future<OAuth2Auth> IBMCloudAuth.discover(Vertx vertx, OAuth2Options config) Create a OAuth2Auth provider for OpenID Connect Discovery.static Future<OAuth2Auth> KeycloakAuth.discover(Vertx vertx, OAuth2Options config) Create a OAuth2Auth provider for OpenID Connect Discovery.static Future<OAuth2Auth> OpenIDConnectAuth.discover(Vertx vertx, OAuth2Options config) Create a OAuth2Auth provider for OpenID Connect Discovery.static Future<OAuth2Auth> SalesforceAuth.discover(Vertx vertx, OAuth2Options config) Create a OAuth2Auth provider for OpenID Connect Discovery.static Future<OAuth2Auth> ZohoAuth.discover(Vertx vertx, String soid, OAuth2Options config) Create a OAuth2Auth provider for OpenID Connect Discovery.static Future<OAuth2Auth> ZohoAuth.discover(Vertx vertx, String dc, String soid, OAuth2Options config) Create a OAuth2Auth provider for OpenID Connect Discovery. -
Uses of Future in io.vertx.ext.auth.otp.hotp
Methods in io.vertx.ext.auth.otp.hotp that return FutureModifier and TypeMethodDescriptionHotpAuth.createAuthenticator(String id, OtpKey otpKey) Creating authenticator from user id and key.Method parameters in io.vertx.ext.auth.otp.hotp with type arguments of type FutureModifier and TypeMethodDescriptionHotpAuth.authenticatorFetcher(Function<String, Future<Authenticator>> fetcher) HotpAuth.authenticatorUpdater(Function<Authenticator, Future<Void>> updater) Provide aFunctionthat can update or insert aAuthenticator. -
Uses of Future in io.vertx.ext.auth.otp.totp
Methods in io.vertx.ext.auth.otp.totp that return FutureModifier and TypeMethodDescriptionTotpAuth.createAuthenticator(String id, OtpKey otpKey) Creating authenticator from user id and key.Method parameters in io.vertx.ext.auth.otp.totp with type arguments of type FutureModifier and TypeMethodDescriptionTotpAuth.authenticatorFetcher(Function<String, Future<Authenticator>> fetcher) TotpAuth.authenticatorUpdater(Function<Authenticator, Future<Void>> updater) Provide aFunctionthat can update or insert aAuthenticator. -
Uses of Future in io.vertx.ext.auth.sqlclient
Methods in io.vertx.ext.auth.sqlclient that return FutureModifier and TypeMethodDescriptionSqlUserUtil.createHashedUser(String username, String hash) Insert a user into a database.SqlUserUtil.createRolePermission(String role, String permission) Insert a role permission into a database.SqlUserUtil.createUser(String username, String password) Insert a user into a database.SqlUserUtil.createUserRole(String username, String role) Insert a user role into a database. -
Uses of Future in io.vertx.ext.auth.webauthn4j
Methods in io.vertx.ext.auth.webauthn4j that return FutureModifier and TypeMethodDescriptionWebAuthn4J.createCredentialsOptions(JsonObject user) Gets a challenge and any other parameters for thenavigator.credentials.create()call.Finds an existing list of credentials for a given user name and credential ID.WebAuthn4J.getCredentialsOptions(String username) Creates an assertion challenge and any other parameters for thenavigator.credentials.get()call.CredentialStorage.storeCredential(Authenticator authenticator) Persists a new credential, bound by its user name (may benull) and credential ID (cannot benull, must be unique).CredentialStorage.updateCounter(Authenticator authenticator) Updates a previously stored credential counter, as identified by its user name (may benull) and credential ID (cannot benull, must be unique). -
Uses of Future in io.vertx.ext.consul
Methods in io.vertx.ext.consul that return FutureModifier and TypeMethodDescriptionConsulClient.agentInfo()Returns the configuration and member information of the local agentConsulClient.catalogDatacenters()Return all the datacenters that are known by the Consul serverConsulClient.catalogNodes()Returns the nodes registered in a datacenterConsulClient.catalogNodeServices(String node) Returns the node's registered servicesConsulClient.catalogNodeServicesWithOptions(String node, BlockingQueryOptions options) Returns the node's registered services This is blocking query unlikeConsulClient.catalogNodeServices(String)ConsulClient.catalogNodesWithOptions(NodeQueryOptions options) Returns the nodes registered in a datacenterConsulClient.catalogServiceNodes(String service) Returns the nodes providing a serviceConsulClient.catalogServiceNodesWithOptions(String service, ServiceQueryOptions options) Returns the nodes providing a serviceConsulClient.catalogServices()Returns the services registered in a datacenterConsulClient.catalogServicesWithOptions(BlockingQueryOptions options) Returns the services registered in a datacenter This is blocking query unlikeConsulClient.catalogServices()ConsulClient.cloneAclToken(String accessorId, CloneAclTokenOptions cloneAclTokenOptions) Clones an existing ACL tokenConsulClient.coordinateDatacenters()Returns the WAN network coordinates for all Consul servers, organized by DCsConsulClient.coordinateNodes()Returns the LAN network coordinates for all nodes in a given DCConsulClient.coordinateNodesWithOptions(BlockingQueryOptions options) Returns the LAN network coordinates for all nodes in a given DC This is blocking query unlikeConsulClient.coordinateNodes()ConsulClient.createAclPolicy(AclPolicy policy) Creates a new ACL policyConsulClient.createAclToken(AclToken token) Create an Acl tokenConsulClient.createPreparedQuery(PreparedQueryDefinition definition) ConsulClient.createSession()Initialize a new sessionConsulClient.createSessionWithOptions(SessionOptions options) Initialize a new sessionConsulClient.deleteAclToken(String accessorId) Deletes an ACL tokenConsulClient.deletePolicy(String id) This endpoint deletes an ACL policyConsulClient.deletePreparedQuery(String id) Deletes an existing prepared queryConsulClient.deleteValue(String key) Remove the key/value pair that corresponding to the specified keyConsulClient.deleteValues(String keyPrefix) Removes all the key/value pair that corresponding to the specified key prefixConsulClient.deregisterCatalogService(String nodeId, String serviceId) Deregister entities from the node or deregister the node itself.ConsulClient.deregisterCheck(String checkId) Remove a check from the local agent.ConsulClient.deregisterService(String id) Remove a service from the local agent.ConsulClient.destroySession(String id) Destroys the given sessionConsulClient.executePreparedQuery(String query) Executes an existing prepared query.ConsulClient.executePreparedQueryWithOptions(String query, PreparedQueryExecuteOptions options) Executes an existing prepared query.Set status of the check to "critical".ConsulClient.failCheckWithNote(String checkId, String note) Set status of the check to "critical".Fires a new user eventConsulClient.fireEventWithOptions(String name, EventOptions options) Fires a new user eventConsulClient.getAclPolicies()This endpoint lists all the ACL policies.ConsulClient.getAclTokens()Get list of Acl tokenConsulClient.getAllPreparedQueries()Returns a list of all prepared queries.Returns the list of keys that corresponding to the specified key prefix.ConsulClient.getKeysWithOptions(String keyPrefix, BlockingQueryOptions options) Returns the list of keys that corresponding to the specified key prefix.ConsulClient.getPreparedQuery(String id) Returns an existing prepared queryReturns key/value pair that corresponding to the specified key.Returns the list of key/value pairs that corresponding to the specified key prefix.ConsulClient.getValuesWithOptions(String keyPrefix, BlockingQueryOptions options) Returns the list of key/value pairs that corresponding to the specified key prefix.ConsulClient.getValueWithOptions(String key, BlockingQueryOptions options) Returns key/value pair that corresponding to the specified key.ConsulClient.healthChecks(String service) Returns the checks associated with the serviceConsulClient.healthChecksWithOptions(String service, CheckQueryOptions options) Returns the checks associated with the serviceConsulClient.healthNodesWithOptions(String node, CheckQueryOptions options) Returns the checks specific to the node provided on the path.ConsulClient.healthServiceNodes(String service, boolean passing) Returns the nodes providing the service.ConsulClient.healthServiceNodesWithOptions(String service, boolean passing, ServiceQueryOptions options) Returns the nodes providing the service.ConsulClient.healthState(HealthState healthState) Returns the checks in the specified statusConsulClient.healthStateWithOptions(HealthState healthState, CheckQueryOptions options) Returns the checks in the specified statusConsulClient.infoSession(String id) Returns the requested session informationConsulClient.infoSessionWithOptions(String id, BlockingQueryOptions options) Returns the requested session information This is blocking query unlikeConsulClient.infoSession(String)ConsulClient.leaderStatus()Get the Raft leader for the datacenter in which the agent is running.ConsulClient.listEvents()Returns the most recent events known by the agentConsulClient.listEventsWithOptions(EventListOptions options) Returns the most recent events known by the agent.ConsulClient.listNodeSessions(String nodeId) Returns the active sessions for a given nodeConsulClient.listNodeSessionsWithOptions(String nodeId, BlockingQueryOptions options) Returns the active sessions for a given node This is blocking query unlikeConsulClient.listNodeSessions(String)ConsulClient.listSessions()Returns the active sessionsConsulClient.listSessionsWithOptions(BlockingQueryOptions options) Returns the active sessions This is blocking query unlikeConsulClient.listSessions()ConsulClient.localChecks()Return all the checks that are registered with the local agent.ConsulClient.localServices()Returns list of services registered with the local agent.ConsulClient.maintenanceService(MaintenanceOptions maintenanceOptions) Places a given service into "maintenance mode"Set status of the check to "passing".ConsulClient.passCheckWithNote(String checkId, String note) Set status of the check to "passing".ConsulClient.peersStatus()Retrieves the Raft peers for the datacenter in which the the agent is running.Adds specified key/value pairConsulClient.putValueWithOptions(String key, String value, KeyValueOptions options) ConsulClient.readAclToken(String accessorId) Reads an ACL token with the given Accessor IDConsulClient.readPolicy(String id) This endpoint reads an ACL policy with the given IDConsulClient.readPolicyByName(String name) This endpoint reads an ACL policy with the given nameConsulClient.registerCatalogService(Node nodeOptions, ServiceOptions serviceOptions) Register node with external serviceConsulClient.registerCheck(CheckOptions checkOptions) Add a new check to the local agent.ConsulClient.registerService(ServiceOptions serviceOptions) Adds a new service, with an optional health check, to the local agent.ConsulClient.renewSession(String id) Renews the given session.ConsulClient.transaction(TxnRequest request) Manages multiple operations inside a single, atomic transaction.ConsulClient.updateAclToken(String accessorId, AclToken token) Update an existing Acl tokenConsulClient.updateCheck(String checkId, CheckStatus status) Set status of the check to given status.ConsulClient.updateCheckWithNote(String checkId, CheckStatus status, String note) Set status of the check to given status.ConsulClient.updatePolicy(String id, AclPolicy policy) This endpoint updates an existing ACL policyConsulClient.updatePreparedQuery(PreparedQueryDefinition definition) Set status of the check to "warning".ConsulClient.warnCheckWithNote(String checkId, String note) Set status of the check to "warning". -
Uses of Future in io.vertx.ext.eventbus.bridge.tcp
Methods in io.vertx.ext.eventbus.bridge.tcp that return FutureModifier and TypeMethodDescriptionTcpEventBusBridge.close()Close the current socket.TcpEventBusBridge.listen()Start listening on the port and host as configured in theNetServerOptionsused when creating the server.TcpEventBusBridge.listen(int port) Start listening on the specified port and host "0.0.0.0", ignoring port and host configured in theNetServerOptionsused when creating the server.Start listening on the specified port and host, ignoring port and host configured in theNetServerOptionsused when creating the server.default Future<TcpEventBusBridge> TcpEventBusBridge.listen(SocketAddress localAddress) Start listening on the specified local address, ignoring port and host configured in theNetServerOptionsused when creating the server. -
Uses of Future in io.vertx.ext.healthchecks
Methods in io.vertx.ext.healthchecks that return FutureModifier and TypeMethodDescriptionHealthChecks.checkStatus()Invokes the registered procedures.HealthChecks.checkStatus(String name) Invokes the registered procedure with the given name and sub-procedures.Invokes the registered procedure with the given name and sub-procedures.Methods in io.vertx.ext.healthchecks with parameters of type Future -
Uses of Future in io.vertx.ext.mail
Methods in io.vertx.ext.mail that return FutureModifier and TypeMethodDescriptionMailClient.close()Close the MailClientMailClient.sendMail(MailMessage email) send a single mail via MailClientMethod parameters in io.vertx.ext.mail with type arguments of type FutureModifier and TypeMethodDescriptionMailClientBuilder.withCredentialsSupplier(Supplier<Future<UsernamePasswordCredentials>> credentialsSupplier) Set a credentials supplier for the mail client. -
Uses of Future in io.vertx.ext.mongo
Methods in io.vertx.ext.mongo that return FutureModifier and TypeMethodDescriptionMongoClient.bulkWrite(String collection, List<BulkOperation> operations) Execute a bulk operation.MongoClient.bulkWriteWithOptions(String collection, List<BulkOperation> operations, BulkWriteOptions bulkWriteOptions) Execute a bulk operation with the specified write options.MongoClient.close()Close the client and release its resourcesMongoClient.count(String collection, JsonObject query) Count matching documents in a collection.MongoClient.countWithOptions(String collection, JsonObject query, CountOptions countOptions) Count matching documents in a collection.MongoClient.createCollection(String collectionName) Create a new collectionMongoClient.createCollectionWithOptions(String collectionName, CreateCollectionOptions collectionOptions) Create a new collection with optionsMongoClient.createDefaultGridFsBucketService()Creates aMongoGridFsClientused to interact with Mongo GridFS.MongoClient.createGridFsBucketService(String bucketName) Creates aMongoGridFsClientused to interact with Mongo GridFS.MongoClient.createIndex(String collection, JsonObject key) Creates an index.MongoClient.createIndexes(String collection, List<IndexModel> indexes) creates an indexesMongoClient.createIndexWithOptions(String collection, JsonObject key, IndexOptions options) Creates an index.Deletes a file by it's IDGets the distinct values of the specified field name.MongoClient.distinct(String collection, String fieldName, String resultClassname, DistinctOptions distinctOptions) Gets the distinct values of the specified field name.MongoClient.distinctWithQuery(String collection, String fieldName, String resultClassname, JsonObject query) Gets the distinct values of the specified field name filtered by specified query.MongoClient.distinctWithQuery(String collection, String fieldName, String resultClassname, JsonObject query, DistinctOptions distinctOptions) Gets the distinct values of the specified field name filtered by specified query.MongoGridFsClient.downloadByFileName(WriteStream<Buffer> stream, String fileName) MongoGridFsClient.downloadByFileNameWithOptions(WriteStream<Buffer> stream, String fileName, GridFsDownloadOptions options) MongoGridFsClient.downloadById(WriteStream<Buffer> stream, String id) MongoGridFsClient.downloadFile(String fileName) Downloads a file.MongoGridFsClient.downloadFileAs(String fileName, String newFileName) Downloads a file and gives it a new name.MongoGridFsClient.downloadFileByID(String id, String fileName) Downloads a file using the ID generated by GridFs.MongoGridFsClient.drop()Drops the entire file bucket with all of its contentsMongoClient.dropCollection(String collection) Drop a collectionMongoClient.dropIndex(String collection, JsonObject key) Drops the index given the keys used to create it.Drops the index given its name.MongoClient.find(String collection, JsonObject query) Find matching documents in the specified collectionMongoGridFsClient.findAllIds()Finds all file ids in the bucketMongoGridFsClient.findIds(JsonObject query) Finds all file ids that match a query.MongoClient.findOne(String collection, JsonObject query, JsonObject fields) Find a single matching document in the specified collectionMongoClient.findOneAndDelete(String collection, JsonObject query) Find a single matching document in the specified collection and delete it.MongoClient.findOneAndDeleteWithOptions(String collection, JsonObject query, FindOptions findOptions) Find a single matching document in the specified collection and delete it.MongoClient.findOneAndReplace(String collection, JsonObject query, JsonObject replace) Find a single matching document in the specified collection and replace it.MongoClient.findOneAndReplaceWithOptions(String collection, JsonObject query, JsonObject replace, FindOptions findOptions, UpdateOptions updateOptions) Find a single matching document in the specified collection and replace it.MongoClient.findOneAndUpdate(String collection, JsonObject query, JsonObject update) Find a single matching document in the specified collection and update it.MongoClient.findOneAndUpdateWithOptions(String collection, JsonObject query, JsonObject update, FindOptions findOptions, UpdateOptions updateOptions) Find a single matching document in the specified collection and update it.MongoClient.findWithOptions(String collection, JsonObject query, FindOptions options) Find matching documents in the specified collection, specifying optionsMongoClient.getCollections()Get a list of all collections in the database.MongoClient.insert(String collection, JsonObject document) Insert a document in the specified collectionMongoClient.insertWithOptions(String collection, JsonObject document, WriteOption writeOption) Insert a document in the specified collection with the specified write optionMongoClient.listIndexes(String collection) Get all the indexes in this collection.MongoClient.removeDocument(String collection, JsonObject query) Remove a single matching document from a collection and return the handler withMongoClientDeleteResultresultMongoClient.removeDocuments(String collection, JsonObject query) Remove matching documents from a collection and return the handler withMongoClientDeleteResultresultMongoClient.removeDocumentsWithOptions(String collection, JsonObject query, WriteOption writeOption) Remove matching documents from a collection with the specified write option and return the handler withMongoClientDeleteResultresultMongoClient.removeDocumentWithOptions(String collection, JsonObject query, WriteOption writeOption) Remove a single matching document from a collection with the specified write option and return the handler withMongoClientDeleteResultresultMongoClient.renameCollection(String oldCollectionName, String newCollectionName) Rename a collectionMongoClient.renameCollectionWithOptions(String oldCollectionName, String newCollectionName, RenameCollectionOptions collectionOptions) Rename a collectionMongoClient.replaceDocuments(String collection, JsonObject query, JsonObject replace) Replace matching documents in the specified collection and return the handler withMongoClientUpdateResultresultMongoClient.replaceDocumentsWithOptions(String collection, JsonObject query, JsonObject replace, UpdateOptions options) Replace matching documents in the specified collection, specifying options and return the handler withMongoClientUpdateResultresultMongoClient.runCommand(String commandName, JsonObject command) Run an arbitrary MongoDB command.MongoClient.save(String collection, JsonObject document) Save a document in the specified collectionMongoClient.saveWithOptions(String collection, JsonObject document, WriteOption writeOption) Save a document in the specified collection with the specified write optionMongoClient.updateCollection(String collection, JsonObject query, JsonArray update) Use an aggregation pipeline to update documents in the specified collection and return the handler withMongoClientUpdateResultresultMongoClient.updateCollection(String collection, JsonObject query, JsonObject update) Update matching documents in the specified collection and return the handler withMongoClientUpdateResultresultMongoClient.updateCollectionWithOptions(String collection, JsonObject query, JsonArray update, UpdateOptions options) Use an aggregation pipeline to update documents in the specified collection, specifying options and return the handler withMongoClientUpdateResultresultMongoClient.updateCollectionWithOptions(String collection, JsonObject query, JsonObject update, UpdateOptions options) Update matching documents in the specified collection, specifying options and return the handler withMongoClientUpdateResultresultMongoGridFsClient.uploadByFileName(ReadStream<Buffer> stream, String fileName) MongoGridFsClient.uploadByFileNameWithOptions(ReadStream<Buffer> stream, String fileName, GridFsUploadOptions options) MongoGridFsClient.uploadFile(String fileName) Upload a file to gridfsMongoGridFsClient.uploadFileWithOptions(String fileName, GridFsUploadOptions options) Upload a file to gridfs with options -
Uses of Future in io.vertx.ext.reactivestreams
Methods in io.vertx.ext.reactivestreams that return Future -
Uses of Future in io.vertx.ext.shell
Methods in io.vertx.ext.shell that return FutureModifier and TypeMethodDescriptionShellServer.close()Close the shell server, this is an asynchronous close.ShellServer.listen()Start the shell service, this is an asynchronous start.ShellService.start()Start the shell service, this is an asynchronous start.ShellService.stop()Stop the shell service, this is an asynchronous stop. -
Uses of Future in io.vertx.ext.shell.command
Methods in io.vertx.ext.shell.command that return FutureModifier and TypeMethodDescriptionCommandRegistry.registerCommand(Command command) Register a commandCommandRegistry.registerCommand(Class<? extends AnnotatedCommand> command) Register a single command.CommandRegistry.registerCommands(List<Command> commands) Register a list of commands.CommandRegistry.unregisterCommand(String commandName) Unregister a command. -
Uses of Future in io.vertx.ext.shell.term
Methods in io.vertx.ext.shell.term that return Future -
Uses of Future in io.vertx.ext.stomp
Methods in io.vertx.ext.stomp that return FutureModifier and TypeMethodDescriptionAborts a transaction.Aborts a transaction.Sends an acknowledgement for a specific message.Sends an acknowledgement for the given frame.Begins a transaction.Begins a transaction.StompClient.close()Closes the client.StompServer.close()Closes the server.Commits a transaction.Commits a transaction.StompClient.connect()Connects to the server using the host and port configured in the client's options.Connects to the server.StompClientConnection.disconnect()Disconnects the client.StompClientConnection.disconnect(Frame frame) Disconnects the client.StompServer.listen()Connects the STOMP server default port (61613) and network interface (0.0.0.0).StompServer.listen(int port) Connects the STOMP server to the given port.Connects the STOMP server to the given port / interface.Sends a non-acknowledgement for the given message.Sends a non-acknowledgement for the given frame.StompServerHandler.onAuthenticationRequest(StompServerConnection connection, String login, String passcode) Called when the client connects to a server requiring authentication.Sends the given frame to the server.Sends aSENDframe to the server to the given destination.Sends aSENDframe to the server to the given destination.Sends aSENDframe to the server.Subscribes to the given destination.StompClientConnection.subscribe(String destination, Map<String, String> headers, Handler<Frame> handler) Subscribes to the given destination.StompClientConnection.unsubscribe(String destination) Un-subscribes from the given destination.StompClientConnection.unsubscribe(String destination, Map<String, String> headers) Un-subscribes from the given destination. -
Uses of Future in io.vertx.ext.unit.junit
Constructors in io.vertx.ext.unit.junit with parameters of type FutureModifierConstructorDescriptionRunTestOnContext(Future<Vertx> createVertx) Create a new rule with an asynchronous supplier for creating a Vert.x instance.RunTestOnContext(Future<Vertx> createVertx, BiConsumer<Vertx, Consumer<Void>> closeVertx) Create a new rule with an asynchronous supplier and consumer for creating and closing a Vert.x instance. -
Uses of Future in io.vertx.ext.web
Methods in io.vertx.ext.web that return FutureModifier and TypeMethodDescriptionFileUpload.delete()Delete the uploaded file on the disk.RoutingContext.end()Shortcut to the response end.Shortcut to the response end.Shortcut to the response end.UserContext.impersonate()Impersonates a second identity.UserContext.impersonate(String redirectUri) Impersonates a second identity.Encode an Object to JSON and end the request.UserContext.logout()Logout can be called from any route handler which needs to terminate a login session.Logout can be called from any route handler which needs to terminate a login session.Perform a 302 redirect tourl.UserContext.refresh()Forces the current user to re-authenticate.Forces the current user to re-authenticate.UserContext.restore()Undo a previous call to a impersonation.Undo a previous call to an impersonation.Method parameters in io.vertx.ext.web with type arguments of type FutureModifier and TypeMethodDescriptiondefault <T> RouteRoute.respond(Function<RoutingContext, Future<T>> function) Append a function request handler to the route handlers list. -
Uses of Future in io.vertx.ext.web.client
Methods in io.vertx.ext.web.client that return FutureModifier and TypeMethodDescriptionHttpRequest.send()Send a request, thehandlerwill receive the response as anHttpResponse.HttpRequest.sendBuffer(Buffer body) LikeHttpRequest.send()but with an HTTP requestbodybuffer.LikeHttpRequest.send()but with an HTTP requestbodymultimap encoded as form and the content type set toapplication/x-www-form-urlencoded.LikeHttpRequest.send()but with an HTTP requestbodymultimap encoded as form and the content type set toapplication/x-www-form-urlencoded.LikeHttpRequest.send()but with an HTTP requestbodyobject encoded as json and the content type set toapplication/json.HttpRequest.sendJsonObject(JsonObject body) LikeHttpRequest.send()but with an HTTP requestbodyobject encoded as json and the content type set toapplication/json.HttpRequest.sendMultipartForm(MultipartForm body) LikeHttpRequest.send()but with an HTTP requestbodymultimap encoded as form and the content type set tomultipart/form-data.HttpRequest.sendStream(ReadStream<Buffer> body) LikeHttpRequest.send()but with an HTTP requestbodystream.WebClient.updateSSLOptions(ClientSSLOptions options) Update the client with new SSLoptions, the update happens if the options object is valid and different from the existing options object.WebClient.updateSSLOptions(ClientSSLOptions options, boolean force) Update the client with new SSLoptions, the update happens if the options object is valid and different from the existing options object. -
Uses of Future in io.vertx.ext.web.client.spi
Methods in io.vertx.ext.web.client.spi that return FutureModifier and TypeMethodDescriptionCacheStore.delete(io.vertx.ext.web.client.impl.cache.CacheKey key) Delete a key from the cache.CacheStore.flush()Delete all entries from the cache.Future<io.vertx.ext.web.client.impl.cache.CachedHttpResponse> CacheStore.get(io.vertx.ext.web.client.impl.cache.CacheKey key) Retrieve a cached response.Future<io.vertx.ext.web.client.impl.cache.CachedHttpResponse> CacheStore.set(io.vertx.ext.web.client.impl.cache.CacheKey key, io.vertx.ext.web.client.impl.cache.CachedHttpResponse response) Add a response in the cache with the given key. -
Uses of Future in io.vertx.ext.web.codec.spi
Methods in io.vertx.ext.web.codec.spi that return Future -
Uses of Future in io.vertx.ext.web.common.template
Methods in io.vertx.ext.web.common.template that return Future -
Uses of Future in io.vertx.ext.web.handler
Methods in io.vertx.ext.web.handler that return FutureModifier and TypeMethodDescriptionSessionHandler.flush(RoutingContext ctx) Flush a context session earlier to the store, this will allow the end user to have full control on the event of a failure at the store level.SessionHandler.flush(RoutingContext ctx, boolean ignoreStatus) Flush a context session earlier to the store, this will allow the end user to have full control on the event of a failure at the store level.SessionHandler.setUser(RoutingContext context, User user) Set the user for the sessionMethod parameters in io.vertx.ext.web.handler with type arguments of type FutureModifier and TypeMethodDescriptionSimpleAuthenticationHandler.authenticate(Function<RoutingContext, Future<User>> authenticationFunction) This function will allow you to perform authentication the way you intended to.APIKeyHandler.tokenExtractor(Function<String, Future<String>> tokenExtractor) Transform from user's token format to the AuthenticationHandler's format. -
Uses of Future in io.vertx.ext.web.handler.sockjs
Methods in io.vertx.ext.web.handler.sockjs that return Future -
Uses of Future in io.vertx.ext.web.healthchecks
Method parameters in io.vertx.ext.web.healthchecks with type arguments of type FutureModifier and TypeMethodDescriptionHealthCheckHandler.resultMapper(Function<CheckResult, Future<CheckResult>> resultMapper) Sets a function which will be invoked before theCheckResultgets written to clients. -
Uses of Future in io.vertx.ext.web.openapi.router
Methods in io.vertx.ext.web.openapi.router that return FutureModifier and TypeMethodDescriptionRequestExtractor.extractValidatableRequest(RoutingContext routingContext, Operation operation) Extracts and transforms the parameters and the body of an incoming request into aformatthat can be validated by theRequestValidator.Security.openIdConnectHandler(String callback, Function<String, Future<OAuth2AuthHandler>> factory) Configure theOAuth2AuthHandlerto be used when creating the router.default Future<RouterBuilder> Security.openIdConnectHandler(Function<String, Future<OAuth2AuthHandler>> factory) Configure theOAuth2AuthHandlerto be used when creating the router.Method parameters in io.vertx.ext.web.openapi.router with type arguments of type FutureModifier and TypeMethodDescriptionSecurity.openIdConnectHandler(String callback, Function<String, Future<OAuth2AuthHandler>> factory) Configure theOAuth2AuthHandlerto be used when creating the router.default Future<RouterBuilder> Security.openIdConnectHandler(Function<String, Future<OAuth2AuthHandler>> factory) Configure theOAuth2AuthHandlerto be used when creating the router. -
Uses of Future in io.vertx.ext.web.sstore
Methods in io.vertx.ext.web.sstore that return Future -
Uses of Future in io.vertx.grpc.client
Methods in io.vertx.grpc.client that return FutureModifier and TypeMethodDescriptionGrpcClient.close()Close this client.<Req,Resp> Future <GrpcClientRequest<Req, Resp>> ServiceInvoker.invoker(ServiceMethod<Resp, Req> method) Create a request for the given service method.GrpcClient.request()LikeGrpcClient.request(Address)with the default remote server.Connect to the remoteserverand create a request for any hosted gRPC service.<Req,Resp> Future <GrpcClientRequest<Req, Resp>> GrpcClient.request(Address server, ServiceMethod<Resp, Req> method) Connect to the remoteserverand create a request for any hosted gRPC service.<Req,Resp> Future <GrpcClientRequest<Req, Resp>> GrpcClient.request(ServiceMethod<Resp, Req> method) LikeGrpcClient.request(Address, ServiceMethod)with the default remote server.GrpcClientRequest.response()default Future<GrpcClientResponse<Req, Resp>> GrpcClientRequest.send(ReadStream<Req> body) default Future<GrpcClientResponse<Req, Resp>> -
Uses of Future in io.vertx.grpc.common
Methods in io.vertx.grpc.common that return FutureModifier and TypeMethodDescriptionGrpcReadStream.end()GrpcWriteStream.endMessage(GrpcMessage message) End the stream with an encoded gRPC message.GrpcReadStream.last()GrpcWriteStream.writeMessage(GrpcMessage message) Write an encoded gRPC message. -
Uses of Future in io.vertx.grpc.event.v1alpha
Methods in io.vertx.grpc.event.v1alpha that return FutureModifier and TypeMethodDescriptionFuture<com.google.protobuf.Empty> EventBusBridge.ping(com.google.protobuf.Empty request) Future<com.google.protobuf.Empty> EventBusBridgeClient.ping(com.google.protobuf.Empty request) Calls the Ping RPC service method.Future<com.google.protobuf.Empty> EventBusBridgeService.ping(com.google.protobuf.Empty request) Override this method to implement the Ping RPC.Future<com.google.protobuf.Empty> Future<com.google.protobuf.Empty> Calls the Publish RPC service method.Future<com.google.protobuf.Empty> Override this method to implement the Publish RPC.Calls the Request RPC service method.Override this method to implement the Request RPC.Future<com.google.protobuf.Empty> Future<com.google.protobuf.Empty> Calls the Send RPC service method.Future<com.google.protobuf.Empty> Override this method to implement the Send RPC.EventBusBridge.subscribe(SubscribeOp request) EventBusBridgeClient.subscribe(SubscribeOp request) Calls the Subscribe RPC service method.EventBusBridgeService.subscribe(SubscribeOp request) Override this method to implement the Subscribe RPC.Future<com.google.protobuf.Empty> EventBusBridge.unsubscribe(UnsubscribeOp request) Future<com.google.protobuf.Empty> EventBusBridgeClient.unsubscribe(UnsubscribeOp request) Calls the Unsubscribe RPC service method.Future<com.google.protobuf.Empty> EventBusBridgeService.unsubscribe(UnsubscribeOp request) Override this method to implement the Unsubscribe RPC. -
Uses of Future in io.vertx.grpc.server
Methods in io.vertx.grpc.server that return Future -
Uses of Future in io.vertx.grpc.stub
Methods in io.vertx.grpc.stub that return FutureModifier and TypeMethodDescriptionGrpcWriteStream.end()Deprecated.static <I,O> Future <O> ClientCalls.manyToOne(io.vertx.core.internal.ContextInternal ctx, Handler<WriteStream<I>> requestHandler, Function<StreamObserver<O>, StreamObserver<I>> delegate) Deprecated.static <I,O> Future <O> ClientCalls.oneToOne(io.vertx.core.internal.ContextInternal ctx, I request, BiConsumer<I, StreamObserver<O>> delegate) Deprecated.Deprecated.Method parameters in io.vertx.grpc.stub with type arguments of type FutureModifier and TypeMethodDescriptionstatic <I,O> StreamObserver <I> ServerCalls.manyToOne(StreamObserver<O> response, String compression, Function<ReadStream<I>, Future<O>> delegate) Deprecated, for removal: This API element is subject to removal in a future version.static <I,O> void ServerCalls.oneToOne(I request, StreamObserver<O> response, String compression, Function<I, Future<O>> delegate) Deprecated, for removal: This API element is subject to removal in a future version. -
Uses of Future in io.vertx.grpcio.client
Methods in io.vertx.grpcio.client that return FutureModifier and TypeMethodDescriptiondefault <Req,Resp, T>
Future<T> GrpcIoClient.call(MethodDescriptor<Req, Resp> service, Handler<GrpcClientRequest<Req, Resp>> requestHandler, Function<GrpcClientResponse<Req, Resp>, Future<T>> resultFn) LikeGrpcIoClient.call(Address, MethodDescriptor, Handler, Function)with the default remote server.default <Req,Resp, T>
Future<T> GrpcIoClient.call(Address server, MethodDescriptor<Req, Resp> service, Handler<GrpcClientRequest<Req, Resp>> requestHandler, Function<GrpcClientResponse<Req, Resp>, Future<T>> resultFn) Call theservicegRPC service hosted byserver.<Req,Resp> Future <GrpcClientRequest<Req, Resp>> GrpcIoClient.request(MethodDescriptor<Req, Resp> service) LikeGrpcIoClient.request(Address, MethodDescriptor)with the default remote server.<Req,Resp> Future <GrpcClientRequest<Req, Resp>> GrpcIoClient.request(Address server, MethodDescriptor<Req, Resp> service) Connect to the remoteserverand create a request for givenmethodof a hosted gRPC service.Method parameters in io.vertx.grpcio.client with type arguments of type FutureModifier and TypeMethodDescriptiondefault <Req,Resp, T>
Future<T> GrpcIoClient.call(MethodDescriptor<Req, Resp> service, Handler<GrpcClientRequest<Req, Resp>> requestHandler, Function<GrpcClientResponse<Req, Resp>, Future<T>> resultFn) LikeGrpcIoClient.call(Address, MethodDescriptor, Handler, Function)with the default remote server.default <Req,Resp, T>
Future<T> GrpcIoClient.call(Address server, MethodDescriptor<Req, Resp> service, Handler<GrpcClientRequest<Req, Resp>> requestHandler, Function<GrpcClientResponse<Req, Resp>, Future<T>> resultFn) Call theservicegRPC service hosted byserver. -
Uses of Future in io.vertx.httpproxy
Methods in io.vertx.httpproxy that return FutureModifier and TypeMethodDescriptionOriginRequestProvider.create(ProxyContext proxyContext) Create theHttpClientRequestto the origin server for a givenProxyContext.default Future<ProxyResponse> ProxyInterceptor.handleProxyRequest(ProxyContext context) Handle the proxy request at the stage of this interceptor.ProxyInterceptor.handleProxyResponse(ProxyContext context) Handle the proxy response at the stage of this interceptor.ProxyRequest.proxy(HttpClientRequest request) Proxy this request to the origin server using the specifiedrequestand then send the proxy response.ProxyRequest.send(HttpClientRequest request) Send this request to the origin server using the specifiedrequest.ProxyResponse.send()Send the proxies response to the user agent.ProxyContext.sendRequest()ProxyContext.sendResponse()Return the future body, transformed.Method parameters in io.vertx.httpproxy with type arguments of type FutureModifier and TypeMethodDescriptionstatic OriginRequestProviderOriginRequestProvider.selector(Function<ProxyContext, Future<SocketAddress>> selector) Creates a provider that selects the origin server based onProxyContext. -
Uses of Future in io.vertx.httpproxy.spi.cache
Methods in io.vertx.httpproxy.spi.cache that return FutureModifier and TypeMethodDescriptionBeing called when the proxy attempts to fetch a cache item.Being called when the proxy attempts to add a new cache item.Being called when the proxy attempts to delete a cache item, typically caused by invalidating an existing item. -
Uses of Future in io.vertx.jdbcclient
Methods in io.vertx.jdbcclient that return FutureModifier and TypeMethodDescriptionJDBCConnection.getTransactionIsolation()JDBCConnection.setTransactionIsolation(int isolationLevel) -
Uses of Future in io.vertx.junit5
Methods in io.vertx.junit5 that return FutureModifier and TypeMethodDescription<T> Future<T> VertxTestContext.assertComplete(Future<T> fut) This method allows you to check if a future is completed.<T> Future<T> VertxTestContext.assertFailure(Future<T> fut) This method allows you to check if a future is failed.Methods in io.vertx.junit5 with parameters of type FutureModifier and TypeMethodDescription<T> Future<T> VertxTestContext.assertComplete(Future<T> fut) This method allows you to check if a future is completed.<T> Future<T> VertxTestContext.assertFailure(Future<T> fut) This method allows you to check if a future is failed.Constructor parameters in io.vertx.junit5 with type arguments of type FutureModifierConstructorDescriptionRunTestOnContext(Supplier<Future<Vertx>> supplier) Create an instance of this extension that gets aVertxobject using the specified asynchronoussupplier.Create an instance of this extension that gets aVertxobject using the specified asynchronoussupplier.Create an instance of this extension that gets aVertxobject using the specified asynchronoussupplier. -
Uses of Future in io.vertx.kafka.admin
Methods in io.vertx.kafka.admin that return FutureModifier and TypeMethodDescriptionKafkaAdminClient.alterConfigs(Map<ConfigResource, Config> configs) Update the configuration for the specified resources with the default optionsKafkaAdminClient.alterConsumerGroupOffsets(String groupId, Map<TopicPartition, OffsetAndMetadata> offsets) Alter committed offsets for a set of partitions in a consumer group.KafkaAdminClient.close()Close the admin clientKafkaAdminClient.close(long timeout) Close the admin clientKafkaAdminClient.createAcls(List<org.apache.kafka.common.acl.AclBinding> aclBindings) Create the ACL rules.KafkaAdminClient.createPartitions(Map<String, NewPartitions> partitions) Creates a batch of new partitions in the Kafka topicKafkaAdminClient.createTopics(List<NewTopic> topics) Creates a batch of new Kafka topicsKafkaAdminClient.deleteAcls(List<org.apache.kafka.common.acl.AclBindingFilter> aclBindings) Delete the ACL rules.KafkaAdminClient.deleteConsumerGroupOffsets(String groupId, Set<TopicPartition> partitions) Delete committed offsets for a set of partitions in a consumer group.KafkaAdminClient.deleteConsumerGroups(List<String> groupIds) Delete consumer groups from the cluster.Future<Map<TopicPartition, org.apache.kafka.clients.admin.DeletedRecords>> KafkaAdminClient.deleteRecords(Map<TopicPartition, org.apache.kafka.clients.admin.RecordsToDelete> recordsToDelete) Delete records from a topic partition.KafkaAdminClient.deleteTopics(List<String> topicNames) Deletes a batch of Kafka topicsKafkaAdminClient.describeAcls(org.apache.kafka.common.acl.AclBindingFilter aclBindingFilter) Describe the ACL rules.KafkaAdminClient.describeCluster()Describe the nodes in the cluster with the default optionsKafkaAdminClient.describeCluster(DescribeClusterOptions options) LikeKafkaAdminClient.describeCluster()but allows customized options.KafkaAdminClient.describeConfigs(List<ConfigResource> configResources) Get the configuration for the specified resources with the default optionsKafkaAdminClient.describeConsumerGroups(List<String> groupIds) Describe some group ids in the cluster, with the default optionsKafkaAdminClient.describeConsumerGroups(List<String> groupIds, DescribeConsumerGroupsOptions options) LikeKafkaAdminClient.describeConsumerGroups(List)but allows customized optionsKafkaAdminClient.describeLogDirs(List<Integer> brokers) Query the information of all log directories on the given set of brokersKafkaAdminClient.describeTopics(List<String> topicNames) Describe some topics in the cluster, with the default options.KafkaAdminClient.describeTopics(List<String> topicNames, DescribeTopicsOptions options) LikeKafkaAdminClient.describeTopics(List)but allows for customised otionsdefault Future<Map<TopicPartition, OffsetAndMetadata>> KafkaAdminClient.listConsumerGroupOffsets(String groupId) List the consumer group offsets available in the cluster.KafkaAdminClient.listConsumerGroupOffsets(String groupId, ListConsumerGroupOffsetsSpec spec, ListConsumerGroupOffsetsOptions options) List the consumer group offsets available in the cluster.KafkaAdminClient.listConsumerGroups()Get the the consumer groups available in the cluster with the default optionsKafkaAdminClient.listOffsets(Map<TopicPartition, OffsetSpec> topicPartitionOffsets) List the offsets available for a set of partitions.KafkaAdminClient.listTopics()List the topics available in the cluster with the default options. -
Uses of Future in io.vertx.kafka.client.consumer
Methods in io.vertx.kafka.client.consumer that return FutureModifier and TypeMethodDescriptionKafkaConsumer.assign(TopicPartition topicPartition) Manually assign a partition to this consumer.KafkaConsumer.assign(Set<TopicPartition> topicPartitions) Manually assign a list of partition to this consumer.Manually assign a set of partitions to this consumer.KafkaConsumer.assignment()Get the set of partitions currently assigned to this consumer.KafkaReadStream.assignment()Get the set of partitions currently assigned to this consumer.KafkaConsumer.beginningOffsets(TopicPartition topicPartition) Get the first offset for the given partitions.KafkaConsumer.beginningOffsets(Set<TopicPartition> topicPartitions) Get the first offset for the given partitions.KafkaReadStream.beginningOffsets(Set<org.apache.kafka.common.TopicPartition> topicPartitions) Get the first offset for the given partitions.KafkaReadStream.beginningOffsets(org.apache.kafka.common.TopicPartition topicPartition) Get the first offset for the given partition.KafkaConsumer.close()Close the consumerKafkaReadStream.close()Close the streamKafkaConsumer.commit()Commit current offsets for all the subscribed list of topics and partition.KafkaConsumer.commit(Map<TopicPartition, OffsetAndMetadata> offsets) Commit the specified offsets for the specified list of topics and partitions to Kafka.Future<Map<org.apache.kafka.common.TopicPartition, org.apache.kafka.clients.consumer.OffsetAndMetadata>> KafkaReadStream.commit()Commit current offsets for all the subscribed list of topics and partition.Future<Map<org.apache.kafka.common.TopicPartition, org.apache.kafka.clients.consumer.OffsetAndMetadata>> KafkaReadStream.commit(Map<org.apache.kafka.common.TopicPartition, org.apache.kafka.clients.consumer.OffsetAndMetadata> offsets) Commit the specified offsets for the specified list of topics and partitions to Kafka.KafkaConsumer.committed(TopicPartition topicPartition) Get the last committed offset for the given partition (whether the commit happened by this process or another).Future<org.apache.kafka.clients.consumer.OffsetAndMetadata> KafkaReadStream.committed(org.apache.kafka.common.TopicPartition topicPartition) Get the last committed offset for the given partition (whether the commit happened by this process or another).KafkaConsumer.endOffsets(TopicPartition topicPartition) Get the last offset for the given partition.KafkaConsumer.endOffsets(Set<TopicPartition> topicPartitions) Get the last offset for the given partitions.KafkaReadStream.endOffsets(Set<org.apache.kafka.common.TopicPartition> topicPartitions) Get the last offset for the given partitions.KafkaReadStream.endOffsets(org.apache.kafka.common.TopicPartition topicPartition) Get the last offset for the given partition.Future<Map<String, List<PartitionInfo>>> KafkaConsumer.listTopics()Get metadata about partitions for all topics that the user is authorized to view.KafkaReadStream.listTopics()Get metadata about partitions for all topics that the user is authorized to view.KafkaConsumer.offsetsForTimes(TopicPartition topicPartition, Long timestamp) Look up the offset for the given partition by timestamp.KafkaConsumer.offsetsForTimes(Map<TopicPartition, Long> topicPartitionTimestamps) Look up the offsets for the given partitions by timestamp.Future<Map<org.apache.kafka.common.TopicPartition, org.apache.kafka.clients.consumer.OffsetAndTimestamp>> KafkaReadStream.offsetsForTimes(Map<org.apache.kafka.common.TopicPartition, Long> topicPartitionTimestamps) Look up the offsets for the given partitions by timestamp.Future<org.apache.kafka.clients.consumer.OffsetAndTimestamp> KafkaReadStream.offsetsForTimes(org.apache.kafka.common.TopicPartition topicPartition, long timestamp) * Look up the offset for the given partition by timestamp.KafkaConsumer.partitionsFor(String topic) Get metadata about the partitions for a given topic.KafkaReadStream.partitionsFor(String topic) Get metadata about the partitions for a given topic.KafkaConsumer.pause(TopicPartition topicPartition) Suspend fetching from the requested partition.KafkaConsumer.pause(Set<TopicPartition> topicPartitions) Suspend fetching from the requested partitions.Suspend fetching from the requested partitions.KafkaConsumer.paused()Get the set of partitions that were previously paused by a call to pause(Set).KafkaReadStream.paused()Get the set of partitions that were previously paused by a call toKafkaReadStream.pause(Set).Executes a poll for getting messages from Kafka.Executes a poll for getting messages from Kafka.KafkaConsumer.position(TopicPartition partition) Get the offset of the next record that will be fetched (if a record with that offset exists).KafkaReadStream.position(org.apache.kafka.common.TopicPartition partition) Get the offset of the next record that will be fetched (if a record with that offset exists).KafkaConsumer.resume(TopicPartition topicPartition) Resume specified partition which have been paused with pause.KafkaConsumer.resume(Set<TopicPartition> topicPartitions) Resume specified partitions which have been paused with pause.Resume specified partitions which have been paused with pause.KafkaConsumer.seek(TopicPartition topicPartition, long offset) Overrides the fetch offsets that the consumer will use on the next poll.KafkaConsumer.seek(TopicPartition topicPartition, OffsetAndMetadata offsetAndMetadata) Overrides the fetch offsets that the consumer will use on the next poll.KafkaReadStream.seek(org.apache.kafka.common.TopicPartition topicPartition, long offset) Overrides the fetch offsets that the consumer will use on the next poll.KafkaReadStream.seek(org.apache.kafka.common.TopicPartition topicPartition, org.apache.kafka.clients.consumer.OffsetAndMetadata offsetAndMetadata) Overrides the fetch offsets that the consumer will use on the next poll.KafkaConsumer.seekToBeginning(TopicPartition topicPartition) Seek to the first offset for each of the given partition.KafkaConsumer.seekToBeginning(Set<TopicPartition> topicPartitions) Seek to the first offset for each of the given partitions.KafkaReadStream.seekToBeginning(Set<org.apache.kafka.common.TopicPartition> topicPartitions) Seek to the first offset for each of the given partitions.KafkaConsumer.seekToEnd(TopicPartition topicPartition) Seek to the last offset for each of the given partition.KafkaConsumer.seekToEnd(Set<TopicPartition> topicPartitions) Seek to the last offset for each of the given partitions.Seek to the last offset for each of the given partitions.Subscribe to the given topic to get dynamically assigned partitions.Subscribe to all topics matching specified pattern to get dynamically assigned partitions.Subscribe to the given list of topics to get dynamically assigned partitions.Subscribe to all topics matching specified pattern to get dynamically assigned partitions.Subscribe to the given list of topics to get dynamically assigned partitions.KafkaConsumer.subscription()Get the current subscription.KafkaReadStream.subscription()Get the current subscription.KafkaConsumer.unsubscribe()Unsubscribe from topics currently subscribed with subscribe.KafkaReadStream.unsubscribe()Unsubscribe from topics currently subscribed with subscribe. -
Uses of Future in io.vertx.kafka.client.producer
Methods in io.vertx.kafka.client.producer that return FutureModifier and TypeMethodDescriptionKafkaProducer.abortTransaction()Aborts the ongoing transaction.KafkaWriteStream.abortTransaction()Aborts the ongoing transaction.KafkaProducer.beginTransaction()Starts a new kafka transaction.KafkaWriteStream.beginTransaction()Starts a new kafka transaction.KafkaProducer.close()Close the producerKafkaProducer.close(long timeout) Close the producerKafkaWriteStream.close()Close the streamKafkaWriteStream.close(long timeout) Close the streamKafkaProducer.commitTransaction()Commits the ongoing transaction.KafkaWriteStream.commitTransaction()Commits the ongoing transaction.KafkaProducer.flush()Invoking this method makes all buffered records immediately available to writeKafkaWriteStream.flush()Invoking this method makes all buffered records immediately available to writeKafkaProducer.initTransactions()Initializes the underlying kafka transactional producer.KafkaWriteStream.initTransactions()Initializes the underlying kafka transactional producer.KafkaProducer.partitionsFor(String topic) Get the partition metadata for the give topic.KafkaWriteStream.partitionsFor(String topic) Get the partition metadata for the give topic.KafkaProducer.send(KafkaProducerRecord<K, V> record) Asynchronously write a record to a topicFuture<org.apache.kafka.clients.producer.RecordMetadata> Asynchronously write a record to a topic -
Uses of Future in io.vertx.mqtt
Methods in io.vertx.mqtt that return FutureModifier and TypeMethodDescriptionMqttClient.authenticationExchange(MqttAuthenticationExchangeMessage message) It is used for Enhanced Authentication and is able to carry an authentication method and authentication data.MqttServer.close()Close the server.Connects to an MQTT server calling connectHandler after connectionConnects to an MQTT server calling connectHandler after connectionMqttClient.disconnect()Disconnects from the MQTT serverMqttServer.listen()Start the server listening for incoming connections using the specified options through the constructorMqttServer.listen(int port) Start the server listening for incoming connections on the port specified but on "0.0.0.0" as host.Start the server listening for incoming connections on the port and host specifiedMqttClient.publish(int id, String topic, Buffer payload, MqttQoS qosLevel, boolean isDup, boolean isRetain) Sends the PUBLISH message to the remote MQTT serverSends the PUBLISH message to the remote MQTT serverMqttEndpoint.publish(String topic, Buffer payload, MqttQoS qosLevel, boolean isDup, boolean isRetain) Sends the PUBLISH message to the remote MQTT clientMqttEndpoint.publish(String topic, Buffer payload, MqttQoS qosLevel, boolean isDup, boolean isRetain, int messageId) Sends the PUBLISH message to the remote MQTT server explicitly specifying the messageIdMqttEndpoint.publish(String topic, Buffer payload, MqttQoS qosLevel, boolean isDup, boolean isRetain, int messageId, MqttProperties properties) Sends the PUBLISH message to the remote MQTT server explicitly specifying the messageIdMqttClient.publishRelease(int publishMessageId) Sends the PUBREL message to the remote MQTT server.Subscribes to the topic with a specified QoS levelSubscribes to the topics with related QoS levelsMqttClient.unsubscribe(String topic) Unsubscribe from receiving messages on given topicMqttClient.unsubscribe(List<String> topics) Unsubscribe from receiving messages on given list of topic -
Uses of Future in io.vertx.mssqlclient
Methods in io.vertx.mssqlclient that return FutureModifier and TypeMethodDescriptionstatic Future<MSSQLConnection> MSSQLConnection.connect(Vertx vertx, MSSQLConnectOptions connectOptions) Create a connection to SQL Server with the givenconnectOptions.static Future<MSSQLConnection> LikeMSSQLConnection.connect(Vertx, MSSQLConnectOptions)with options built fromconnectionUri. -
Uses of Future in io.vertx.mysqlclient
Methods in io.vertx.mysqlclient that return FutureModifier and TypeMethodDescriptionMySQLConnection.changeUser(MySQLAuthOptions options) Send a CHANGE_USER command to change the user of the current connection, this operation will also reset connection state.static Future<MySQLConnection> MySQLConnection.connect(Vertx vertx, MySQLConnectOptions connectOptions) Create a connection to MySQL server with the givenconnectOptions.static Future<MySQLConnection> LikeMySQLConnection.connect(Vertx, MySQLConnectOptions)with options built fromconnectionUri.MySQLConnection.debug()Send a DEBUG command to dump debug information to the server's stdout.MySQLConnection.getInternalStatistics()Send a STATISTICS command to get a human readable string of the server internal status.MySQLConnection.ping()Send a PING command to check if the server is alive.MySQLConnection.resetConnection()Send a RESET_CONNECTION command to reset the session state.MySQLConnection.setOption(MySQLSetOption option) Send a SET_OPTION command to set options for the current connection.MySQLConnection.specifySchema(String schemaName) Send a INIT_DB command to change the default schema of the connection. -
Uses of Future in io.vertx.mysqlclient.spi
Method parameters in io.vertx.mysqlclient.spi with type arguments of type FutureModifier and TypeMethodDescriptionprotected PoolMySQLDriver.newPool(io.vertx.core.internal.VertxInternal vertx, Handler<SqlConnection> connectHandler, Supplier<Future<MySQLConnectOptions>> databases, PoolOptions poolOptions, NetClientOptions transportOptions, io.vertx.core.internal.CloseFuture closeFuture) -
Uses of Future in io.vertx.openapi.contract
Methods in io.vertx.openapi.contract that return FutureModifier and TypeMethodDescriptionOpenAPIContractBuilder.build()Builds the contract.static Future<OpenAPIContract> OpenAPIContract.from(Vertx vertx, JsonObject contract) Resolves / dereferences the passed contract and creates anOpenAPIContractinstance.static Future<OpenAPIContract> OpenAPIContract.from(Vertx vertx, JsonObject contract, Map<String, JsonObject> additionalContractParts) Resolves / dereferences the passed contract and creates anOpenAPIContractinstance.static Future<OpenAPIContract> Resolves / dereferences the passed contract and creates anOpenAPIContractinstance.static Future<OpenAPIContract> OpenAPIContract.from(Vertx vertx, String contractPath, Map<String, String> additionalContractPartPaths) Resolves / dereferences the passed contract and creates anOpenAPIContractinstance.OpenAPIVersion.getRepository(Vertx vertx, String baseUri) OpenAPIVersion.resolve(Vertx vertx, SchemaRepository repo, JsonObject contract) OpenAPIVersion.validateAdditionalContractFile(Vertx vertx, SchemaRepository repo, JsonObject file) Deprecated.OpenAPIVersion.validateAdditionalContractPart(Vertx vertx, SchemaRepository repo, JsonObject part) Validates an additional contract against the openapi schema.OpenAPIVersion.validateContract(Vertx vertx, SchemaRepository repo, JsonObject contract) -
Uses of Future in io.vertx.openapi.validation
Methods in io.vertx.openapi.validation that return FutureModifier and TypeMethodDescriptionstatic Future<ValidatableRequest> RequestUtils.extract(HttpServerRequest request, Operation operation) Extracts and transforms the parameters and the body of an incoming request into aformatthat can be validated by theRequestValidator.static Future<ValidatableRequest> RequestUtils.extract(HttpServerRequest request, Operation operation, Supplier<Future<Buffer>> bodySupplier) LikeRequestUtils.extract(HttpServerRequest, Operation), but offers to pass a supplier fpr the body.static Future<ValidatableRequest> ValidatableRequest.of(HttpServerRequest request, Operation operation) ValidatedResponse.send(HttpServerResponse serverResponse) Add all parameters from the validated response to the passedHttpServerResponseand send it.RequestValidator.validate(HttpServerRequest request) LikeRequestValidator.validate(ValidatableRequest, String), but the operationId andValidatableRequestare determined from the passed request.RequestValidator.validate(HttpServerRequest request, String operationId) LikeRequestValidator.validate(ValidatableRequest, String), butValidatableRequestare directly extracted from the passed request.RequestValidator.validate(ValidatableRequest params, String operationId) Validates the passed request parameters against the operation defined in the related OpenAPI contract.ResponseValidator.validate(ValidatableResponse params, String operationId) Validates the passed response parameters against the operation defined in the related OpenAPI contract.Method parameters in io.vertx.openapi.validation with type arguments of type FutureModifier and TypeMethodDescriptionstatic Future<ValidatableRequest> RequestUtils.extract(HttpServerRequest request, Operation operation, Supplier<Future<Buffer>> bodySupplier) LikeRequestUtils.extract(HttpServerRequest, Operation), but offers to pass a supplier fpr the body. -
Uses of Future in io.vertx.oracleclient
Methods in io.vertx.oracleclient that return FutureModifier and TypeMethodDescriptionstatic Future<OracleConnection> OracleConnection.connect(Vertx vertx, OracleConnectOptions connectOptions) Create a connection to Oracle with the givenconnectOptions.static Future<OracleConnection> LikeOracleConnection.connect(Vertx, OracleConnectOptions)with options built fromconnectionUri. -
Uses of Future in io.vertx.pgclient
Methods in io.vertx.pgclient that return FutureModifier and TypeMethodDescriptionPgConnection.cancelRequest()Send a request cancellation message to tell the server to cancel processing request in this connection.static Future<PgConnection> LikePgConnection.connect(Vertx, PgConnectOptions)with options build from the environment variables.static Future<PgConnection> PgConnection.connect(Vertx vertx, PgConnectOptions options) Connects to the database and returns the connection if that succeeds.static Future<PgConnection> LikePgConnection.connect(Vertx, PgConnectOptions)with options build fromconnectionUri. -
Uses of Future in io.vertx.pgclient.pubsub
Methods in io.vertx.pgclient.pubsub that return Future -
Uses of Future in io.vertx.pgclient.spi
Method parameters in io.vertx.pgclient.spi with type arguments of type FutureModifier and TypeMethodDescriptionprotected PoolPgDriver.newPool(io.vertx.core.internal.VertxInternal vertx, Handler<SqlConnection> connectHandler, Supplier<Future<PgConnectOptions>> databases, PoolOptions poolOptions, NetClientOptions transportOptions, io.vertx.core.internal.CloseFuture closeFuture) -
Uses of Future in io.vertx.rabbitmq
Methods in io.vertx.rabbitmq that return FutureModifier and TypeMethodDescriptionRabbitMQClient.addConfirmListener(int maxQueueSize) Add a Confirm Listener to the channel.RabbitMQClient.basicAck(long deliveryTag, boolean multiple) Acknowledge one or several received messages.default Future<RabbitMQConsumer> RabbitMQClient.basicConsumer(String queue) RabbitMQClient.basicConsumer(String queue, QueueOptions options) Create a consumer with the givenoptions.Retrieve a message from a queue using AMQP.Basic.GetRabbitMQClient.basicNack(long deliveryTag, boolean multiple, boolean requeue) Reject one or several received messages.RabbitMQClient.basicPublish(String exchange, String routingKey, com.rabbitmq.client.BasicProperties properties, Buffer body) Publish a message.RabbitMQClient.basicPublish(String exchange, String routingKey, Buffer body) Publish a message.RabbitMQClient.basicPublishWithDeliveryTag(String exchange, String routingKey, com.rabbitmq.client.BasicProperties properties, Buffer body, Handler<Long> deliveryTagHandler) Publish a message.RabbitMQClient.basicQos(int prefetchCount) Request a specific prefetchCount "quality of service" settings for this channel.RabbitMQClient.basicQos(int prefetchCount, boolean global) Request a specific prefetchCount "quality of service" settings for this channel.RabbitMQClient.basicQos(int prefetchSize, int prefetchCount, boolean global) Request specific "quality of service" settings.RabbitMQConsumer.cancel()Stop message consumption from a queue.RabbitMQClient.confirmSelect()Enables publisher acknowledgements on this channel.RabbitMQClient.exchangeBind(String destination, String source, String routingKey) Bind an exchange to an exchange.RabbitMQClient.exchangeBind(String destination, String source, String routingKey, Map<String, Object> arguments) Bind an exchange to an exchange.RabbitMQClient.exchangeDeclare(String exchange, String type, boolean durable, boolean autoDelete) Declare an exchange.RabbitMQClient.exchangeDeclare(String exchange, String type, boolean durable, boolean autoDelete, JsonObject config) Declare an exchange with additional parameters such as dead lettering, an alternate exchange or TTL.RabbitMQClient.exchangeDelete(String exchange) Delete an exchange, without regard for whether it is in use or not.RabbitMQClient.exchangeUnbind(String destination, String source, String routingKey) Unbind an exchange from an exchange.RabbitMQClient.exchangeUnbind(String destination, String source, String routingKey, Map<String, Object> arguments) Unbind an exchange from an exchange.RabbitMQClient.messageCount(String queue) Returns the number of messages in a queue ready to be delivered.RabbitMQPublisher.publish(String exchange, String routingKey, com.rabbitmq.client.BasicProperties properties, Buffer body) Publish a message.RabbitMQPublisher.publishConfirm(String exchange, String routingKey, com.rabbitmq.client.BasicProperties properties, Buffer body) Publish a message and complete when publish confirm has returned.Bind a queue to an exchangeRabbitMQClient.queueBind(String queue, String exchange, String routingKey, Map<String, Object> arguments) Bind a queue to an exchangeFuture<com.rabbitmq.client.AMQP.Queue.DeclareOk> RabbitMQClient.queueDeclare(String queue, boolean durable, boolean exclusive, boolean autoDelete) Declare a queueFuture<com.rabbitmq.client.AMQP.Queue.DeclareOk> RabbitMQClient.queueDeclare(String queue, boolean durable, boolean exclusive, boolean autoDelete, JsonObject config) Declare a queue with config optionsRabbitMQClient.queueDeclareAuto()Actively declare a server-named exclusive, autodelete, non-durable queue.Future<com.rabbitmq.client.AMQP.Queue.DeleteOk> RabbitMQClient.queueDelete(String queue) Delete a queue, without regard for whether it is in use or has messages on itFuture<com.rabbitmq.client.AMQP.Queue.DeleteOk> RabbitMQClient.queueDeleteIf(String queue, boolean ifUnused, boolean ifEmpty) Delete a queueRabbitMQClient.queueUnbind(String queue, String exchange, String routingKey) Unbind a queue from an exchangeRabbitMQClient.queueUnbind(String queue, String exchange, String routingKey, Map<String, Object> arguments) Unbind a queue from an exchangeRabbitMQClient.restartConnect(int attempts) restart the rabbitMQ connect.RabbitMQClient.start()Start the rabbitMQ client.RabbitMQPublisher.start()Start the rabbitMQ publisher.RabbitMQClient.stop()Stop the rabbitMQ client.RabbitMQPublisher.stop()Stop the rabbitMQ publisher.RabbitMQClient.waitForConfirms()Wait until all messages published since the last call have been either ack'd or nack'd by the broker.RabbitMQClient.waitForConfirms(long timeout) Wait until all messages published since the last call have been either ack'd or nack'd by the broker; or until timeout elapses. -
Uses of Future in io.vertx.reactivex
Methods in io.vertx.reactivex that return FutureModifier and TypeMethodDescriptionCompletableHelper.toFuture(Completable maybe) static <T> Future<T> Adapts an RxJava2Maybe<T>to a Vert.xFuture<T>.static <T,U> Future <U> LikeMaybeHelper.toFuture(Maybe)but with anadapterof the result.static <T> Future<T> Adapts an RxJava2Single<T>to a Vert.xFuture<T>.static <T,U> Future <U> LikeSingleHelper.toFuture(Single)but with anadapterof the result. -
Uses of Future in io.vertx.reactivex.amqp
Methods in io.vertx.reactivex.amqp that return FutureModifier and TypeMethodDescriptionAmqpClient.close()Closes the client.AmqpConnection.close()Closes the AMQP connection, i.e. allows the Close frame to be emitted.AmqpReceiver.close()Closes the receiver.AmqpSender.close()Closes the sender.AmqpConnection.closeFuture()AmqpClient.connect()Connects to the AMQP broker or router.AmqpConnection.createAnonymousSender()Creates an anonymous sender.AmqpConnection.createDynamicReceiver()Creates a dynamic receiver.AmqpClient.createReceiver(String address) Creates a receiver used to consume messages from the given address.AmqpClient.createReceiver(String address, AmqpReceiverOptions receiverOptions) Creates a receiver used to consumer messages from the given address.AmqpConnection.createReceiver(String address) Creates a receiver used to consume messages from the given address.AmqpConnection.createReceiver(String address, AmqpReceiverOptions receiverOptions) Creates a receiver used to consumer messages from the given address.AmqpClient.createSender(String address) Creates a sender used to send messages to the given address.AmqpClient.createSender(String address, AmqpSenderOptions options) Creates a sender used to send messages to the given address.AmqpConnection.createSender(String address) Creates a sender used to send messages to the given address.AmqpConnection.createSender(String address, AmqpSenderOptions options) Creates a sender used to send messages to the given address.AmqpSender.end()Ends the stream.AmqpSender.end(AmqpMessage data) Same asWriteStream.end()but writes some data to the stream before ending.AmqpReceiver.pipeTo(WriteStream<AmqpMessage> dst) Pipe thisReadStreamto theWriteStream.AmqpSender.sendWithAck(AmqpMessage message) Sends an AMQP message and waits for an acknowledgement.AmqpSender.write(AmqpMessage data) Write some data to the stream. -
Uses of Future in io.vertx.reactivex.cassandra
Methods in io.vertx.reactivex.cassandra that return FutureModifier and TypeMethodDescriptionResultSet.all()The method should not be used concurrently with others likeResultSet.fetchNextPage()orResultSet.one().CassandraClient.close()Closes this client.CassandraClient.execute(com.datastax.oss.driver.api.core.cql.Statement statement) Execute the statement and provide a handler for consuming results.Execute the query and provide a handler for consuming results.CassandraClient.executeWithFullFetch(com.datastax.oss.driver.api.core.cql.Statement statement) Execute the query and provide a handler for consuming results.CassandraClient.executeWithFullFetch(String query) Execute the query and provide a handler for consuming results.ResultSet.fetchNextPage()Future<com.datastax.oss.driver.api.core.metadata.Metadata> CassandraClient.metadata()Get for the session.CassandraRowStream.pipeTo(WriteStream<com.datastax.oss.driver.api.core.cql.Row> dst) Future<com.datastax.oss.driver.api.core.cql.PreparedStatement> CassandraClient.prepare(com.datastax.oss.driver.api.core.cql.SimpleStatement statement) Prepares the provided a .Future<com.datastax.oss.driver.api.core.cql.PreparedStatement> Prepares the provided query string.CassandraClient.queryStream(com.datastax.oss.driver.api.core.cql.Statement statement) Executes the given SQL statement which returns the results of the query as a read stream.CassandraClient.queryStream(String sql) Executes the given SQLSELECTstatement which returns the results of the query as a read stream. -
Uses of Future in io.vertx.reactivex.circuitbreaker
Methods in io.vertx.reactivex.circuitbreaker that return FutureModifier and TypeMethodDescription<T> Future<T> Same asCircuitBreaker.executeWithFallback(Handler, Function)but using the circuit breaker .<T> Future<T> Same asCircuitBreaker.executeWithFallback(Handler, Function)but using the circuit breaker .<T> Future<T> CircuitBreaker.executeWithFallback(Handler<Promise<T>> command, Function<Throwable, T> fallback) Executes the given operation with the circuit breaker control.<T> Future<T> CircuitBreaker.executeWithFallback(Supplier<Future<T>> command, Function<Throwable, T> fallback) Executes the given operation with the circuit breaker control.Methods in io.vertx.reactivex.circuitbreaker with parameters of type FutureModifier and TypeMethodDescriptionbooleanInvoked by theCircuitBreakerwhen an operation completes.Method parameters in io.vertx.reactivex.circuitbreaker with type arguments of type FutureModifier and TypeMethodDescription<T> Future<T> Same asCircuitBreaker.executeWithFallback(Handler, Function)but using the circuit breaker .<T> Future<T> CircuitBreaker.executeWithFallback(Supplier<Future<T>> command, Function<Throwable, T> fallback) Executes the given operation with the circuit breaker control.<T> Single<T> Same asCircuitBreaker.executeWithFallback(Handler, Function)but using the circuit breaker .<T> Single<T> CircuitBreaker.rxExecuteWithFallback(Supplier<Future<T>> command, Function<Throwable, T> fallback) Executes the given operation with the circuit breaker control. -
Uses of Future in io.vertx.reactivex.config
Methods in io.vertx.reactivex.config that return Future -
Uses of Future in io.vertx.reactivex.core
Methods in io.vertx.reactivex.core that return FutureModifier and TypeMethodDescriptionVertxBuilder.buildClustered()Creates a clustered instance.Vertx.close()Stop the Vertx instance and release any resources held by it.WorkerExecutor.close()Close the executor.Vertx.clusteredVertx(VertxOptions options) Creates a clustered instance using the specified options.Vertx.deployVerticle(Deployable verticle) Deploy a verticle instance that you have created yourself.Vertx.deployVerticle(Deployable verticle, DeploymentOptions options) LikeVertx.deployVerticle(String)butDeploymentOptionsare provided to configure the deployment.Vertx.deployVerticle(String name) Deploy a verticle instance given a name.Vertx.deployVerticle(String name, DeploymentOptions options) LikeVertx.deployVerticle(String)butDeploymentOptionsare provided to configure the deployment.Vertx.deployVerticle(Supplier<? extends Deployable> supplier, DeploymentOptions options) LikeVertx.deployVerticle(String)butDeployableinstance is created by invoking theverticleSupplier.<T> Future<T> Context.executeBlocking(Callable<T> blockingCodeHandler) InvokeContext.executeBlocking(Callable, boolean)with order = true.<T> Future<T> Context.executeBlocking(Callable<T> blockingCodeHandler, boolean ordered) Safely execute some blocking code.<T> Future<T> Vertx.executeBlocking(Callable<T> blockingCodeHandler) LikeVertx.executeBlocking(Callable, boolean)called with ordered = true.<T> Future<T> Vertx.executeBlocking(Callable<T> blockingCodeHandler, boolean ordered) Safely execute some blocking code.<T> Future<T> WorkerExecutor.executeBlocking(Callable<T> blockingCodeHandler) LikeWorkerExecutor.executeBlocking(Callable, boolean)called with ordered = true.<T> Future<T> WorkerExecutor.executeBlocking(Callable<T> blockingCodeHandler, boolean ordered) Safely execute some blocking code.Promise.future()Undeploy a verticle deployment. -
Uses of Future in io.vertx.reactivex.core.datagram
Methods in io.vertx.reactivex.core.datagram that return FutureModifier and TypeMethodDescriptionDatagramSocket.blockMulticastGroup(String multicastAddress, String sourceToBlock) Block the given address for the given multicast address and notifies the once the operation completes.DatagramSocket.blockMulticastGroup(String multicastAddress, String networkInterface, String sourceToBlock) Block the given address for the given multicast address on the given network interface and notifies the once the operation completes.DatagramSocket.close()Closes theDatagramSocketimplementation asynchronous and notifies the handler once done.Start listening on the given port and host.DatagramSocket.listenMulticastGroup(String multicastAddress) Joins a multicast group and listens for packets send to it.DatagramSocket.listenMulticastGroup(String multicastAddress, String networkInterface, String source) Joins a multicast group and listens for packets send to it on the given network interface.Write the givenBufferto theSocketAddress.Write the givenStringto theSocketAddressusing UTF8 encoding.Write the givenStringto theSocketAddressusing the given encoding.DatagramSocket.unlistenMulticastGroup(String multicastAddress) Leaves a multicast group and stops listening for packets send to it.DatagramSocket.unlistenMulticastGroup(String multicastAddress, String networkInterface, String source) Leaves a multicast group and stops listening for packets send to it on the given network interface. -
Uses of Future in io.vertx.reactivex.core.dns
Methods in io.vertx.reactivex.core.dns that return FutureModifier and TypeMethodDescriptionDnsClient.close()Close the client.Try to lookup the A (ipv4) or AAAA (ipv6) record for the given name.Try to lookup the A (ipv4) record for the given name.Try to lookup the AAAA (ipv6) record for the given name.Try to resolve all A (ipv4) records for the given name.DnsClient.resolveAAAA(String name) Try to resolve all AAAA (ipv6) records for the given name.DnsClient.resolveCNAME(String name) Try to resolve the CNAME record for the given name.Try to resolve the MX records for the given name.Try to resolve the NS records for the given name.DnsClient.resolvePTR(String name) Try to resolve the PTR record for the given name.DnsClient.resolveSRV(String name) Try to resolve the SRV records for the given name.DnsClient.resolveTXT(String name) Try to resolve the TXT records for the given name.DnsClient.reverseLookup(String ipaddress) Try to do a reverse lookup of an IP address. -
Uses of Future in io.vertx.reactivex.core.eventbus
Methods in io.vertx.reactivex.core.eventbus that return FutureModifier and TypeMethodDescriptionMessageProducer.close()Closes the producer, this method should be called when the message producer is not used anymore.MessageConsumer.completion()MessageConsumer.pipeTo(WriteStream<Message<T>> dst) Pipe thisReadStreamto theWriteStream.Message.replyAndRequest(Object message) Reply to this message, specifying areplyHandlerfor the reply - i.e. to receive the reply to the reply.Message.replyAndRequest(Object message, DeliveryOptions options) LikeMessage.replyAndRequest(Object)but specifyingoptionsthat can be used to configure the delivery.Sends a message and specify areplyHandlerthat will be called if the recipient subsequently replies to the message.EventBus.request(String address, Object message, DeliveryOptions options) LikeEventBus.request(String, Object)but specifyingoptionsthat can be used to configure the delivery.MessageConsumer.unregister()Unregisters the handler which created this registrationWrite a message to the event-bus, either sending or publishing. -
Uses of Future in io.vertx.reactivex.core.file
Methods in io.vertx.reactivex.core.file that return FutureModifier and TypeMethodDescriptionChange the permissions on the file represented bypathtoperms, asynchronously.FileSystem.chmodRecursive(String path, String perms, String dirPerms) Change the permissions on the file represented bypathtoperms, asynchronously.Change the ownership on the file represented bypathtouserand {code group}, asynchronously.AsyncFile.close()Close the file.Copy a file from the pathfromto pathto, asynchronously.FileSystem.copy(String from, String to, CopyOptions options) Copy a file from the pathfromto pathto, asynchronously.FileSystem.copyRecursive(String from, String to, boolean recursive) Copy a file from the pathfromto pathto, asynchronously.FileSystem.createFile(String path) Creates an empty file with the specifiedpath, asynchronously.FileSystem.createFile(String path, String perms) Creates an empty file with the specifiedpathand permissionsperms, asynchronously.FileSystem.createTempDirectory(String prefix) Creates a new directory in the default temporary-file directory, using the given prefix to generate its name, asynchronously.FileSystem.createTempDirectory(String prefix, String perms) Creates a new directory in the default temporary-file directory, using the given prefix to generate its name, asynchronously.FileSystem.createTempDirectory(String dir, String prefix, String perms) Creates a new directory in the directory provided by the pathpath, using the given prefix to generate its name, asynchronously.FileSystem.createTempFile(String prefix, String suffix) Creates a new file in the default temporary-file directory, using the given prefix and suffix to generate its name, asynchronously.FileSystem.createTempFile(String prefix, String suffix, String perms) Creates a new file in the directory provided by the pathdir, using the given prefix and suffix to generate its name, asynchronously.FileSystem.createTempFile(String dir, String prefix, String suffix, String perms) Creates a new file in the directory provided by the pathdir, using the given prefix and suffix to generate its name, asynchronously.Deletes the file represented by the specifiedpath, asynchronously.FileSystem.deleteRecursive(String path) Deletes the file represented by the specifiedpath, asynchronously.AsyncFile.end()Ends the stream.Same asWriteStream.end()but writes some data to the stream before ending.Determines whether the file as specified by the pathpathexists, asynchronously.AsyncFile.flush()Flush any writes made to this file to underlying persistent storage.Returns properties of the file-system being used by the specifiedpath, asynchronously.AsyncFileLock.isValid()A lock remains valid until it is released or the file correspondingAsyncFileis closed.Create a hard link on the file system fromlinktoexisting, asynchronously.AsyncFile.lock()Acquire a non-shared lock on the entire file.AsyncFile.lock(long position, long size, boolean shared) Acquire a lock on a portion of this file.Obtain properties for the link represented bypath, asynchronously.Create the directory represented bypath, asynchronously.Create the directory represented bypath, asynchronously.Create the directory represented bypathand any non existent parents, asynchronously.Create the directory represented bypathand any non existent parents, asynchronously.Move a file from the pathfromto pathto, asynchronously.FileSystem.move(String from, String to, CopyOptions options) Move a file from the pathfromto pathto, asynchronously.FileSystem.open(String path, OpenOptions options) Open the file represented bypath, asynchronously.AsyncFile.pipeTo(WriteStream<Buffer> dst) Pipe thisReadStreamto theWriteStream.Obtain properties for the file represented bypath, asynchronously.Readslengthbytes of data from the file at positionpositionin the file, asynchronously.Read the contents of the directory specified bypath, asynchronously.Read the contents of the directory specified bypath, asynchronously.Reads the entire file as represented by the pathpathas a , asynchronously.FileSystem.readSymlink(String link) Returns the path representing the file that the symbolic link specified bylinkpoints to, asynchronously.AsyncFileLock.release()Releases this lock;AsyncFile.size()Create a symbolic link on the file system fromlinktoexisting, asynchronously.Truncate the file represented bypathto lengthlenin bytes, asynchronously.Unlinks the link on the file system represented by the pathlink, asynchronously.<T> Future<T> Acquire a lock on a portion of this file.<T> Future<T> Acquire a non-shared lock on the entire file.Write some data to the stream.Write aBufferto the file at positionpositionin the file, asynchronously.Creates the file, and writes the specifiedBuffer datato the file represented by the pathpath, asynchronously.Method parameters in io.vertx.reactivex.core.file with type arguments of type FutureModifier and TypeMethodDescription<T> Single<T> AsyncFile.rxWithLock(long position, long size, boolean shared, Supplier<Future<T>> block) Acquire a lock on a portion of this file.<T> Single<T> AsyncFile.rxWithLock(Supplier<Future<T>> block) Acquire a non-shared lock on the entire file.<T> Future<T> Acquire a lock on a portion of this file.<T> Future<T> Acquire a non-shared lock on the entire file. -
Uses of Future in io.vertx.reactivex.core.http
Methods in io.vertx.reactivex.core.http that return FutureModifier and TypeMethodDescriptionServerWebSocketHandshake.accept()Accept the WebSocket and terminate the WebSocket handshake.HttpClientResponse.body()Convenience method for receiving the entire request body in one piece.HttpServerRequest.body()Convenience method for receiving the entire request body in one piece.HttpClientRequest.cancel()Attempt to cancel the request according to the semantics of the underlying HTTP implementation.HttpServerResponse.cancel()Attempt to cancel the request according to the semantics of the underlying HTTP implementation.ClientWebSocket.close()Close the WebSocket sending the default close frame.ClientWebSocket.close(short statusCode) Close the WebSocket sending a close frame with specified status code.Close sending a close frame with specified status code and reason.HttpClient.close()Close immediately (shutdown(0, TimeUnit.SECONDS).HttpClientAgent.close()Close immediately (shutdown(0, TimeUnit.SECONDS).HttpClientConnection.close()HttpConnection.close()Close immediately (shutdown(0, TimeUnit.SECONDS).HttpServer.close()Close the server.ServerWebSocket.close()The WebSocket handshake will be accepted when it hasn't yet been settled or when an asynchronous handshake is in progress.ServerWebSocket.close(short statusCode) Close the WebSocket sending a close frame with specified status code.Close sending a close frame with specified status code and reason.WebSocket.close()Close the WebSocket sending the default close frame.WebSocket.close(short statusCode) Close the WebSocket sending a close frame with specified status code.Close sending a close frame with specified status code and reason.WebSocketBase.close()Close the WebSocket sending the default close frame.WebSocketBase.close(short statusCode) Close the WebSocket sending a close frame with specified status code.Close sending a close frame with specified status code and reason.WebSocketClient.close()Close immediately (shutdown(0, TimeUnit.SECONDS).Connect this WebSocket to the specified port, host and relative request URI.ClientWebSocket.connect(WebSocketConnectOptions options) Connect this WebSocket with the specified options.Connect this WebSocket at the relative request URI using the default host and port.Connect this WebSocket to the host and relative request URI and default port.HttpClientAgent.connect(HttpConnectOptions options) Connect to a remote HTTP server with the specificoptions, the connection is un-pooled and the management of the connection is left to the user.HttpClientRequest.connect()Create an HTTP tunnel to the server.Connect a WebSocket to the specified port, host and relative request URI.WebSocketClient.connect(WebSocketConnectOptions options) Connect a WebSocket with the specified options.Connect a WebSocket to the default client port, default client host and specified, relative request URI.Connect a WebSocket to the default client port and specified host and relative request URI.ClientWebSocket.end()CallsWebSocketBase.close()Same asWebSocketBase.end(Buffer)but writes some data to the stream before ending.HttpClientRequest.end()Ends the request.Same asHttpClientRequest.end(String)but writes some data to the request body before ending.Same asHttpClientRequest.end(String)but writes a String in UTF-8 encodingSame asHttpClientRequest.end(String)but writes a String with the specified encodingHttpClientResponse.end()Returns a future signaling when the response has been fully received successfully or failed.HttpServerRequest.end()Returns a future signaling when the request has been fully received successfully or failed.HttpServerResponse.end()Ends the response.Same asHttpServerResponse.end(String)but writes some data to the response body before ending.Same asHttpServerResponse.end(String)but writes a String in UTF-8 encoding before ending the response.Same asHttpServerResponse.end(String)but writes a String with the specified encoding before ending the response.ServerWebSocket.end()Same asWebSocketBase.end(Buffer)but writes some data to the stream before ending.WebSocket.end()CallsWebSocketBase.close()Same asWebSocketBase.end(Buffer)but writes some data to the stream before ending.WebSocketBase.end()CallsWebSocketBase.close()Same asWebSocketBase.end(Buffer)but writes some data to the stream before ending.HttpServer.listen()Tell the server to start listening.HttpServer.listen(int port) LikeHttpServer.listen()but the server will listen on host "0.0.0.0" and port specified here ignoring any value in theHttpServerOptionsthat was used when creating the server.Tell the server to start listening.HttpServer.listen(SocketAddress address) Tell the server to start listening on the given address supplying a handler that will be called when the server is actually listening (or has failed).Send a frame to the remote endpoint.ClientWebSocket.pipeTo(WriteStream<Buffer> dst) Pipe thisReadStreamto theWriteStream.HttpClientResponse.pipeTo(WriteStream<Buffer> dst) Pipe thisReadStreamto theWriteStream.HttpServerFileUpload.pipeTo(WriteStream<Buffer> dst) Pipe thisReadStreamto theWriteStream.HttpServerRequest.pipeTo(WriteStream<Buffer> dst) Pipe thisReadStreamto theWriteStream.ServerWebSocket.pipeTo(WriteStream<Buffer> dst) Pipe thisReadStreamto theWriteStream.WebSocket.pipeTo(WriteStream<Buffer> dst) Pipe thisReadStreamto theWriteStream.WebSocketBase.pipeTo(WriteStream<Buffer> dst) Pipe thisReadStreamto theWriteStream.HttpServerResponse.push(HttpMethod method, HostAndPort authority, String path) LikeHttpServerResponse.push(HttpMethod, HostAndPort, String)with no headers.HttpServerResponse.push(HttpMethod method, HostAndPort authority, String path, MultiMap headers) Push a response to the client.HttpServerResponse.push(HttpMethod method, String path) LikeHttpServerResponse.push(HttpMethod, HostAndPort, String)with the host copied from the current request.HttpServerResponse.push(HttpMethod method, String path, MultiMap headers) LikeHttpServerResponse.push(HttpMethod, HostAndPort, String)with the host copied from the current request.ServerWebSocketHandshake.reject()Reject the WebSocket.ServerWebSocketHandshake.reject(int status) LikeServerWebSocketHandshake.reject()but with astatus.HttpClient.request()Create an HTTP request to send to the server with the default host and port of the client.HttpClient.request(HttpMethod method, int port, String host, String requestURI) Create an HTTP request to send to the server at thehostandport.HttpClient.request(HttpMethod method, String requestURI) Create an HTTP request to send to the server at the default host and port.HttpClient.request(HttpMethod method, String host, String requestURI) Create an HTTP request to send to the server at thehostand default port.HttpClient.request(RequestOptions options) Create an HTTP request to send to the server.HttpClientAgent.request()Create an HTTP request to send to the server with the default host and port of the client.HttpClientAgent.request(HttpMethod method, int port, String host, String requestURI) Create an HTTP request to send to the server at thehostandport.HttpClientAgent.request(HttpMethod method, String requestURI) Create an HTTP request to send to the server at the default host and port.HttpClientAgent.request(HttpMethod method, String host, String requestURI) Create an HTTP request to send to the server at thehostand default port.HttpClientAgent.request(RequestOptions options) Create an HTTP request to send to the server.HttpClientConnection.request()Create an HTTP request to send to the server with the default host and port of the client.HttpClientConnection.request(HttpMethod method, int port, String host, String requestURI) Create an HTTP request to send to the server at thehostandport.HttpClientConnection.request(HttpMethod method, String requestURI) Create an HTTP request to send to the server at the default host and port.HttpClientConnection.request(HttpMethod method, String host, String requestURI) Create an HTTP request to send to the server at thehostand default port.HttpClientConnection.request(RequestOptions options) Create an HTTP request to send to the server.HttpClientRequest.reset()Reset this stream with the error code0.HttpClientRequest.reset(long code) Reset this request:Reset this request:HttpServerResponse.reset()Equivalent to callingHttpServerResponse.reset()with0.HttpServerResponse.reset(long code) Reset this response:HttpClientRequest.response()HttpClientRequest.send()Send the request with an empty body.Send the request with a streambody.Send the request with a bufferbody.HttpClientRequest.send(ClientForm form) LikeHttpClientRequest.send()but with aform.HttpClientRequest.send(ReadStream<Buffer> body) Send the request with a streambody.Send the request with a stringbody.HttpServerResponse.send()Send the request with an empty body.Send the request with a streambody.Send the request with a bufferbody.HttpServerResponse.send(ReadStream<Buffer> body) Send the request with a streambody.Send the request with a stringbody.HttpServerResponse.sendFile(RandomAccessFile file) Same asHttpServerResponse.sendFile(String)withHttpServerResponse.sendFile(RandomAccessFile file, long offset) Same asHttpServerResponse.sendFile(String)withHttpServerResponse.sendFile(RandomAccessFile file, long offset, long length) Same asHttpServerResponse.sendFile(String)withSend the request with a streambody.Same asHttpServerResponse.sendFile(String)using length @code{Long.MAX_VALUE} which means until the end of the file.Ask the OS to stream a file as specified byfilenamedirectly from disk to the outgoing connection, bypassing userspace altogether (where supported by the underlying operating system.HttpServerResponse.sendFile(FileChannel channel) Same asHttpServerResponse.sendFile(String)using length @code{Long.MAX_VALUE} which means until the end of the file.HttpServerResponse.sendFile(FileChannel channel, long offset) Same asHttpServerResponse.sendFile(String)using length @code{Long.MAX_VALUE} which means until the end of the file.HttpServerResponse.sendFile(FileChannel channel, long offset, long length) Ask the OS to stream a file as specified bychanneldirectly from disk to the outgoing connection, bypassing userspace altogether (where supported by the underlying operating system).HttpClientRequest.sendHead()Deprecated.ClientWebSocket.shutdown()CallsWebSocketBase.shutdown()with anullreason.CallsWebSocketBase.shutdown()ClientWebSocket.shutdown(short statusCode) LikeWebSocketBase.shutdown()with a 30 seconds timeout and anullreason.LikeWebSocketBase.shutdown()with a 30 seconds timeout.CallsWebSocketBase.shutdown()with anullreason.Initiate a graceful WebSocket shutdown, the shutdown handler is notified and shall close the WebSocket, otherwise after atimeoutthe WebSocket will be closed.HttpClient.shutdown()Shutdown with a 30 seconds timeout (shutdown(30, TimeUnit.SECONDS)).CallsHttpClient.shutdown().HttpClientAgent.shutdown()Shutdown with a 30 seconds timeout (shutdown(30, TimeUnit.SECONDS)).CallsHttpClient.shutdown().Initiate the client shutdown sequence.HttpClientConnection.shutdown()Initiate the client shutdown sequence.HttpConnection.shutdown()Shutdown with a 30 seconds timeout (shutdown(30, TimeUnit.SECONDS)).Initiate a graceful connection shutdown, the connection is taken out of service and closed when all the inflight requests are processed, otherwise after atimeoutthe connection will be closed.HttpServer.shutdown()Shutdown with a 30 seconds timeout (shutdown(Duration.ofSeconds(30))).CallsHttpServer.shutdown().Initiate the server shutdown sequence.ServerWebSocket.shutdown()CallsWebSocketBase.shutdown()with anullreason.CallsWebSocketBase.shutdown()ServerWebSocket.shutdown(short statusCode) LikeWebSocketBase.shutdown()with a 30 seconds timeout and anullreason.LikeWebSocketBase.shutdown()with a 30 seconds timeout.CallsWebSocketBase.shutdown()with anullreason.Initiate a graceful WebSocket shutdown, the shutdown handler is notified and shall close the WebSocket, otherwise after atimeoutthe WebSocket will be closed.WebSocket.shutdown()CallsWebSocketBase.shutdown()with anullreason.CallsWebSocketBase.shutdown()WebSocket.shutdown(short statusCode) LikeWebSocketBase.shutdown()with a 30 seconds timeout and anullreason.LikeWebSocketBase.shutdown()with a 30 seconds timeout.CallsWebSocketBase.shutdown()with anullreason.Initiate a graceful WebSocket shutdown, the shutdown handler is notified and shall close the WebSocket, otherwise after atimeoutthe WebSocket will be closed.WebSocketBase.shutdown()CallsWebSocketBase.shutdown()with anullreason.CallsWebSocketBase.shutdown()WebSocketBase.shutdown(short statusCode) LikeWebSocketBase.shutdown()with a 30 seconds timeout and anullreason.LikeWebSocketBase.shutdown()with a 30 seconds timeout.WebSocketClient.shutdown()Shutdown with a 30 seconds timeout (shutdown(30, TimeUnit.SECONDS)).CallsWebSocketClient.shutdown().Initiate the client shutdown sequence.HttpServerFileUpload.streamToFileSystem(String filename) Stream the content of this upload to the given file on storage.HttpServerRequest.toNetSocket()Establish a TCP tunnel with the client.HttpServerRequest.toWebSocket()Upgrade the connection of the current request to a WebSocket.HttpConnection.updateSettings(HttpSettings settings) Send to the remote endpoint an update of this endpoint settingsHttpClientAgent.updateSSLOptions(ClientSSLOptions options) Update the client with new SSLoptions, the update happens if the options object is valid and different from the existing options object.HttpClientAgent.updateSSLOptions(ClientSSLOptions options, boolean force) Update the client with new SSLoptions, the update happens if the options object is valid and different from the existing options object.HttpServer.updateSSLOptions(ServerSSLOptions options) Update the server with new SSLoptions, the update happens if the options object is valid and different from the existing options object.HttpServer.updateSSLOptions(ServerSSLOptions options, boolean force) Update the server with new SSLoptions, the update happens if the options object is valid and different from the existing options object.WebSocketClient.updateSSLOptions(ClientSSLOptions options) Update the client with new SSLoptions, the update happens if the options object is valid and different from the existing options object.WebSocketClient.updateSSLOptions(ClientSSLOptions options, boolean force) Update the client with new SSLoptions, the update happens if the options object is valid and different from the existing options object.HttpServer.updateTrafficShapingOptions(TrafficShapingOptions options) Update the server with new trafficoptions, the update happens if the options object is valid and different from the existing options object.Write some data to the stream.Write some data to the stream.Write aStringto the request body, encoded as UTF-8.Write aStringto the request body, encoded using the encodingenc.Write some data to the stream.Write aStringto the response body, encoded in UTF-8.Write aStringto the response body, encoded using the encodingenc.Write some data to the stream.Write some data to the stream.Write some data to the stream.HttpServerResponse.writeAltSvc(String advertisement) Write an invalid input: '<'a href="https://datatracker.ietf.org/doc/html/rfc7838"HTTP Alternative Services advertisement for the given request and its authority, according to the underlying protocol.ClientWebSocket.writeBinaryMessage(Buffer data) Writes a (potentially large) piece of binary data to the connection.ServerWebSocket.writeBinaryMessage(Buffer data) Writes a (potentially large) piece of binary data to the connection.WebSocket.writeBinaryMessage(Buffer data) Writes a (potentially large) piece of binary data to the connection.WebSocketBase.writeBinaryMessage(Buffer data) Writes a (potentially large) piece of binary data to the connection.HttpServerResponse.writeContinue()Used to write an interim 100 Continue response to signify that the client should send the rest of the request.HttpClientRequest.writeCustomFrame(int type, int flags, Buffer payload) Write an HTTP/2 frame to the request, allowing to extend the HTTP/2 protocol.HttpClientRequest.writeCustomFrame(HttpFrame frame) LikeHttpClientRequest.writeCustomFrame(int, int, Buffer)but with anHttpFrame.HttpServerResponse.writeCustomFrame(int type, int flags, Buffer payload) Write an HTTP/2 frame to the response, allowing to extend the HTTP/2 protocol.HttpServerResponse.writeCustomFrame(HttpFrame frame) LikeHttpServerResponse.writeCustomFrame(int, int, Buffer)but with anHttpFrame.HttpServerResponse.writeEarlyHints(MultiMap headers) Used to write an interim 103 Early Hints response to return some HTTP headers before the final HTTP message.ClientWebSocket.writeFinalBinaryFrame(Buffer data) Write a final WebSocket binary frame to the connectionServerWebSocket.writeFinalBinaryFrame(Buffer data) Write a final WebSocket binary frame to the connectionWebSocket.writeFinalBinaryFrame(Buffer data) Write a final WebSocket binary frame to the connectionWebSocketBase.writeFinalBinaryFrame(Buffer data) Write a final WebSocket binary frame to the connectionClientWebSocket.writeFinalTextFrame(String text) Write a final WebSocket text frame to the connectionServerWebSocket.writeFinalTextFrame(String text) Write a final WebSocket text frame to the connectionWebSocket.writeFinalTextFrame(String text) Write a final WebSocket text frame to the connectionWebSocketBase.writeFinalTextFrame(String text) Write a final WebSocket text frame to the connectionClientWebSocket.writeFrame(WebSocketFrame frame) Write a WebSocket frame to the connectionServerWebSocket.writeFrame(WebSocketFrame frame) Write a WebSocket frame to the connectionWebSocket.writeFrame(WebSocketFrame frame) Write a WebSocket frame to the connectionWebSocketBase.writeFrame(WebSocketFrame frame) Write a WebSocket frame to the connectionHttpClientRequest.writeHead()Write the head of the request.HttpServerResponse.writeHead()Send the response headers.Writes a ping frame to the connection.Writes a ping frame to the connection.Writes a ping frame to the connection.Writes a ping frame to the connection.Writes a pong frame to the connection.Writes a pong frame to the connection.Writes a pong frame to the connection.Writes a pong frame to the connection.ClientWebSocket.writeTextMessage(String text) Writes a (potentially large) piece of text data to the connection.ServerWebSocket.writeTextMessage(String text) Writes a (potentially large) piece of text data to the connection.WebSocket.writeTextMessage(String text) Writes a (potentially large) piece of text data to the connection.WebSocketBase.writeTextMessage(String text) Writes a (potentially large) piece of text data to the connection.Method parameters in io.vertx.reactivex.core.http with type arguments of type FutureModifier and TypeMethodDescriptionHttpClientRequest.redirectHandler(Function<HttpClientResponse, Future<HttpClientRequest>> handler) HttpClientBuilder.withRedirectHandler(Function<HttpClientResponse, Future<RequestOptions>> handler) Set a redirect handler for the http client. -
Uses of Future in io.vertx.reactivex.core.net
Methods in io.vertx.reactivex.core.net that return FutureModifier and TypeMethodDescriptionQuicStream.abort(int error) Instruct the remote peer that this part of the stream is no longer interested in received data and wants it to cease transmission, aSTOP_SENDINGframe is sent to the remote peer.QuicEndpoint.bind(SocketAddress address) Binds a UDP socket at the givenaddress.NetClient.close()Close immediately (shutdown(0, TimeUnit.SECONDS).NetServer.close()Close the server.NetSocket.close()Close the socketQuicConnection.close()Close the connection, all associated streams will be closed before.QuicConnection.close(QuicConnectionClose payload) Close the connection, all associated streams will be closed before.QuicEndpoint.close()Close the endpoint and release all associated resources.QuicStream.close()Close the channelStreamChannel.close()Close the channelOpen a connection to a server at the specificportandhost.Open a connection to a server at the specificportandhost.NetClient.connect(ConnectOptions connectOptions) Open a connection to a server at the specificconnectOptions.NetClient.connect(SocketAddress remoteAddress) Open a connection to a server at the specificremoteAddress.NetClient.connect(SocketAddress remoteAddress, String serverName) Open a connection to a server at the specificremoteAddress.Connect to a Quic server at the specificportandhost.QuicClient.connect(int port, String host, QuicConnectOptions options) Connect to a Quic server at the specificportandhost, with specificoptions.QuicClient.connect(SocketAddress address) Connect to a Quic server.QuicClient.connect(SocketAddress address, QuicConnectOptions options) Connect to a Quic server with specificoptions.NetSocket.end()CallsNetSocket.close()Same asNetSocket.end(Buffer)but writes some data to the stream before ending.QuicStream.end()CallsStreamChannel.close()Same asStreamChannel.end(Buffer)but writes some data to the stream before ending.StreamChannel.end()CallsStreamChannel.close()Same asStreamChannel.end(Buffer)but writes some data to the stream before ending.NetServer.listen()Start listening on the port and host as configured in theNetServerOptionsused when creating the server.NetServer.listen(int port) Start listening on the specified port and host "0.0.0.0", ignoring port and host configured in theNetServerOptionsused when creating the server.Start listening on the specified port and host, ignoring port and host configured in theNetServerOptionsused when creating the server.NetServer.listen(SocketAddress localAddress) Start listening on the specified local address, ignoring port and host configured in theNetServerOptionsused when creating the server.QuicServer.listen()Start listening on theportandhostas configured in theQuicServerConfigused when creating the server.QuicServer.listen(int port) Start listening on the specified port and host "0.0.0.0".Start listening on the specifiedportandhost.QuicServer.listen(SocketAddress localAddress) Start listening on the specified local address.QuicConnection.openStream()Open a bidirectional stream to the remote endpoint.QuicConnection.openStream(boolean bidirectional) Open a stream to the remote endpoint withbidirectional parameterspecifying its directionality.NetSocket.pipeTo(WriteStream<Buffer> dst) Pipe thisReadStreamto theWriteStream.QuicStream.pipeTo(WriteStream<Buffer> dst) Pipe thisReadStreamto theWriteStream.StreamChannel.pipeTo(WriteStream<Buffer> dst) Pipe thisReadStreamto theWriteStream.QuicStream.reset(int error) Abruptly terminate the sending part of the stream with the specified application protocolerrorcode argument, aRESETframe is sent to the remote peer.Tell the operating system to stream a file as specified byfilenamedirectly from disk to the outgoing connection, bypassing userspace altogether (where supported by the underlying operating system.Tell the operating system to stream a file as specified byfilenamedirectly from disk to the outgoing connection, bypassing userspace altogether (where supported by the underlying operating system.Tell the operating system to stream a file as specified byfilenamedirectly from disk to the outgoing connection, bypassing userspace altogether (where supported by the underlying operating system.Tell the operating system to stream a file as specified byfilenamedirectly from disk to the outgoing connection, bypassing userspace altogether (where supported by the underlying operating system.Tell the operating system to stream a file as specified byfilenamedirectly from disk to the outgoing connection, bypassing userspace altogether (where supported by the underlying operating system.Tell the operating system to stream a file as specified byfilenamedirectly from disk to the outgoing connection, bypassing userspace altogether (where supported by the underlying operating system.Tell the operating system to stream a file as specified byfilenamedirectly from disk to the outgoing connection, bypassing userspace altogether (where supported by the underlying operating system.Tell the operating system to stream a file as specified byfilenamedirectly from disk to the outgoing connection, bypassing userspace altogether (where supported by the underlying operating system.Tell the operating system to stream a file as specified byfilenamedirectly from disk to the outgoing connection, bypassing userspace altogether (where supported by the underlying operating system.NetClient.shutdown()Shutdown with a 30 seconds timeout (shutdown(30, TimeUnit.SECONDS)).CallsNetClient.shutdown().Initiate the client shutdown sequence.NetServer.shutdown()Shutdown with a 30 seconds timeout (shutdown(30, TimeUnit.SECONDS)).CallsNetServer.shutdown().Initiate the server shutdown sequence.QuicConnection.shutdown()Shutdown with a 30 seconds timeout.Initiate a graceful connection shutdown, the connection is taken out of service and closed when all the inflight streams are processed, otherwise after atimeoutthe connection will be closed.QuicConnection.shutdown(Duration timeout, QuicConnectionClose payload) Initiate a graceful connection shutdown, the connection is taken out of service and closed when all the inflight streams are processed, otherwise after atimeoutthe connection will be closed.QuicEndpoint.shutdown()Shutdown the endpoint with a 30 seconds grace period (shutdown(30, TimeUnit.SECONDS)).Initiate the endpoint shutdown sequence.NetClient.updateSSLOptions(ClientSSLOptions options) Update the client with new SSLoptions, the update happens if the options object is valid and different from the existing options object.NetClient.updateSSLOptions(ClientSSLOptions options, boolean force) Update the client with new SSLoptions, the update happens if the options object is valid and different from the existing options object.NetServer.updateSSLOptions(ServerSSLOptions options) Update the server with new SSLoptions, the update happens if the options object is valid and different from the existing options object.NetServer.updateSSLOptions(ServerSSLOptions options, boolean force) Update the server with new SSLoptions, the update happens if the options object is valid and different from the existing options object.QuicServer.updateSSLOptions(ServerSSLOptions options) Update the server with new SSLoptions, the update happens if the options object is valid and different from the existing options object.QuicServer.updateSSLOptions(ServerSSLOptions options, boolean force) Update the server with new SSLoptions, the update happens if the options object is valid and different from the existing options object.NetServer.updateTrafficShapingOptions(TrafficShapingOptions options) Update the server with new trafficoptions, the update happens if the options object is valid and different from the existing options object.NetSocket.upgradeToSsl()LikeNetSocket.upgradeToSsl()with the default SSL options, without indicating a server name, without an upgrade message.NetSocket.upgradeToSsl(Buffer msg) LikeNetSocket.upgradeToSsl()with the default SSL options and without indicating a server name.NetSocket.upgradeToSsl(SSLOptions sslOptions) Upgrade channel to use SSL/TLS.NetSocket.upgradeToSsl(SSLOptions sslOptions, Buffer msg) LikeNetSocket.upgradeToSsl()without indicating a server nameNetSocket.upgradeToSsl(SSLOptions sslOptions, String serverName) LikeNetSocket.upgradeToSsl()without an upgrade message.NetSocket.upgradeToSsl(SSLOptions sslOptions, String serverName, Buffer upgrade) Upgrade the channel to use SSL/TLS, in other words proceeds to the TLS handshake.NetSocket.upgradeToSsl(String serverName) LikeNetSocket.upgradeToSsl()with the default SSL options and without an update message.NetSocket.upgradeToSsl(String serverName, Buffer msg) LikeNetSocket.upgradeToSsl()with the default SSL options.Write some data to the stream.Write aStringto the connection, encoded in UTF-8.Write aStringto the connection, encoded using the encodingenc.Write some data to the stream.Write aStringto the connection, encoded in UTF-8.Write aStringto the connection, encoded using the encodingenc.Write some data to the stream.Write aStringto the connection, encoded in UTF-8.Write aStringto the connection, encoded using the encodingenc.QuicConnection.writeDatagram(Buffer buffer) Send a datagram. -
Uses of Future in io.vertx.reactivex.core.net.endpoint
Methods in io.vertx.reactivex.core.net.endpoint that return FutureModifier and TypeMethodDescriptionEndpointResolver.resolveEndpoint(Address address) Resolver an endpoint for the specifiedaddress -
Uses of Future in io.vertx.reactivex.core.parsetools
Methods in io.vertx.reactivex.core.parsetools that return FutureModifier and TypeMethodDescriptionJsonParser.pipeTo(WriteStream<JsonEvent> dst) Pipe thisReadStreamto theWriteStream.RecordParser.pipeTo(WriteStream<Buffer> dst) Pipe thisReadStreamto theWriteStream. -
Uses of Future in io.vertx.reactivex.core.streams
Methods in io.vertx.reactivex.core.streams that return FutureModifier and TypeMethodDescriptionWriteStream.end()Ends the stream.Same asWriteStream.end()but writes some data to the stream before ending.ReadStream.pipeTo(WriteStream<T> dst) Pipe thisReadStreamto theWriteStream.Pipe.to(WriteStream<T> dst) Start to pipe the elements to the destinationWriteStream.Write some data to the stream. -
Uses of Future in io.vertx.reactivex.db2client
Methods in io.vertx.reactivex.db2client that return FutureModifier and TypeMethodDescriptionstatic Future<DB2Connection> DB2Connection.connect(Vertx vertx, DB2ConnectOptions connectOptions) Create a connection to DB2 server with the givenconnectOptions.static Future<DB2Connection> LikeDB2Connection.connect(Vertx, DB2ConnectOptions)with options build fromconnectionUri.DB2Connection.debug()Send a DEBUG command to dump debug information to the server's stdout.DB2Connection.ping()Send a PING command to check if the server is alive. -
Uses of Future in io.vertx.reactivex.eventbus.bridge.grpc
Methods in io.vertx.reactivex.eventbus.bridge.grpc that return Future -
Uses of Future in io.vertx.reactivex.ext.auth.abac
Methods in io.vertx.reactivex.ext.auth.abac that return FutureModifier and TypeMethodDescriptionPolicyBasedAuthorizationProvider.getAuthorizations(User user) Updates the user with the set of authorizations. -
Uses of Future in io.vertx.reactivex.ext.auth.authentication
Methods in io.vertx.reactivex.ext.auth.authentication that return FutureModifier and TypeMethodDescriptionAuthenticationProvider.authenticate(Credentials credentials) Authenticate a user. -
Uses of Future in io.vertx.reactivex.ext.auth.authorization
Methods in io.vertx.reactivex.ext.auth.authorization that return FutureModifier and TypeMethodDescriptionAuthorizationProvider.getAuthorizations(User user) Updates the user with the set of authorizations. -
Uses of Future in io.vertx.reactivex.ext.auth.jwt.authorization
Methods in io.vertx.reactivex.ext.auth.jwt.authorization that return FutureModifier and TypeMethodDescriptionJWTAuthorization.getAuthorizations(User user) Updates the user with the set of authorizations.MicroProfileAuthorization.getAuthorizations(User user) Updates the user with the set of authorizations. -
Uses of Future in io.vertx.reactivex.ext.auth.oauth2
Methods in io.vertx.reactivex.ext.auth.oauth2 that return FutureModifier and TypeMethodDescriptionOAuth2Auth.jWKSet()Retrieve the public server JSON Web Key (JWK) required to verify the authenticity of issued ID and access tokens.Refresh the current User (access token).Revoke an obtained access token.Revoke an obtained access or refresh token.Retrieve profile information and other attributes for a logged-in end-user. -
Uses of Future in io.vertx.reactivex.ext.auth.oauth2.authorization
Methods in io.vertx.reactivex.ext.auth.oauth2.authorization that return FutureModifier and TypeMethodDescriptionKeycloakAuthorization.getAuthorizations(User user) Updates the user with the set of authorizations.ScopeAuthorization.getAuthorizations(User user) Updates the user with the set of authorizations. -
Uses of Future in io.vertx.reactivex.ext.auth.oauth2.providers
Methods in io.vertx.reactivex.ext.auth.oauth2.providers that return FutureModifier and TypeMethodDescriptionstatic Future<OAuth2Auth> AmazonCognitoAuth.discover(Vertx vertx, OAuth2Options config) Create a OAuth2Auth provider for OpenID Connect Discovery.static Future<OAuth2Auth> AppleIdAuth.discover(Vertx vertx, PubSecKeyOptions privateKey, OAuth2Options config) Create a OAuth2Auth provider for OpenID Connect Discovery.static Future<OAuth2Auth> AzureADAuth.discover(Vertx vertx, OAuth2Options config) Create a OAuth2Auth provider for OpenID Connect Discovery.static Future<OAuth2Auth> GoogleAuth.discover(Vertx vertx, OAuth2Options config) Create a OAuth2Auth provider for OpenID Connect Discovery.static Future<OAuth2Auth> IBMCloudAuth.discover(Vertx vertx, OAuth2Options config) Create a OAuth2Auth provider for OpenID Connect Discovery.static Future<OAuth2Auth> KeycloakAuth.discover(Vertx vertx, OAuth2Options config) Create a OAuth2Auth provider for OpenID Connect Discovery.static Future<OAuth2Auth> OpenIDConnectAuth.discover(Vertx vertx, OAuth2Options config) Create a OAuth2Auth provider for OpenID Connect Discovery.static Future<OAuth2Auth> SalesforceAuth.discover(Vertx vertx, OAuth2Options config) Create a OAuth2Auth provider for OpenID Connect Discovery.static Future<OAuth2Auth> ZohoAuth.discover(Vertx vertx, String soid, OAuth2Options config) Create a OAuth2Auth provider for OpenID Connect Discovery.static Future<OAuth2Auth> ZohoAuth.discover(Vertx vertx, String dc, String soid, OAuth2Options config) Create a OAuth2Auth provider for OpenID Connect Discovery. -
Uses of Future in io.vertx.reactivex.ext.auth.otp.hotp
Methods in io.vertx.reactivex.ext.auth.otp.hotp that return FutureModifier and TypeMethodDescriptionHotpAuth.createAuthenticator(String id, OtpKey otpKey) Creating authenticator from user id and key.Method parameters in io.vertx.reactivex.ext.auth.otp.hotp with type arguments of type FutureModifier and TypeMethodDescriptionHotpAuth.authenticatorFetcher(Function<String, Future<Authenticator>> fetcher) Provide a that can fetch s from a backend given anidentifierargument.HotpAuth.authenticatorUpdater(Function<Authenticator, Future<Void>> updater) Provide a that can update or insert a . -
Uses of Future in io.vertx.reactivex.ext.auth.otp.totp
Methods in io.vertx.reactivex.ext.auth.otp.totp that return FutureModifier and TypeMethodDescriptionTotpAuth.createAuthenticator(String id, OtpKey otpKey) Creating authenticator from user id and key.Method parameters in io.vertx.reactivex.ext.auth.otp.totp with type arguments of type FutureModifier and TypeMethodDescriptionTotpAuth.authenticatorFetcher(Function<String, Future<Authenticator>> fetcher) Provide a that can fetch s from a backend given anidentifierargument.TotpAuth.authenticatorUpdater(Function<Authenticator, Future<Void>> updater) Provide a that can update or insert a . -
Uses of Future in io.vertx.reactivex.ext.auth.properties
Methods in io.vertx.reactivex.ext.auth.properties that return FutureModifier and TypeMethodDescriptionPropertyFileAuthorization.getAuthorizations(User user) Updates the user with the set of authorizations. -
Uses of Future in io.vertx.reactivex.ext.auth.sqlclient
Methods in io.vertx.reactivex.ext.auth.sqlclient that return FutureModifier and TypeMethodDescriptionSqlUserUtil.createHashedUser(String username, String hash) Insert a user into a database.SqlUserUtil.createRolePermission(String role, String permission) Insert a role permission into a database.SqlUserUtil.createUser(String username, String password) Insert a user into a database.SqlUserUtil.createUserRole(String username, String role) Insert a user role into a database.SqlAuthorization.getAuthorizations(User user) Updates the user with the set of authorizations. -
Uses of Future in io.vertx.reactivex.ext.auth.webauthn4j
Methods in io.vertx.reactivex.ext.auth.webauthn4j that return FutureModifier and TypeMethodDescriptionWebAuthn4J.createCredentialsOptions(JsonObject user) Gets a challenge and any other parameters for thenavigator.credentials.create()call.Finds an existing list of credentials for a given user name and credential ID.WebAuthn4J.getCredentialsOptions(String username) Creates an assertion challenge and any other parameters for thenavigator.credentials.get()call.CredentialStorage.storeCredential(Authenticator authenticator) Persists a new credential, bound by its user name (may benull) and credential ID (cannot benull, must be unique).CredentialStorage.updateCounter(Authenticator authenticator) Updates a previously stored credential counter, as identified by its user name (may benull) and credential ID (cannot benull, must be unique). -
Uses of Future in io.vertx.reactivex.ext.bridge
Methods in io.vertx.reactivex.ext.bridge that return Future -
Uses of Future in io.vertx.reactivex.ext.consul
Methods in io.vertx.reactivex.ext.consul that return FutureModifier and TypeMethodDescriptionConsulClient.agentInfo()Returns the configuration and member information of the local agentConsulClient.catalogDatacenters()Return all the datacenters that are known by the Consul serverConsulClient.catalogNodes()Returns the nodes registered in a datacenterConsulClient.catalogNodeServices(String node) Returns the node's registered servicesConsulClient.catalogNodeServicesWithOptions(String node, BlockingQueryOptions options) Returns the node's registered services This is blocking query unlikeConsulClient.catalogNodeServices(String)ConsulClient.catalogNodesWithOptions(NodeQueryOptions options) Returns the nodes registered in a datacenterConsulClient.catalogServiceNodes(String service) Returns the nodes providing a serviceConsulClient.catalogServiceNodesWithOptions(String service, ServiceQueryOptions options) Returns the nodes providing a serviceConsulClient.catalogServices()Returns the services registered in a datacenterConsulClient.catalogServicesWithOptions(BlockingQueryOptions options) Returns the services registered in a datacenter This is blocking query unlikeConsulClient.catalogServices()ConsulClient.cloneAclToken(String accessorId, CloneAclTokenOptions cloneAclTokenOptions) Clones an existing ACL tokenConsulClient.coordinateDatacenters()Returns the WAN network coordinates for all Consul servers, organized by DCsConsulClient.coordinateNodes()Returns the LAN network coordinates for all nodes in a given DCConsulClient.coordinateNodesWithOptions(BlockingQueryOptions options) Returns the LAN network coordinates for all nodes in a given DC This is blocking query unlikeConsulClient.coordinateNodes()ConsulClient.createAclPolicy(AclPolicy policy) Creates a new ACL policyConsulClient.createAclToken(AclToken token) Create an Acl tokenConsulClient.createPreparedQuery(PreparedQueryDefinition definition) ConsulClient.createSession()Initialize a new sessionConsulClient.createSessionWithOptions(SessionOptions options) Initialize a new sessionConsulClient.deleteAclToken(String accessorId) Deletes an ACL tokenConsulClient.deletePolicy(String id) This endpoint deletes an ACL policyConsulClient.deletePreparedQuery(String id) Deletes an existing prepared queryConsulClient.deleteValue(String key) Remove the key/value pair that corresponding to the specified keyConsulClient.deleteValues(String keyPrefix) Removes all the key/value pair that corresponding to the specified key prefixConsulClient.deregisterCatalogService(String nodeId, String serviceId) Deregister entities from the node or deregister the node itself.ConsulClient.deregisterCheck(String checkId) Remove a check from the local agent.ConsulClient.deregisterService(String id) Remove a service from the local agent.ConsulClient.destroySession(String id) Destroys the given sessionConsulClient.executePreparedQuery(String query) Executes an existing prepared query.ConsulClient.executePreparedQueryWithOptions(String query, PreparedQueryExecuteOptions options) Executes an existing prepared query.Set status of the check to "critical".ConsulClient.failCheckWithNote(String checkId, String note) Set status of the check to "critical".Fires a new user eventConsulClient.fireEventWithOptions(String name, EventOptions options) Fires a new user eventConsulClient.getAclPolicies()This endpoint lists all the ACL policies.ConsulClient.getAclTokens()Get list of Acl tokenConsulClient.getAllPreparedQueries()Returns a list of all prepared queries.Returns the list of keys that corresponding to the specified key prefix.ConsulClient.getKeysWithOptions(String keyPrefix, BlockingQueryOptions options) Returns the list of keys that corresponding to the specified key prefix.ConsulClient.getPreparedQuery(String id) Returns an existing prepared queryReturns key/value pair that corresponding to the specified key.Returns the list of key/value pairs that corresponding to the specified key prefix.ConsulClient.getValuesWithOptions(String keyPrefix, BlockingQueryOptions options) Returns the list of key/value pairs that corresponding to the specified key prefix.ConsulClient.getValueWithOptions(String key, BlockingQueryOptions options) Returns key/value pair that corresponding to the specified key.ConsulClient.healthChecks(String service) Returns the checks associated with the serviceConsulClient.healthChecksWithOptions(String service, CheckQueryOptions options) Returns the checks associated with the serviceConsulClient.healthNodesWithOptions(String node, CheckQueryOptions options) Returns the checks specific to the node provided on the path.ConsulClient.healthServiceNodes(String service, boolean passing) Returns the nodes providing the service.ConsulClient.healthServiceNodesWithOptions(String service, boolean passing, ServiceQueryOptions options) Returns the nodes providing the service.ConsulClient.healthState(HealthState healthState) Returns the checks in the specified statusConsulClient.healthStateWithOptions(HealthState healthState, CheckQueryOptions options) Returns the checks in the specified statusConsulClient.infoSession(String id) Returns the requested session informationConsulClient.infoSessionWithOptions(String id, BlockingQueryOptions options) Returns the requested session information This is blocking query unlikeConsulClient.infoSession(String)ConsulClient.leaderStatus()Get the Raft leader for the datacenter in which the agent is running.ConsulClient.listEvents()Returns the most recent events known by the agentConsulClient.listEventsWithOptions(EventListOptions options) Returns the most recent events known by the agent.ConsulClient.listNodeSessions(String nodeId) Returns the active sessions for a given nodeConsulClient.listNodeSessionsWithOptions(String nodeId, BlockingQueryOptions options) Returns the active sessions for a given node This is blocking query unlikeConsulClient.listNodeSessions(String)ConsulClient.listSessions()Returns the active sessionsConsulClient.listSessionsWithOptions(BlockingQueryOptions options) Returns the active sessions This is blocking query unlikeConsulClient.listSessions()ConsulClient.localChecks()Return all the checks that are registered with the local agent.ConsulClient.localServices()Returns list of services registered with the local agent.ConsulClient.maintenanceService(MaintenanceOptions maintenanceOptions) Places a given service into "maintenance mode"Set status of the check to "passing".ConsulClient.passCheckWithNote(String checkId, String note) Set status of the check to "passing".ConsulClient.peersStatus()Retrieves the Raft peers for the datacenter in which the the agent is running.Adds specified key/value pairConsulClient.putValueWithOptions(String key, String value, KeyValueOptions options) ConsulClient.readAclToken(String accessorId) Reads an ACL token with the given Accessor IDConsulClient.readPolicy(String id) This endpoint reads an ACL policy with the given IDConsulClient.readPolicyByName(String name) This endpoint reads an ACL policy with the given nameConsulClient.registerCatalogService(Node nodeOptions, ServiceOptions serviceOptions) Register node with external serviceConsulClient.registerCheck(CheckOptions checkOptions) Add a new check to the local agent.ConsulClient.registerService(ServiceOptions serviceOptions) Adds a new service, with an optional health check, to the local agent.ConsulClient.renewSession(String id) Renews the given session.ConsulClient.transaction(TxnRequest request) Manages multiple operations inside a single, atomic transaction.ConsulClient.updateAclToken(String accessorId, AclToken token) Update an existing Acl tokenConsulClient.updateCheck(String checkId, CheckStatus status) Set status of the check to given status.ConsulClient.updateCheckWithNote(String checkId, CheckStatus status, String note) Set status of the check to given status.ConsulClient.updatePolicy(String id, AclPolicy policy) This endpoint updates an existing ACL policyConsulClient.updatePreparedQuery(PreparedQueryDefinition definition) Set status of the check to "warning".ConsulClient.warnCheckWithNote(String checkId, String note) Set status of the check to "warning". -
Uses of Future in io.vertx.reactivex.ext.eventbus.bridge.tcp
Methods in io.vertx.reactivex.ext.eventbus.bridge.tcp that return FutureModifier and TypeMethodDescriptionTcpEventBusBridge.close()Close the current socket.BridgeEvent.future()TcpEventBusBridge.listen()Start listening on the port and host as configured in theNetServerOptionsused when creating the server.TcpEventBusBridge.listen(int port) Start listening on the specified port and host "0.0.0.0", ignoring port and host configured in theNetServerOptionsused when creating the server.Start listening on the specified port and host, ignoring port and host configured in theNetServerOptionsused when creating the server.TcpEventBusBridge.listen(SocketAddress localAddress) Start listening on the specified local address, ignoring port and host configured in the used when creating the server. -
Uses of Future in io.vertx.reactivex.ext.healthchecks
Methods in io.vertx.reactivex.ext.healthchecks that return FutureModifier and TypeMethodDescriptionHealthChecks.checkStatus()Invokes the registered procedures.HealthChecks.checkStatus(String name) Invokes the registered procedure with the given name and sub-procedures.Invokes the registered procedure with the given name and sub-procedures. -
Uses of Future in io.vertx.reactivex.ext.mail
Methods in io.vertx.reactivex.ext.mail that return FutureModifier and TypeMethodDescriptionMailClient.close()Close the MailClientMailClient.sendMail(MailMessage email) send a single mail via MailClientMethod parameters in io.vertx.reactivex.ext.mail with type arguments of type FutureModifier and TypeMethodDescriptionMailClientBuilder.withCredentialsSupplier(Supplier<Future<UsernamePasswordCredentials>> credentialsSupplier) Set a credentials supplier for the mail client. -
Uses of Future in io.vertx.reactivex.ext.mongo
Methods in io.vertx.reactivex.ext.mongo that return FutureModifier and TypeMethodDescriptionMongoClient.bulkWrite(String collection, List<BulkOperation> operations) Execute a bulk operation.MongoClient.bulkWriteWithOptions(String collection, List<BulkOperation> operations, BulkWriteOptions bulkWriteOptions) Execute a bulk operation with the specified write options.MongoClient.close()Close the client and release its resourcesMongoClient.count(String collection, JsonObject query) Count matching documents in a collection.MongoClient.countWithOptions(String collection, JsonObject query, CountOptions countOptions) Count matching documents in a collection.MongoClient.createCollection(String collectionName) Create a new collectionMongoClient.createCollectionWithOptions(String collectionName, CreateCollectionOptions collectionOptions) Create a new collection with optionsMongoClient.createDefaultGridFsBucketService()Creates aMongoGridFsClientused to interact with Mongo GridFS.MongoClient.createGridFsBucketService(String bucketName) Creates aMongoGridFsClientused to interact with Mongo GridFS.MongoClient.createIndex(String collection, JsonObject key) Creates an index.MongoClient.createIndexes(String collection, List<IndexModel> indexes) creates an indexesMongoClient.createIndexWithOptions(String collection, JsonObject key, IndexOptions options) Creates an index.Deletes a file by it's IDGets the distinct values of the specified field name.MongoClient.distinct(String collection, String fieldName, String resultClassname, DistinctOptions distinctOptions) Gets the distinct values of the specified field name.MongoClient.distinctWithQuery(String collection, String fieldName, String resultClassname, JsonObject query) Gets the distinct values of the specified field name filtered by specified query.MongoClient.distinctWithQuery(String collection, String fieldName, String resultClassname, JsonObject query, DistinctOptions distinctOptions) Gets the distinct values of the specified field name filtered by specified query.MongoGridFsClient.downloadByFileName(WriteStream<Buffer> stream, String fileName) MongoGridFsClient.downloadByFileNameWithOptions(WriteStream<Buffer> stream, String fileName, GridFsDownloadOptions options) MongoGridFsClient.downloadById(WriteStream<Buffer> stream, String id) MongoGridFsClient.downloadFile(String fileName) Downloads a file.MongoGridFsClient.downloadFileAs(String fileName, String newFileName) Downloads a file and gives it a new name.MongoGridFsClient.downloadFileByID(String id, String fileName) Downloads a file using the ID generated by GridFs.MongoGridFsClient.drop()Drops the entire file bucket with all of its contentsMongoClient.dropCollection(String collection) Drop a collectionMongoClient.dropIndex(String collection, JsonObject key) Drops the index given the keys used to create it.Drops the index given its name.MongoClient.find(String collection, JsonObject query) Find matching documents in the specified collectionMongoGridFsClient.findAllIds()Finds all file ids in the bucketMongoGridFsClient.findIds(JsonObject query) Finds all file ids that match a query.MongoClient.findOne(String collection, JsonObject query, JsonObject fields) Find a single matching document in the specified collectionMongoClient.findOneAndDelete(String collection, JsonObject query) Find a single matching document in the specified collection and delete it.MongoClient.findOneAndDeleteWithOptions(String collection, JsonObject query, FindOptions findOptions) Find a single matching document in the specified collection and delete it.MongoClient.findOneAndReplace(String collection, JsonObject query, JsonObject replace) Find a single matching document in the specified collection and replace it.MongoClient.findOneAndReplaceWithOptions(String collection, JsonObject query, JsonObject replace, FindOptions findOptions, UpdateOptions updateOptions) Find a single matching document in the specified collection and replace it.MongoClient.findOneAndUpdate(String collection, JsonObject query, JsonObject update) Find a single matching document in the specified collection and update it.MongoClient.findOneAndUpdateWithOptions(String collection, JsonObject query, JsonObject update, FindOptions findOptions, UpdateOptions updateOptions) Find a single matching document in the specified collection and update it.MongoClient.findWithOptions(String collection, JsonObject query, FindOptions options) Find matching documents in the specified collection, specifying optionsMongoClient.getCollections()Get a list of all collections in the database.MongoClient.insert(String collection, JsonObject document) Insert a document in the specified collectionMongoClient.insertWithOptions(String collection, JsonObject document, WriteOption writeOption) Insert a document in the specified collection with the specified write optionMongoClient.listIndexes(String collection) Get all the indexes in this collection.MongoClient.removeDocument(String collection, JsonObject query) Remove a single matching document from a collection and return the handler withMongoClientDeleteResultresultMongoClient.removeDocuments(String collection, JsonObject query) Remove matching documents from a collection and return the handler withMongoClientDeleteResultresultMongoClient.removeDocumentsWithOptions(String collection, JsonObject query, WriteOption writeOption) Remove matching documents from a collection with the specified write option and return the handler withMongoClientDeleteResultresultMongoClient.removeDocumentWithOptions(String collection, JsonObject query, WriteOption writeOption) Remove a single matching document from a collection with the specified write option and return the handler withMongoClientDeleteResultresultMongoClient.renameCollection(String oldCollectionName, String newCollectionName) Rename a collectionMongoClient.renameCollectionWithOptions(String oldCollectionName, String newCollectionName, RenameCollectionOptions collectionOptions) Rename a collectionMongoClient.replaceDocuments(String collection, JsonObject query, JsonObject replace) Replace matching documents in the specified collection and return the handler withMongoClientUpdateResultresultMongoClient.replaceDocumentsWithOptions(String collection, JsonObject query, JsonObject replace, UpdateOptions options) Replace matching documents in the specified collection, specifying options and return the handler withMongoClientUpdateResultresultMongoClient.runCommand(String commandName, JsonObject command) Run an arbitrary MongoDB command.MongoClient.save(String collection, JsonObject document) Save a document in the specified collectionMongoClient.saveWithOptions(String collection, JsonObject document, WriteOption writeOption) Save a document in the specified collection with the specified write optionMongoClient.updateCollection(String collection, JsonObject query, JsonArray update) Use an aggregation pipeline to update documents in the specified collection and return the handler withMongoClientUpdateResultresultMongoClient.updateCollection(String collection, JsonObject query, JsonObject update) Update matching documents in the specified collection and return the handler withMongoClientUpdateResultresultMongoClient.updateCollectionWithOptions(String collection, JsonObject query, JsonArray update, UpdateOptions options) Use an aggregation pipeline to update documents in the specified collection, specifying options and return the handler withMongoClientUpdateResultresultMongoClient.updateCollectionWithOptions(String collection, JsonObject query, JsonObject update, UpdateOptions options) Update matching documents in the specified collection, specifying options and return the handler withMongoClientUpdateResultresultMongoGridFsClient.uploadByFileName(Flowable<Buffer> stream, String fileName) MongoGridFsClient.uploadByFileName(ReadStream<Buffer> stream, String fileName) MongoGridFsClient.uploadByFileNameWithOptions(Flowable<Buffer> stream, String fileName, GridFsUploadOptions options) MongoGridFsClient.uploadByFileNameWithOptions(ReadStream<Buffer> stream, String fileName, GridFsUploadOptions options) MongoGridFsClient.uploadFile(String fileName) Upload a file to gridfsMongoGridFsClient.uploadFileWithOptions(String fileName, GridFsUploadOptions options) Upload a file to gridfs with options -
Uses of Future in io.vertx.reactivex.ext.stomp
Methods in io.vertx.reactivex.ext.stomp that return FutureModifier and TypeMethodDescriptionAborts a transaction.Aborts a transaction.Sends an acknowledgement for a specific message.Sends an acknowledgement for the given frame.Begins a transaction.Begins a transaction.StompClient.close()Closes the client.StompServer.close()Closes the server.Commits a transaction.Commits a transaction.StompClient.connect()Connects to the server using the host and port configured in the client's options.Connects to the server.StompClientConnection.disconnect()Disconnects the client.StompClientConnection.disconnect(Frame frame) Disconnects the client.StompServer.listen()Connects the STOMP server default port (61613) and network interface (0.0.0.0).StompServer.listen(int port) Connects the STOMP server to the given port.Connects the STOMP server to the given port / interface.Sends a non-acknowledgement for the given message.Sends a non-acknowledgement for the given frame.StompServerHandler.onAuthenticationRequest(StompServerConnection connection, String login, String passcode) Called when the client connects to a server requiring authentication.Sends the given frame to the server.Sends aSENDframe to the server to the given destination.Sends aSENDframe to the server to the given destination.Sends aSENDframe to the server.Subscribes to the given destination.StompClientConnection.subscribe(String destination, Map<String, String> headers, Handler<Frame> handler) Subscribes to the given destination.StompClientConnection.unsubscribe(String destination) Un-subscribes from the given destination.StompClientConnection.unsubscribe(String destination, Map<String, String> headers) Un-subscribes from the given destination. -
Uses of Future in io.vertx.reactivex.ext.unit.report
Methods in io.vertx.reactivex.ext.unit.report that return FutureModifier and TypeMethodDescriptionTestSuiteReport.pipeTo(WriteStream<TestCaseReport> dst) Pipe thisReadStreamto theWriteStream. -
Uses of Future in io.vertx.reactivex.ext.web
Methods in io.vertx.reactivex.ext.web that return FutureModifier and TypeMethodDescriptionFileUpload.delete()Delete the uploaded file on the disk.RoutingContext.end()Shortcut to the response end.Shortcut to the response end.Shortcut to the response end.UserContext.impersonate()Impersonates a second identity.UserContext.impersonate(String redirectUri) Impersonates a second identity.Encode an Object to JSON and end the request.UserContext.logout()Logout can be called from any route handler which needs to terminate a login session.Logout can be called from any route handler which needs to terminate a login session.Perform a 302 redirect tourl.UserContext.refresh()Forces the current user to re-authenticate.Forces the current user to re-authenticate.UserContext.restore()Undo a previous call to a impersonation.Undo a previous call to an impersonation.Method parameters in io.vertx.reactivex.ext.web with type arguments of type FutureModifier and TypeMethodDescription<T> RouteRoute.respond(Function<RoutingContext, Future<T>> function) Append a function request handler to the route handlers list. -
Uses of Future in io.vertx.reactivex.ext.web.client
Methods in io.vertx.reactivex.ext.web.client that return FutureModifier and TypeMethodDescriptionHttpRequest.send()Send a request, thehandlerwill receive the response as anHttpResponse.HttpRequest.sendBuffer(Buffer body) LikeHttpRequest.send()but with an HTTP requestbodybuffer.LikeHttpRequest.send()but with an HTTP requestbodymultimap encoded as form and the content type set toapplication/x-www-form-urlencoded.LikeHttpRequest.send()but with an HTTP requestbodymultimap encoded as form and the content type set toapplication/x-www-form-urlencoded.LikeHttpRequest.send()but with an HTTP requestbodyobject encoded as json and the content type set toapplication/json.HttpRequest.sendJsonObject(JsonObject body) LikeHttpRequest.send()but with an HTTP requestbodyobject encoded as json and the content type set toapplication/json.HttpRequest.sendMultipartForm(MultipartForm body) LikeHttpRequest.send()but with an HTTP requestbodymultimap encoded as form and the content type set tomultipart/form-data.HttpRequest.sendStream(Flowable<Buffer> body) LikeHttpRequest.send()but with an HTTP requestbodystream.HttpRequest.sendStream(ReadStream<Buffer> body) LikeHttpRequest.send()but with an HTTP requestbodystream.WebClient.updateSSLOptions(ClientSSLOptions options) Update the client with new SSLoptions, the update happens if the options object is valid and different from the existing options object.WebClient.updateSSLOptions(ClientSSLOptions options, boolean force) Update the client with new SSLoptions, the update happens if the options object is valid and different from the existing options object. -
Uses of Future in io.vertx.reactivex.ext.web.common.template
Methods in io.vertx.reactivex.ext.web.common.template that return Future -
Uses of Future in io.vertx.reactivex.ext.web.handler
Methods in io.vertx.reactivex.ext.web.handler that return FutureModifier and TypeMethodDescriptionSessionHandler.flush(RoutingContext ctx) Flush a context session earlier to the store, this will allow the end user to have full control on the event of a failure at the store level.SessionHandler.flush(RoutingContext ctx, boolean ignoreStatus) Flush a context session earlier to the store, this will allow the end user to have full control on the event of a failure at the store level.SessionHandler.setUser(RoutingContext context, User user) Set the user for the sessionMethod parameters in io.vertx.reactivex.ext.web.handler with type arguments of type FutureModifier and TypeMethodDescriptionSimpleAuthenticationHandler.authenticate(Function<RoutingContext, Future<User>> authenticationFunction) This function will allow you to perform authentication the way you intended to.APIKeyHandler.tokenExtractor(Function<String, Future<String>> tokenExtractor) Transform from user's token format to the AuthenticationHandler's format. -
Uses of Future in io.vertx.reactivex.ext.web.handler.graphql.ws
Methods in io.vertx.reactivex.ext.web.handler.graphql.ws that return Future -
Uses of Future in io.vertx.reactivex.ext.web.handler.sockjs
Methods in io.vertx.reactivex.ext.web.handler.sockjs that return FutureModifier and TypeMethodDescriptionSockJSSocket.end()CallSockJSSocket.close().Same asSockJSSocket.end(Buffer)but writes some data to the stream before ending.BridgeEvent.future()SockJSSocket.pipeTo(WriteStream<Buffer> dst) Pipe thisReadStreamto theWriteStream.Write aStringto the socket, encoded in UTF-8. -
Uses of Future in io.vertx.reactivex.ext.web.healthchecks
Method parameters in io.vertx.reactivex.ext.web.healthchecks with type arguments of type FutureModifier and TypeMethodDescriptionHealthCheckHandler.resultMapper(Function<CheckResult, Future<CheckResult>> resultMapper) Sets a function which will be invoked before the gets written to clients. -
Uses of Future in io.vertx.reactivex.ext.web.openapi.router
Methods in io.vertx.reactivex.ext.web.openapi.router that return FutureModifier and TypeMethodDescriptionRequestExtractor.extractValidatableRequest(RoutingContext routingContext, Operation operation) Extracts and transforms the parameters and the body of an incoming request into a that can be validated by theRequestValidator.Security.openIdConnectHandler(Function<String, Single<OAuth2AuthHandler>> factory) Configure the to be used when creating the router.Security.openIdConnectHandler(String callback, Function<String, Single<OAuth2AuthHandler>> factory) Configure the to be used when creating the router.Security.openIdConnectHandler(String callback, Function<String, Future<OAuth2AuthHandler>> factory) Configure the to be used when creating the router.Security.openIdConnectHandler(Function<String, Future<OAuth2AuthHandler>> factory) Configure the to be used when creating the router.Method parameters in io.vertx.reactivex.ext.web.openapi.router with type arguments of type FutureModifier and TypeMethodDescriptionSecurity.openIdConnectHandler(String callback, Function<String, Future<OAuth2AuthHandler>> factory) Configure the to be used when creating the router.Security.openIdConnectHandler(Function<String, Future<OAuth2AuthHandler>> factory) Configure the to be used when creating the router.Security.rxOpenIdConnectHandler(String callback, Function<String, Future<OAuth2AuthHandler>> factory) Configure the to be used when creating the router.Security.rxOpenIdConnectHandler(Function<String, Future<OAuth2AuthHandler>> factory) Configure the to be used when creating the router. -
Uses of Future in io.vertx.reactivex.ext.web.sstore
Methods in io.vertx.reactivex.ext.web.sstore that return Future -
Uses of Future in io.vertx.reactivex.grpc.client
Methods in io.vertx.reactivex.grpc.client that return FutureModifier and TypeMethodDescriptionGrpcClient.close()Close this client.GrpcClientRequest.end()Ends the stream.Same asWriteStream.end()but writes some data to the stream before ending.<Req,Resp> Future <GrpcClientRequest<Req, Resp>> ServiceInvoker.invoker(ServiceMethod<Resp, Req> method) Create a request for the given service method.GrpcClientResponse.last()GrpcClientResponse.pipeTo(WriteStream<Resp> dst) Pipe thisReadStreamto theWriteStream.GrpcClient.request()LikeGrpcClient.request(Address)with the default remote server.Connect to the remoteserverand create a request for any hosted gRPC service.<Req,Resp> Future <GrpcClientRequest<Req, Resp>> GrpcClient.request(Address server, ServiceMethod<Resp, Req> method) Connect to the remoteserverand create a request for any hosted gRPC service.<Req,Resp> Future <GrpcClientRequest<Req, Resp>> GrpcClient.request(ServiceMethod<Resp, Req> method) LikeGrpcClient.request(Address)with the default remote server.GrpcClientRequest.response()GrpcClientRequest.send(ReadStream<Req> body) Write some data to the stream. -
Uses of Future in io.vertx.reactivex.grpc.common
Methods in io.vertx.reactivex.grpc.common that return FutureModifier and TypeMethodDescriptionGrpcReadStream.end()GrpcWriteStream.end()Ends the stream.Same asWriteStream.end()but writes some data to the stream before ending.GrpcWriteStream.endMessage(GrpcMessage message) End the stream with an encoded gRPC message.GrpcReadStream.last()GrpcReadStream.pipeTo(WriteStream<T> dst) Pipe thisReadStreamto theWriteStream.Write some data to the stream.GrpcWriteStream.writeMessage(GrpcMessage message) Write an encoded gRPC message. -
Uses of Future in io.vertx.reactivex.grpc.server
Methods in io.vertx.reactivex.grpc.server that return FutureModifier and TypeMethodDescriptionGrpcServerResponse.end()Ends the stream.Same asWriteStream.end()but writes some data to the stream before ending.GrpcServerRequest.last()GrpcServerRequest.pipeTo(WriteStream<Req> dst) Pipe thisReadStreamto theWriteStream.GrpcServerResponse.send(ReadStream<Resp> body) Write some data to the stream.GrpcServerResponse.writeHead()Send the response headers. -
Uses of Future in io.vertx.reactivex.jdbcclient
Methods in io.vertx.reactivex.jdbcclient that return FutureModifier and TypeMethodDescriptionJDBCConnection.getTransactionIsolation()JDBCConnection.setTransactionIsolation(int isolationLevel) -
Uses of Future in io.vertx.reactivex.kafka.admin
Methods in io.vertx.reactivex.kafka.admin that return FutureModifier and TypeMethodDescriptionKafkaAdminClient.close()Close the admin clientKafkaAdminClient.close(long timeout) Close the admin clientKafkaAdminClient.createAcls(List<org.apache.kafka.common.acl.AclBinding> aclBindings) Create the ACL rules.KafkaAdminClient.createPartitions(Map<String, NewPartitions> partitions) Creates a batch of new partitions in the Kafka topicKafkaAdminClient.createTopics(List<NewTopic> topics) Creates a batch of new Kafka topicsKafkaAdminClient.deleteAcls(List<org.apache.kafka.common.acl.AclBindingFilter> aclBindings) Delete the ACL rules.KafkaAdminClient.deleteConsumerGroupOffsets(String groupId, Set<TopicPartition> partitions) Delete committed offsets for a set of partitions in a consumer group.KafkaAdminClient.deleteConsumerGroups(List<String> groupIds) Delete consumer groups from the cluster.KafkaAdminClient.deleteTopics(List<String> topicNames) Deletes a batch of Kafka topicsKafkaAdminClient.describeAcls(org.apache.kafka.common.acl.AclBindingFilter aclBindingFilter) Describe the ACL rules.KafkaAdminClient.describeCluster()Describe the nodes in the cluster with the default optionsKafkaAdminClient.describeCluster(DescribeClusterOptions options) LikeKafkaAdminClient.describeCluster()but allows customized options.KafkaAdminClient.describeConsumerGroups(List<String> groupIds) Describe some group ids in the cluster, with the default optionsKafkaAdminClient.describeConsumerGroups(List<String> groupIds, DescribeConsumerGroupsOptions options) LikeKafkaAdminClient.describeConsumerGroups(List)but allows customized optionsKafkaAdminClient.describeTopics(List<String> topicNames) Describe some topics in the cluster, with the default options.KafkaAdminClient.describeTopics(List<String> topicNames, DescribeTopicsOptions options) LikeKafkaAdminClient.describeTopics(List)but allows for customised otionsKafkaAdminClient.listConsumerGroups()Get the the consumer groups available in the cluster with the default optionsKafkaAdminClient.listTopics()List the topics available in the cluster with the default options. -
Uses of Future in io.vertx.reactivex.kafka.client.consumer
Methods in io.vertx.reactivex.kafka.client.consumer that return FutureModifier and TypeMethodDescriptionKafkaConsumer.assign(TopicPartition topicPartition) Manually assign a partition to this consumer.KafkaConsumer.assign(Set<TopicPartition> topicPartitions) Manually assign a list of partition to this consumer.KafkaConsumer.assignment()Get the set of partitions currently assigned to this consumer.KafkaConsumer.beginningOffsets(TopicPartition topicPartition) Get the first offset for the given partitions.KafkaConsumer.close()Close the consumerKafkaConsumer.commit()Commit current offsets for all the subscribed list of topics and partition.KafkaConsumer.committed(TopicPartition topicPartition) Get the last committed offset for the given partition (whether the commit happened by this process or another).KafkaConsumer.endOffsets(TopicPartition topicPartition) Get the last offset for the given partition.KafkaConsumer.offsetsForTimes(TopicPartition topicPartition, Long timestamp) Look up the offset for the given partition by timestamp.KafkaConsumer.partitionsFor(String topic) Get metadata about the partitions for a given topic.KafkaConsumer.pause(TopicPartition topicPartition) Suspend fetching from the requested partition.KafkaConsumer.pause(Set<TopicPartition> topicPartitions) Suspend fetching from the requested partitions.KafkaConsumer.paused()Get the set of partitions that were previously paused by a call to pause(Set).KafkaConsumer.pipeTo(WriteStream<KafkaConsumerRecord<K, V>> dst) Pipe thisReadStreamto theWriteStream.Executes a poll for getting messages from Kafka.KafkaConsumer.position(TopicPartition partition) Get the offset of the next record that will be fetched (if a record with that offset exists).KafkaConsumer.resume(TopicPartition topicPartition) Resume specified partition which have been paused with pause.KafkaConsumer.resume(Set<TopicPartition> topicPartitions) Resume specified partitions which have been paused with pause.KafkaConsumer.seek(TopicPartition topicPartition, long offset) Overrides the fetch offsets that the consumer will use on the next poll.KafkaConsumer.seek(TopicPartition topicPartition, OffsetAndMetadata offsetAndMetadata) Overrides the fetch offsets that the consumer will use on the next poll.KafkaConsumer.seekToBeginning(TopicPartition topicPartition) Seek to the first offset for each of the given partition.KafkaConsumer.seekToBeginning(Set<TopicPartition> topicPartitions) Seek to the first offset for each of the given partitions.KafkaConsumer.seekToEnd(TopicPartition topicPartition) Seek to the last offset for each of the given partition.KafkaConsumer.seekToEnd(Set<TopicPartition> topicPartitions) Seek to the last offset for each of the given partitions.Subscribe to the given topic to get dynamically assigned partitions.Subscribe to all topics matching specified pattern to get dynamically assigned partitions.Subscribe to the given list of topics to get dynamically assigned partitions.KafkaConsumer.subscription()Get the current subscription.KafkaConsumer.unsubscribe()Unsubscribe from topics currently subscribed with subscribe. -
Uses of Future in io.vertx.reactivex.kafka.client.producer
Methods in io.vertx.reactivex.kafka.client.producer that return FutureModifier and TypeMethodDescriptionKafkaProducer.abortTransaction()Aborts the ongoing transaction.KafkaProducer.beginTransaction()Starts a new kafka transaction.KafkaProducer.close()Close the producerKafkaProducer.close(long timeout) Close the producerKafkaProducer.commitTransaction()Commits the ongoing transaction.KafkaProducer.end()Ends the stream.KafkaProducer.end(KafkaProducerRecord<K, V> data) Same asWriteStream.end()but writes some data to the stream before ending.KafkaProducer.flush()Invoking this method makes all buffered records immediately available to writeKafkaProducer.initTransactions()Initializes the underlying kafka transactional producer.KafkaProducer.partitionsFor(String topic) Get the partition metadata for the give topic.KafkaProducer.send(KafkaProducerRecord<K, V> record) Asynchronously write a record to a topicKafkaProducer.write(KafkaProducerRecord<K, V> data) Write some data to the stream. -
Uses of Future in io.vertx.reactivex.mqtt
Methods in io.vertx.reactivex.mqtt that return FutureModifier and TypeMethodDescriptionMqttClient.authenticationExchange(MqttAuthenticationExchangeMessage message) It is used for Enhanced Authentication and is able to carry an authentication method and authentication data.MqttServer.close()Close the server.Connects to an MQTT server calling connectHandler after connectionConnects to an MQTT server calling connectHandler after connectionMqttClient.disconnect()Disconnects from the MQTT serverMqttServer.listen()Start the server listening for incoming connections using the specified options through the constructorMqttServer.listen(int port) Start the server listening for incoming connections on the port specified but on "0.0.0.0" as host.Start the server listening for incoming connections on the port and host specifiedMqttClient.publish(int id, String topic, Buffer payload, MqttQoS qosLevel, boolean isDup, boolean isRetain) Sends the PUBLISH message to the remote MQTT serverSends the PUBLISH message to the remote MQTT serverMqttEndpoint.publish(String topic, Buffer payload, MqttQoS qosLevel, boolean isDup, boolean isRetain) Sends the PUBLISH message to the remote MQTT clientMqttEndpoint.publish(String topic, Buffer payload, MqttQoS qosLevel, boolean isDup, boolean isRetain, int messageId) Sends the PUBLISH message to the remote MQTT server explicitly specifying the messageIdMqttEndpoint.publish(String topic, Buffer payload, MqttQoS qosLevel, boolean isDup, boolean isRetain, int messageId, MqttProperties properties) Sends the PUBLISH message to the remote MQTT server explicitly specifying the messageIdMqttClient.publishRelease(int publishMessageId) Sends the PUBREL message to the remote MQTT server.Subscribes to the topic with a specified QoS levelSubscribes to the topics with related QoS levelsMqttClient.unsubscribe(String topic) Unsubscribe from receiving messages on given topicMqttClient.unsubscribe(List<String> topics) Unsubscribe from receiving messages on given list of topic -
Uses of Future in io.vertx.reactivex.mssqlclient
Methods in io.vertx.reactivex.mssqlclient that return FutureModifier and TypeMethodDescriptionstatic Future<MSSQLConnection> MSSQLConnection.connect(Vertx vertx, MSSQLConnectOptions connectOptions) Create a connection to SQL Server with the givenconnectOptions.static Future<MSSQLConnection> LikeMSSQLConnection.connect(Vertx, MSSQLConnectOptions)with options built fromconnectionUri. -
Uses of Future in io.vertx.reactivex.mysqlclient
Methods in io.vertx.reactivex.mysqlclient that return FutureModifier and TypeMethodDescriptionMySQLConnection.changeUser(MySQLAuthOptions options) Send a CHANGE_USER command to change the user of the current connection, this operation will also reset connection state.static Future<MySQLConnection> MySQLConnection.connect(Vertx vertx, MySQLConnectOptions connectOptions) Create a connection to MySQL server with the givenconnectOptions.static Future<MySQLConnection> LikeMySQLConnection.connect(Vertx, MySQLConnectOptions)with options built fromconnectionUri.MySQLConnection.debug()Send a DEBUG command to dump debug information to the server's stdout.MySQLConnection.getInternalStatistics()Send a STATISTICS command to get a human readable string of the server internal status.MySQLConnection.ping()Send a PING command to check if the server is alive.MySQLConnection.resetConnection()Send a RESET_CONNECTION command to reset the session state.MySQLConnection.setOption(MySQLSetOption option) Send a SET_OPTION command to set options for the current connection.MySQLConnection.specifySchema(String schemaName) Send a INIT_DB command to change the default schema of the connection. -
Uses of Future in io.vertx.reactivex.openapi.contract
Methods in io.vertx.reactivex.openapi.contract that return FutureModifier and TypeMethodDescriptionstatic Future<OpenAPIContract> OpenAPIContract.from(Vertx vertx, JsonObject contract) Resolves / dereferences the passed contract and creates anOpenAPIContractinstance.static Future<OpenAPIContract> OpenAPIContract.from(Vertx vertx, JsonObject contract, Map<String, JsonObject> additionalContractParts) Resolves / dereferences the passed contract and creates anOpenAPIContractinstance.static Future<OpenAPIContract> Resolves / dereferences the passed contract and creates anOpenAPIContractinstance.static Future<OpenAPIContract> OpenAPIContract.from(Vertx vertx, String contractPath, Map<String, String> additionalContractPartPaths) Resolves / dereferences the passed contract and creates anOpenAPIContractinstance. -
Uses of Future in io.vertx.reactivex.openapi.validation
Methods in io.vertx.reactivex.openapi.validation that return FutureModifier and TypeMethodDescriptionstatic Future<ValidatableRequest> ValidatableRequest.of(HttpServerRequest request, Operation operation) Creates a newValidatableRequestobject based on the passed and .ValidatedResponse.send(HttpServerResponse serverResponse) Add all parameters from the validated response to the passed and send it.RequestValidator.validate(HttpServerRequest request) LikeRequestValidator.validate(HttpServerRequest), but the operationId andValidatableRequestare determined from the passed request.RequestValidator.validate(HttpServerRequest request, String operationId) LikeRequestValidator.validate(HttpServerRequest), butValidatableRequestare directly extracted from the passed request.RequestValidator.validate(ValidatableRequest params, String operationId) Validates the passed request parameters against the operation defined in the related OpenAPI contract. -
Uses of Future in io.vertx.reactivex.oracleclient
Methods in io.vertx.reactivex.oracleclient that return FutureModifier and TypeMethodDescriptionstatic Future<OracleConnection> OracleConnection.connect(Vertx vertx, OracleConnectOptions connectOptions) Create a connection to Oracle with the givenconnectOptions.static Future<OracleConnection> LikeOracleConnection.connect(Vertx, OracleConnectOptions)with options built fromconnectionUri. -
Uses of Future in io.vertx.reactivex.pgclient
Methods in io.vertx.reactivex.pgclient that return FutureModifier and TypeMethodDescriptionPgConnection.cancelRequest()Send a request cancellation message to tell the server to cancel processing request in this connection.static Future<PgConnection> LikePgConnection.connect(Vertx, PgConnectOptions)with options build from the environment variables.static Future<PgConnection> PgConnection.connect(Vertx vertx, PgConnectOptions options) Connects to the database and returns the connection if that succeeds.static Future<PgConnection> LikePgConnection.connect(Vertx, PgConnectOptions)with options build fromconnectionUri. -
Uses of Future in io.vertx.reactivex.pgclient.pubsub
Methods in io.vertx.reactivex.pgclient.pubsub that return Future -
Uses of Future in io.vertx.reactivex.rabbitmq
Methods in io.vertx.reactivex.rabbitmq that return FutureModifier and TypeMethodDescriptionRabbitMQClient.addConfirmListener(int maxQueueSize) Add a Confirm Listener to the channel.RabbitMQClient.basicAck(long deliveryTag, boolean multiple) Acknowledge one or several received messages.RabbitMQClient.basicConsumer(String queue) RabbitMQClient.basicConsumer(String queue, QueueOptions options) Create a consumer with the givenoptions.Retrieve a message from a queue using AMQP.Basic.GetRabbitMQClient.basicNack(long deliveryTag, boolean multiple, boolean requeue) Reject one or several received messages.RabbitMQClient.basicPublish(String exchange, String routingKey, com.rabbitmq.client.BasicProperties properties, Buffer body) Publish a message.RabbitMQClient.basicPublish(String exchange, String routingKey, Buffer body) Publish a message.RabbitMQClient.basicPublishWithDeliveryTag(String exchange, String routingKey, com.rabbitmq.client.BasicProperties properties, Buffer body, Handler<Long> deliveryTagHandler) Publish a message.RabbitMQClient.basicQos(int prefetchCount) Request a specific prefetchCount "quality of service" settings for this channel.RabbitMQClient.basicQos(int prefetchCount, boolean global) Request a specific prefetchCount "quality of service" settings for this channel.RabbitMQClient.basicQos(int prefetchSize, int prefetchCount, boolean global) Request specific "quality of service" settings.RabbitMQConsumer.cancel()Stop message consumption from a queue.RabbitMQClient.confirmSelect()Enables publisher acknowledgements on this channel.RabbitMQClient.exchangeBind(String destination, String source, String routingKey) Bind an exchange to an exchange.RabbitMQClient.exchangeBind(String destination, String source, String routingKey, Map<String, Object> arguments) Bind an exchange to an exchange.RabbitMQClient.exchangeDeclare(String exchange, String type, boolean durable, boolean autoDelete) Declare an exchange.RabbitMQClient.exchangeDeclare(String exchange, String type, boolean durable, boolean autoDelete, JsonObject config) Declare an exchange with additional parameters such as dead lettering, an alternate exchange or TTL.RabbitMQClient.exchangeDelete(String exchange) Delete an exchange, without regard for whether it is in use or not.RabbitMQClient.exchangeUnbind(String destination, String source, String routingKey) Unbind an exchange from an exchange.RabbitMQClient.exchangeUnbind(String destination, String source, String routingKey, Map<String, Object> arguments) Unbind an exchange from an exchange.RabbitMQClient.messageCount(String queue) Returns the number of messages in a queue ready to be delivered.RabbitMQConsumer.pipeTo(WriteStream<RabbitMQMessage> dst) Pipe thisReadStreamto theWriteStream.RabbitMQPublisher.publish(String exchange, String routingKey, com.rabbitmq.client.BasicProperties properties, Buffer body) Publish a message.RabbitMQPublisher.publishConfirm(String exchange, String routingKey, com.rabbitmq.client.BasicProperties properties, Buffer body) Publish a message and complete when publish confirm has returned.Bind a queue to an exchangeRabbitMQClient.queueBind(String queue, String exchange, String routingKey, Map<String, Object> arguments) Bind a queue to an exchangeFuture<com.rabbitmq.client.AMQP.Queue.DeclareOk> RabbitMQClient.queueDeclare(String queue, boolean durable, boolean exclusive, boolean autoDelete) Declare a queueFuture<com.rabbitmq.client.AMQP.Queue.DeclareOk> RabbitMQClient.queueDeclare(String queue, boolean durable, boolean exclusive, boolean autoDelete, JsonObject config) Declare a queue with config optionsRabbitMQClient.queueDeclareAuto()Actively declare a server-named exclusive, autodelete, non-durable queue.Future<com.rabbitmq.client.AMQP.Queue.DeleteOk> RabbitMQClient.queueDelete(String queue) Delete a queue, without regard for whether it is in use or has messages on itFuture<com.rabbitmq.client.AMQP.Queue.DeleteOk> RabbitMQClient.queueDeleteIf(String queue, boolean ifUnused, boolean ifEmpty) Delete a queueRabbitMQClient.queueUnbind(String queue, String exchange, String routingKey) Unbind a queue from an exchangeRabbitMQClient.queueUnbind(String queue, String exchange, String routingKey, Map<String, Object> arguments) Unbind a queue from an exchangeRabbitMQClient.restartConnect(int attempts) restart the rabbitMQ connect.RabbitMQClient.start()Start the rabbitMQ client.RabbitMQPublisher.start()Start the rabbitMQ publisher.RabbitMQClient.stop()Stop the rabbitMQ client.RabbitMQPublisher.stop()Stop the rabbitMQ publisher.RabbitMQClient.waitForConfirms()Wait until all messages published since the last call have been either ack'd or nack'd by the broker.RabbitMQClient.waitForConfirms(long timeout) Wait until all messages published since the last call have been either ack'd or nack'd by the broker; or until timeout elapses. -
Uses of Future in io.vertx.reactivex.redis.client
Methods in io.vertx.reactivex.redis.client that return FutureModifier and TypeMethodDescriptionA container for Access List Control commands.A container for Access List Control commands.Appends a string to the value of a key.Appends a string to the value of a key.RedisAPI.asking()Signals that a cluster client is following an -ASK redirect.ValkeyAPI.asking()Signals that a cluster client is following an -ASK redirect.Authenticates the connection.Authenticates the connection.Sends a list of commands in a single IO operation, this prevents any inter twinning to happen from other client users.Sends a list of commands in a single IO operation, this prevents any inter twinning to happen from other client users.Adds an item to a Bloom Filter.Adds an item to a Bloom Filter.Returns the cardinality of a Bloom filter.Returns the cardinality of a Bloom filter.Checks whether an item exists in a Bloom Filter.Checks whether an item exists in a Bloom Filter.Returns information about a Bloom Filter.Adds one or more items to a Bloom Filter.RedisAPI.bfLoadchunk(String arg0, String arg1, String arg2) Restores a filter previously saved using SCANDUMP.RedisAPI.bfLoadchunk(List<String> args) Restores a filter previously saved using SCANDUMP.Adds one or more items to a Bloom Filter.Checks whether one or more items exist in a Bloom Filter.Creates a new Bloom Filter.RedisAPI.bfScandump(String arg0, String arg1) Begins an incremental save of the bloom filter.RedisAPI.bfScandump(List<String> args) Begins an incremental save of the bloom filter.RedisAPI.bgrewriteaof()Asynchronously rewrites the append-only file to disk.ValkeyAPI.bgrewriteaof()Asynchronously rewrites the append-only file to disk.Asynchronously saves the database(s) to disk.Asynchronously saves the database(s) to disk.Counts the number of set bits (population counting) in a string.Counts the number of set bits (population counting) in a string.Performs arbitrary bitfield integer operations on strings.Performs arbitrary bitfield integer operations on strings.RedisAPI.bitfieldRo(List<String> args) Performs arbitrary read-only bitfield integer operations on strings.ValkeyAPI.bitfieldRo(List<String> args) Performs arbitrary read-only bitfield integer operations on strings.Performs bitwise operations on multiple strings, and stores the result.Performs bitwise operations on multiple strings, and stores the result.Finds the first set (1) or clear (0) bit in a string.Finds the first set (1) or clear (0) bit in a string.Pops an element from a list, pushes it to another list and returns it.Pops an element from a list, pushes it to another list and returns it.Pops the first element from one of multiple lists.Pops the first element from one of multiple lists.Removes and returns the first element in a list.Removes and returns the first element in a list.Removes and returns the last element in a list.Removes and returns the last element in a list.RedisAPI.brpoplpush(String arg0, String arg1, String arg2) Pops an element from a list, pushes it to another list and returns it.ValkeyAPI.brpoplpush(String arg0, String arg1, String arg2) Pops an element from a list, pushes it to another list and returns it.Removes and returns a member by score from one or more sorted sets.Removes and returns a member by score from one or more sorted sets.Removes and returns the member with the highest score from one or more sorted sets.Removes and returns the member with the highest score from one or more sorted sets.Removes and returns the member with the lowest score from one or more sorted sets.Removes and returns the member with the lowest score from one or more sorted sets.Adds an item to a Cuckoo Filter.Adds an item to a Cuckoo Filter.Adds an item to a Cuckoo Filter if the item did not exist previously.Adds an item to a Cuckoo Filter if the item did not exist previously.Return the number of times an item might be in a Cuckoo Filter.Return the number of times an item might be in a Cuckoo Filter.Deletes an item from a Cuckoo Filter.Deletes an item from a Cuckoo Filter.Checks whether one or more items exist in a Cuckoo Filter.Checks whether one or more items exist in a Cuckoo Filter.Returns information about a Cuckoo Filter.Returns information about a Cuckoo Filter.Adds one or more items to a Cuckoo Filter.RedisAPI.cfInsertnx(List<String> args) Adds one or more items to a Cuckoo Filter if the items did not exist previously.RedisAPI.cfLoadchunk(String arg0, String arg1, String arg2) Restores a filter previously saved using SCANDUMP.RedisAPI.cfLoadchunk(List<String> args) Restores a filter previously saved using SCANDUMP.Checks whether one or more items exist in a Cuckoo Filter.Creates a new Cuckoo Filter.RedisAPI.cfScandump(String arg0, String arg1) Begins an incremental save of the bloom filter.RedisAPI.cfScandump(List<String> args) Begins an incremental save of the bloom filter.A container for client connection commands.A container for client connection commands.Redis.close()Closes the client and terminates any connection.RedisConnection.close()Closes the connection or returns to the pool.A container for Redis Cluster commands.A container for Cluster commands.Increases the count of one or more items by increment.Returns information about a sketch.Returns information about a sketch.RedisAPI.cmsInitbydim(String arg0, String arg1, String arg2) Initializes a Count-Min Sketch to dimensions specified by user.RedisAPI.cmsInitbydim(List<String> args) Initializes a Count-Min Sketch to dimensions specified by user.RedisAPI.cmsInitbyprob(String arg0, String arg1, String arg2) Initializes a Count-Min Sketch to accommodate requested tolerances.RedisAPI.cmsInitbyprob(List<String> args) Initializes a Count-Min Sketch to accommodate requested tolerances.Merges several sketches into one sketch.Returns the count for one or more items in a sketch.Returns detailed information about all commands.Returns detailed information about all commands.ValkeyAPI.commandlog(List<String> args) A container for command log commands.A container for server configuration commands.A container for server configuration commands.Redis.connect()Connects to the Redis server.Copies the value of a key to a new key.Copies the value of a key to a new key.RedisAPI.dbsize()Returns the number of keys in the database.ValkeyAPI.dbsize()Returns the number of keys in the database.A container for debugging commands.A container for debugging commands.Decrements the integer value of a key by one.Decrements the integer value of a key by one.Decrements a number from the integer value of a key.Decrements a number from the integer value of a key.Deletes one or more keys.Deletes one or more keys.Conditionally removes the specified key based on value or digest comparison.Delete key if value matches string.Returns the XXH3 hash of a string value.RedisAPI.discard()Discards a transaction.ValkeyAPI.discard()Discards a transaction.Returns a serialized representation of the value stored at a key.Returns a serialized representation of the value stored at a key.Returns the given string.Returns the given string.Executes a server-side Lua script.Executes a server-side Lua script.Executes a read-only server-side Lua script.Executes a read-only server-side Lua script.Executes a server-side Lua script by SHA1 digest.Executes a server-side Lua script by SHA1 digest.Executes a read-only server-side Lua script by SHA1 digest.Executes a read-only server-side Lua script by SHA1 digest.RedisAPI.exec()Executes all commands in a transaction.ValkeyAPI.exec()Executes all commands in a transaction.Determines whether one or more keys exist.Determines whether one or more keys exist.Sets the expiration time of a key in seconds.Sets the expiration time of a key in seconds.Sets the expiration time of a key to a Unix timestamp.Sets the expiration time of a key to a Unix timestamp.RedisAPI.expiretime(String arg0) Returns the expiration time of a key as a Unix timestamp.ValkeyAPI.expiretime(String arg0) Returns the expiration time of a key as a Unix timestamp.Starts a coordinated failover from a server to one of its replicas.Starts a coordinated failover from a server to one of its replicas.Invokes a function.Invokes a function.Invokes a read-only function.Invokes a read-only function.Removes all keys from all databases.Removes all keys from all databases.Remove all keys from the current database.Remove all keys from the current database.RedisAPI.ftAggregate(List<String> args) Run a search query on an index and perform aggregate transformations on the results.RedisAPI.ftAliasadd(List<String> args) Adds an alias to the index.RedisAPI.ftAliasaddifnx(List<String> args) Adds an alias to the index.RedisAPI.ftAliasdel(List<String> args) Deletes an alias from the index.RedisAPI.ftAliasdelifx(List<String> args) Deletes an alias from the index.RedisAPI.ftAliasupdate(List<String> args) Adds or updates an alias to the index.Adds a new field to the index.RedisAPI.ftAlterifnx(List<String> args) Adds a new field to the index.Creates an index with the given spec.RedisAPI.ftCreateifnx(List<String> args) Creates an index with the given spec.Adds terms to a dictionary.Deletes terms from a dictionary.RedisAPI.ftDictdump(List<String> args) Dumps all terms in the given dictionary.RedisAPI.ftDropindex(List<String> args) Deletes the index.RedisAPI.ftDropindexifx(List<String> args) Deletes the index.Returns the execution plan for a complex query.RedisAPI.ftExplaincli(List<String> args) Returns the execution plan for a complex query.Performs hybrid search combining text search and vector similarity search.Returns information and statistics on the index.Returns a list of all existing indexes.Performs a `FT.SEARCH` or `FT.AGGREGATE` command and collects performance information.Searches the index with a textual query, returning either documents or just ids.RedisAPI.ftSpellcheck(List<String> args) Performs spelling correction on a query, returning suggestions for misspelled terms.Adds a suggestion string to an auto-complete suggestion dictionary.Deletes a string from a suggestion index.Gets completion suggestions for a prefix.Gets the size of an auto-complete suggestion dictionary.Dumps the contents of a synonym group.RedisAPI.ftSynupdate(List<String> args) Creates or updates a synonym group with additional terms.Returns the distinct tags indexed in a Tag field.A container for function commands.A container for function commands.Adds one or more members to a geospatial index.Adds one or more members to a geospatial index.Returns the distance between two members of a geospatial index.Returns the distance between two members of a geospatial index.Returns members from a geospatial index as geohash strings.Returns members from a geospatial index as geohash strings.Returns the longitude and latitude of members from a geospatial index.Returns the longitude and latitude of members from a geospatial index.Queries a geospatial index for members within a distance from a coordinate, optionally stores the result.Queries a geospatial index for members within a distance from a coordinate, optionally stores the result.RedisAPI.georadiusbymember(List<String> args) Queries a geospatial index for members within a distance from a member, optionally stores the result.ValkeyAPI.georadiusbymember(List<String> args) Queries a geospatial index for members within a distance from a member, optionally stores the result.RedisAPI.georadiusbymemberRo(List<String> args) Returns members from a geospatial index that are within a distance from a member.ValkeyAPI.georadiusbymemberRo(List<String> args) Returns members from a geospatial index that are within a distance from a member.RedisAPI.georadiusRo(List<String> args) Returns members from a geospatial index that are within a distance from a coordinate.ValkeyAPI.georadiusRo(List<String> args) Returns members from a geospatial index that are within a distance from a coordinate.Queries a geospatial index for members inside an area of a box or a circle.Queries a geospatial index for members inside an area of a box, circle, or a polygon.RedisAPI.geosearchstore(List<String> args) Queries a geospatial index for members inside an area of a box or a circle, optionally stores the result.ValkeyAPI.geosearchstore(List<String> args) Queries a geospatial index for members inside an area of a box, a circle, or a polygon, optionally stores the result.Returns the string value of a key.Returns the string value of a key.Returns a bit value by offset.Returns a bit value by offset.Returns the string value of a key after deleting the key.Returns the string value of a key after deleting the key.Returns the string value of a key after setting its expiration time.Returns the string value of a key after setting its expiration time.Returns a substring of the string stored at a key.Returns a substring of the string stored at a key.Returns the previous string value of a key after setting it to a new value.Returns the previous string value of a key after setting it to a new value.RedisAPI.graphConfig(List<String> args) RedisAPI.graphDebug(List<String> args) RedisAPI.graphDelete(List<String> args) RedisAPI.graphExplain(List<String> args) RedisAPI.graphProfile(List<String> args) RedisAPI.graphQuery(List<String> args) RedisAPI.graphRoQuery(List<String> args) RedisAPI.graphSlowlog(List<String> args) RedisCluster.groupByNodes(List<Request> requests) Groups therequestsinto aRequestGrouping, which contains: keyed requests: requests that include a key and it is therefore possible to determine to which master node they should be sent; all requests in each inner list in thekeyedcollection are guaranteed to be sent to the same master node; unkeyed requests: requests that do not include a key and it is therefore not possible to determine to which master node they should be sent. If any of therequestsincludes multiple keys that belong to different master nodes, the resulting future will fail.Deletes one or more fields and their values from a hash.Deletes one or more fields and their values from a hash.Handshakes with the Redis server.Handshakes with the server.Determines whether a field exists in a hash.Determines whether a field exists in a hash.Set expiry for hash field using relative time to expire (seconds).Set expiry time on hash fields.Set expiry for hash field using an absolute Unix timestamp (seconds).Set expiry time on hash fields.RedisAPI.hexpiretime(List<String> args) Returns the expiration time of a hash field as a Unix timestamp, in seconds.ValkeyAPI.hexpiretime(List<String> args) Returns Unix timestamps in seconds since the epoch at which the given key's field(s) will expire.Returns the value of a field in a hash.Returns the value of a field in a hash.Returns all fields and values in a hash.Returns all fields and values in a hash.Returns the value of a field and deletes it from the hash.Get the value of one or more fields of a given hash key, and optionally set their expiration.Get the value of one or more fields of a given hash key, and optionally set their expiration time or time-to-live (TTL).Increments the integer value of a field in a hash by a number.Increments the integer value of a field in a hash by a number.RedisAPI.hincrbyfloat(String arg0, String arg1, String arg2) Increments the floating point value of a field by a number.ValkeyAPI.hincrbyfloat(String arg0, String arg1, String arg2) Increments the floating point value of a field by a number.Returns all fields in a hash.Returns all fields in a hash.Returns the number of fields in a hash.Returns the number of fields in a hash.Returns the values of all fields in a hash.Returns the values of all fields in a hash.Sets the values of multiple fields.Sets the values of multiple fields.A container for hotkeys tracking commands.Removes the expiration time for each specified field.Remove the existing expiration on a hash key's field(s).Set expiry for hash field using relative time to expire (milliseconds).Set expiry time on hash object.RedisAPI.hpexpireat(List<String> args) Set expiry for hash field using an absolute Unix timestamp (milliseconds).ValkeyAPI.hpexpireat(List<String> args) Set expiration time on hash field.RedisAPI.hpexpiretime(List<String> args) Returns the expiration time of a hash field as a Unix timestamp, in msec.ValkeyAPI.hpexpiretime(List<String> args) Returns the Unix timestamp in milliseconds since Unix epoch at which the given key's field(s) will expire.Returns the TTL in milliseconds of a hash field.Returns the remaining time to live in milliseconds of a hash key's field(s) that have an associated expiration.RedisAPI.hrandfield(List<String> args) Returns one or more random fields from a hash.ValkeyAPI.hrandfield(List<String> args) Returns one or more random fields from a hash.Iterates over fields and values of a hash.Iterates over fields and values of a hash.Creates or modifies the value of a field in a hash.Creates or modifies the value of a field in a hash.Set the value of one or more fields of a given hash key, and optionally set their expiration.Set the value of one or more fields of a given hash key, and optionally set their expiration time.Sets the value of a field in a hash only when the field doesn't exist.Sets the value of a field in a hash only when the field doesn't exist.Returns the length of the value of a field.Returns the length of the value of a field.Returns the TTL in seconds of a hash field.Returns the remaining time to live (in seconds) of a hash key's field(s) that have an associated expiration.Returns all values in a hash.Returns all values in a hash.Increments the integer value of a key by one.Increments the integer value of a key by one.Increments the integer value of a key by a number.Increments the integer value of a key by a number.RedisAPI.incrbyfloat(String arg0, String arg1) Increment the floating point value of a key by a number.ValkeyAPI.incrbyfloat(String arg0, String arg1) Increment the floating point value of a key by a number.Returns information and statistics about the server.Returns information and statistics about the server.RedisAPI.jsonArrappend(List<String> args) Append the JSON values into the array at path after the last element in it.RedisAPI.jsonArrindex(List<String> args) Search for the first occurrence of a JSON value in an array.RedisAPI.jsonArrinsert(List<String> args) Insert the json values into the array at path before the index (shifts to the right).RedisAPI.jsonArrlen(List<String> args) Report the length of the JSON array at path in key.RedisAPI.jsonArrpop(List<String> args) Remove and return the element at the specified index in the array at path.RedisAPI.jsonArrtrim(String arg0, String arg1, String arg2, String arg3) Trim an array so that it contains only the specified inclusive range of elements.RedisAPI.jsonArrtrim(List<String> args) Trim an array so that it contains only the specified inclusive range of elements.Clear container values (arrays/objects) and set numeric values to 0.This is a container command for debugging related tasks.Delete a value.RedisAPI.jsonForget(List<String> args) Delete a value.Get JSON value at path.Merge a given JSON value into matching paths.Return the values at path from multiple key arguments.Set or update one or more JSON values according to the specified key-path-value triplets.RedisAPI.jsonNumincrby(String arg0, String arg1, String arg2) Increment the number value stored at path by number.RedisAPI.jsonNumincrby(List<String> args) Increment the number value stored at path by number.RedisAPI.jsonNummultby(String arg0, String arg1, String arg2) Multiply the number value stored at path by number.RedisAPI.jsonNummultby(List<String> args) Multiply the number value stored at path by number.RedisAPI.jsonNumpowby(String arg0, String arg1, String arg2) Raise the number value stored at path to the power of number.RedisAPI.jsonNumpowby(List<String> args) Raise the number value stored at path to the power of number.RedisAPI.jsonObjkeys(List<String> args) Return the keys in the object that's referenced by path.RedisAPI.jsonObjlen(List<String> args) Report the number of keys in the JSON object at path in key.Return the JSON in key in Redis serialization protocol specification form.Set the JSON value at path in key.RedisAPI.jsonStrappend(List<String> args) Append the json-string values to the string at path.RedisAPI.jsonStrlen(List<String> args) Report the length of the JSON String at path in key.RedisAPI.jsonToggle(String arg0, String arg1) Toggle the boolean value stored at path.RedisAPI.jsonToggle(List<String> args) Toggle the boolean value stored at path.Report the type of JSON value at path.Returns all key names that match a pattern.Returns all key names that match a pattern.RedisAPI.lastsave()Returns the Unix timestamp of the last successful save to disk.ValkeyAPI.lastsave()Returns the Unix timestamp of the last successful save to disk.A container for latency diagnostics commands.A container for latency diagnostics commands.Finds the longest common substring.Finds the longest common substring.Returns an element from a list by its index.Returns an element from a list by its index.Inserts an element before or after another element in a list.Inserts an element before or after another element in a list.Returns the length of a list.Returns the length of a list.Returns an element after popping it from one list and pushing it to another.Returns an element after popping it from one list and pushing it to another.Returns multiple elements from a list after removing them.Returns multiple elements from a list after removing them.Displays computer art and the Redis version.Displays computer art and the server version.Returns the first elements in a list after removing it.Returns and removes one or more elements from the beginning of a list.Returns the index of matching elements in a list.Returns the index of matching elements in a list.Prepends one or more elements to a list.Prepends one or more elements to a list.Prepends one or more elements to a list only when the list exists.Prepends one or more elements to a list only when the list exists.Returns a range of elements from a list.Returns a range of elements from a list.Removes elements from a list.Removes elements from a list.Sets the value of an element in a list by its index.Sets the value of an element in a list by its index.Removes elements from both ends a list.Removes elements from both ends a list.A container for memory diagnostics commands.A container for memory diagnostics commands.Atomically returns the string values of one or more keys.Atomically returns the string values of one or more keys.Atomically transfers a key from one Redis instance to another.Atomically transfers a key from one instance to another.A container for module commands.A container for module commands.RedisAPI.monitor()Listens for all requests received by the server in real-time.ValkeyAPI.monitor()Listens for all requests received by the server in real-time.Moves a key to another database.Moves a key to another database.Atomically creates or modifies the string values of one or more keys.Atomically creates or modifies the string values of one or more keys.Atomically sets multiple string keys with a shared expiration in a single operation.Atomically modifies the string values of one or more keys only when all keys don't exist.Atomically modifies the string values of one or more keys only when all keys don't exist.RedisAPI.multi()Starts a transaction.ValkeyAPI.multi()Starts a transaction.A container for object introspection commands.A container for object introspection commands.RedisCluster.onAllMasterNodes(Request request) Runs therequestagainst all master nodes in the cluster.RedisCluster.onAllNodes(Request request) Runs therequestagainst all nodes in the cluster.Removes the expiration time of a key.Removes the expiration time of a key.Sets the expiration time of a key in milliseconds.Sets the expiration time of a key in milliseconds.Sets the expiration time of a key to a Unix milliseconds timestamp.Sets the expiration time of a key to a Unix milliseconds timestamp.RedisAPI.pexpiretime(String arg0) Returns the expiration time of a key as a Unix milliseconds timestamp.ValkeyAPI.pexpiretime(String arg0) Returns the expiration time of a key as a Unix milliseconds timestamp.Adds elements to a HyperLogLog key.Adds elements to a HyperLogLog key.Returns the approximated cardinality of the set(s) observed by the HyperLogLog key(s).Returns the approximated cardinality of the set(s) observed by the HyperLogLog key(s).Internal commands for debugging HyperLogLog values.Internal commands for debugging HyperLogLog values.Merges one or more HyperLogLog values into a single key.Merges one or more HyperLogLog values into a single key.RedisAPI.pfselftest()An internal command for testing HyperLogLog values.ValkeyAPI.pfselftest()An internal command for testing HyperLogLog values.Returns the server's liveliness response.Returns the server's liveliness response.RedisConnection.pipeTo(WriteStream<Response> dst) Pipe thisReadStreamto theWriteStream.Sets both string value and expiration time in milliseconds of a key.Sets both string value and expiration time in milliseconds of a key.RedisAPI.psubscribe(List<String> args) Listens for messages published to channels that match one or more patterns.ValkeyAPI.psubscribe(List<String> args) Listens for messages published to channels that match one or more patterns.An internal command used in replication.An internal command used in replication.Returns the expiration time in milliseconds of a key.Returns the expiration time in milliseconds of a key.Posts a message to a channel.Posts a message to a channel.A container for Pub/Sub commands.A container for Pub/Sub commands.RedisAPI.punsubscribe(List<String> args) Stops listening to messages published to channels that match one or more patterns.ValkeyAPI.punsubscribe(List<String> args) Stops listening to messages published to channels that match one or more patterns.Closes the connection.Closes the connection.RedisAPI.randomkey()Returns a random key name from the database.ValkeyAPI.randomkey()Returns a random key name from the database.RedisAPI.readonly()Enables read-only queries for a connection to a Redis Cluster replica node.ValkeyAPI.readonly()Enables read-only queries for a connection to a Valkey replica node.RedisAPI.readwrite()Enables read-write queries for a connection to a Reids Cluster replica node.ValkeyAPI.readwrite()Enables read-write queries for a connection to a Valkey replica node.Renames a key and overwrites the destination.Renames a key and overwrites the destination.Renames a key only when the target key name doesn't exist.Renames a key only when the target key name doesn't exist.An internal command for configuring the replication stream.An internal command for configuring the replication stream.Configures a server as replica of another, or promotes it to a master.Configures a server as replica of another, or promotes it to a primary.RedisAPI.reset()Resets the connection.ValkeyAPI.reset()Resets the connection.Creates a key from the serialized representation of a value.Creates a key from the serialized representation of a value.RedisAPI.restoreAsking(List<String> args) An internal command for migrating keys in a cluster.ValkeyAPI.restoreAsking(List<String> args) An internal command for migrating keys in a cluster.RedisAPI.role()Returns the replication role.ValkeyAPI.role()Returns the replication role.Returns and removes the last elements of a list.Returns and removes one or more elements from the end of a list.Returns the last element of a list after removing and pushing it to another list.Returns the last element of a list after removing and pushing it to another list.Appends one or more elements to a list.Appends one or more elements to a list.Appends an element to a list only when the list exists.Appends one or more elements to a list only when the list exists.Adds one or more members to a set.Adds one or more members to a set.RedisAPI.save()Synchronously saves the database(s) to disk.ValkeyAPI.save()Synchronously saves the database(s) to disk.Iterates over the key names in the database.Iterates over the key names in the database.Returns the number of members in a set.Returns the number of members in a set.A container for Lua scripts management commands.A container for Lua scripts management commands.Returns the difference of multiple sets.Returns the difference of multiple sets.RedisAPI.sdiffstore(List<String> args) Stores the difference of multiple sets in a key.ValkeyAPI.sdiffstore(List<String> args) Stores the difference of multiple sets in a key.RedisAPI.searchClusterinfo(List<String> args) RedisAPI.searchClusterrefresh(List<String> args) RedisAPI.searchClusterset(List<String> args) Changes the selected database.Changes the selected database.Send the given command to the Redis server or cluster.Send the given command to the redis server or cluster.Sets the string value of a key, ignoring its type.Sets the string value of a key, ignoring its type.Sets or clears the bit at offset of the string value.Sets or clears the bit at offset of the string value.Sets the string value and expiration time of a key.Sets the string value and expiration time of a key.Set the string value of a key only when the key doesn't exist.Set the string value of a key only when the key doesn't exist.Overwrites a part of a string value with another by an offset.Overwrites a part of a string value with another by an offset.Synchronously saves the database(s) to disk and shuts down the Redis server.Synchronously saves the database(s) to disk and shuts down the server.Returns the intersect of multiple sets.Returns the intersect of multiple sets.RedisAPI.sintercard(List<String> args) Returns the number of members of the intersect of multiple sets.ValkeyAPI.sintercard(List<String> args) Returns the number of members of the intersect of multiple sets.RedisAPI.sinterstore(List<String> args) Stores the intersect of multiple sets in a key.ValkeyAPI.sinterstore(List<String> args) Stores the intersect of multiple sets in a key.Determines whether a member belongs to a set.Determines whether a member belongs to a set.Sets a Redis server as a replica of another, or promotes it to being a master.Sets a server as a replica of another, or promotes it to being a primary.A container for slow log commands.A container for slow log commands.Returns all members of a set.Returns all members of a set.RedisAPI.smismember(List<String> args) Determines whether multiple members belong to a set.ValkeyAPI.smismember(List<String> args) Determines whether multiple members belong to a set.Moves a member from one set to another.Moves a member from one set to another.Sorts the elements in a list, a set, or a sorted set, optionally storing the result.Sorts the elements in a list, a set, or a sorted set, optionally storing the result.Returns the sorted elements of a list, a set, or a sorted set.Returns the sorted elements of a list, a set, or a sorted set.Returns one or more random members from a set after removing them.Returns one or more random members from a set after removing them.Post a message to a shard channel.Post a message to a shard channel.RedisAPI.srandmember(List<String> args) Get one or multiple random members from a set.ValkeyAPI.srandmember(List<String> args) Get one or multiple random members from a set.Removes one or more members from a set.Removes one or more members from a set.Iterates over members of a set.Iterates over members of a set.RedisAPI.ssubscribe(List<String> args) Listens for messages published to shard channels.ValkeyAPI.ssubscribe(List<String> args) Listens for messages published to shard channels.Returns the length of a string value.Returns the length of a string value.Listens for messages published to channels.Listens for messages published to channels.Returns a substring from a string value.Returns a substring from a string value.Returns the union of multiple sets.Returns the union of multiple sets.RedisAPI.sunionstore(List<String> args) Stores the union of multiple sets in a key.ValkeyAPI.sunionstore(List<String> args) Stores the union of multiple sets in a key.RedisAPI.sunsubscribe(List<String> args) Stops listening to messages posted to shard channels.ValkeyAPI.sunsubscribe(List<String> args) Stops listening to messages posted to shard channels.Swaps two Redis databases.Swaps two databases.RedisAPI.sync()An internal command used in replication.ValkeyAPI.sync()An internal command used in replication.RedisAPI.tdigestAdd(List<String> args) Adds one or more observations to a t-digest sketch.RedisAPI.tdigestByrank(List<String> args) Returns, for each input rank, an estimation of the value (floating-point) with that rank.RedisAPI.tdigestByrevrank(List<String> args) Returns, for each input reverse rank, an estimation of the value (floating-point) with that reverse rank.RedisAPI.tdigestCdf(List<String> args) Returns, for each input value, an estimation of the floating-point fraction of (observations smaller than the given value + half the observations equal to the given value).RedisAPI.tdigestCreate(List<String> args) Allocates memory and initializes a new t-digest sketch.RedisAPI.tdigestInfo(String arg0) Returns information and statistics about a t-digest sketch.RedisAPI.tdigestInfo(List<String> args) Returns information and statistics about a t-digest sketch.RedisAPI.tdigestMax(String arg0) Returns the maximum observation value from a t-digest sketch.RedisAPI.tdigestMax(List<String> args) Returns the maximum observation value from a t-digest sketch.RedisAPI.tdigestMerge(List<String> args) Merges multiple t-digest sketches into a single sketch.RedisAPI.tdigestMin(String arg0) Returns the minimum observation value from a t-digest sketch.RedisAPI.tdigestMin(List<String> args) Returns the minimum observation value from a t-digest sketch.RedisAPI.tdigestQuantile(List<String> args) Returns, for each input fraction, an estimation of the value (floating point) that is smaller than the given fraction of observations.RedisAPI.tdigestRank(List<String> args) Returns, for each input value (floating-point), the estimated rank of the value (the number of observations in the sketch that are smaller than the value + half the number of observations that are equal to the value).RedisAPI.tdigestReset(String arg0) Resets a t-digest sketch: empty the sketch and re-initializes it.RedisAPI.tdigestReset(List<String> args) Resets a t-digest sketch: empty the sketch and re-initializes it.RedisAPI.tdigestRevrank(List<String> args) Returns, for each input value (floating-point), the estimated reverse rank of the value (the number of observations in the sketch that are larger than the value + half the number of observations that are equal to the value).RedisAPI.tdigestTrimmedMean(String arg0, String arg1, String arg2) Returns an estimation of the mean value from the sketch, excluding observation values outside the low and high cutoff quantiles.RedisAPI.tdigestTrimmedMean(List<String> args) Returns an estimation of the mean value from the sketch, excluding observation values outside the low and high cutoff quantiles.RedisAPI.time()Returns the server time.ValkeyAPI.time()Returns the server time.RedisAPI.timeseriesClusterset(List<String> args) RedisAPI.timeseriesClustersetfromshard(List<String> args) RedisAPI.timeseriesHello(List<String> args) RedisAPI.timeseriesInfocluster(List<String> args) RedisAPI.timeseriesInnercommunication(List<String> args) RedisAPI.timeseriesNetworktest(List<String> args) RedisAPI.timeseriesRefreshcluster(List<String> args) Adds an item to a Top-k sketch.Return the count for one or more items are in a sketch.RedisAPI.topkIncrby(List<String> args) Increases the count of one or more items by increment.Returns information about a sketch.Returns information about a sketch.Return the full list of items in Top-K sketch.Checks whether one or more items are in a sketch.RedisAPI.topkReserve(List<String> args) Initializes a Top-K sketch with specified parameters.Returns the number of existing keys out of those specified after updating the time they were last accessed.Returns the number of existing keys out of those specified after updating the time they were last accessed.Trim the keys that belong to specified slots.Append a sample to a time series.Update the retention, chunk size, duplicate policy, and labels of an existing time series.Create a new time series.RedisAPI.tsCreaterule(List<String> args) Create a compaction rule.Decrease the value of the latest sample.Delete all samples between two timestamps for a given time series.Delete all samples between two timestamps for a given time series.RedisAPI.tsDeleterule(String arg0, String arg1) Delete a compaction rule.RedisAPI.tsDeleterule(List<String> args) Delete a compaction rule.Get the sample with the highest timestamp from a given time series.Increase the value of the latest sample.Returns information and statistics for a time series.Append new samples to one or more time series.Get the sample with the highest timestamp from each time series matching a specific filter.Query a range across multiple time series by filters in forward direction.RedisAPI.tsMrevrange(List<String> args) Query a range across multiple time series by filters in reverse direction.RedisAPI.tsQueryindex(List<String> args) Get all time series keys matching a filter list.Query a range in forward direction.RedisAPI.tsRevrange(List<String> args) Query a range in reverse direction.Returns the expiration time in seconds of a key.Returns the expiration time in seconds of a key.Determines the type of value stored at a key.Determines the type of value stored at a key.Asynchronously deletes one or more keys.Asynchronously deletes one or more keys.RedisAPI.unsubscribe(List<String> args) Stops listening to messages posted to channels.ValkeyAPI.unsubscribe(List<String> args) Stops listening to messages posted to channels.RedisAPI.unwatch()Forgets about watched keys of a transaction.ValkeyAPI.unwatch()Forgets about watched keys of a transaction.Add one or more elements to a vector set, or update its vector if it already exists.Return the number of elements in a vector set.Return the dimension of vectors in the vector set.Return the vector associated with an element.Retrieve the JSON attributes of elements.Return information about a vector set.Check if an element exists in a vector set.Return the neighbors of an element at each layer in the HNSW graph.RedisAPI.vrandmember(List<String> args) Return one or multiple random members from a vector set.Return vector set elements in a lex range.Remove an element from a vector set.Associate or remove the JSON attributes of elements.Return elements by vector similarity.Blocks until the asynchronous replication of all preceding write commands sent by the connection is completed.Blocks until the asynchronous replication of all preceding write commands sent by the connection is completed.Blocks until all of the preceding write commands sent by the connection are written to the append-only file of the master and/or replicas.Blocks until all of the preceding write commands sent by the connection are written to the append-only file of the primary and/or replicas.Monitors changes to keys to determine the execution of a transaction.Monitors changes to keys to determine the execution of a transaction.Returns the number of messages that were successfully acknowledged by the consumer group member of a stream.Returns the number of messages that were successfully acknowledged by the consumer group member of a stream.Acknowledges and deletes one or multiple messages for a stream consumer group.Appends a new message to a stream.Appends a new message to a stream.RedisAPI.xautoclaim(List<String> args) Changes, or acquires, ownership of messages in a consumer group, as if the messages were delivered to as consumer group member.ValkeyAPI.xautoclaim(List<String> args) Changes, or acquires, ownership of messages in a consumer group, as if the messages were delivered to as consumer group member.Sets the IDMP configuration parameters for a stream.Changes, or acquires, ownership of a message in a consumer group, as if the message was delivered a consumer group member.Changes, or acquires, ownership of a message in a consumer group, as if the message was delivered a consumer group member.Returns the number of messages after removing them from a stream.Returns the number of messages after removing them from a stream.Deletes one or multiple entries from the stream.A container for consumer groups commands.A container for consumer groups commands.RedisAPI.xidmprecord(String arg0, String arg1, String arg2, String arg3) An internal command for setting IDMP metadata on an existing stream message.A container for stream introspection commands.A container for stream introspection commands.Return the number of messages in a stream.Return the number of messages in a stream.Returns the information and entries from a stream consumer group's pending entries list.Returns the information and entries from a stream consumer group's pending entries list.Returns the messages from a stream within a range of IDs.Returns the messages from a stream within a range of IDs.Returns messages from multiple streams with IDs greater than the ones requested.Returns messages from multiple streams with IDs greater than the ones requested.RedisAPI.xreadgroup(List<String> args) Returns new or historical messages from a stream for a consumer in a group.ValkeyAPI.xreadgroup(List<String> args) Returns new or historical messages from a stream for a consumer in a group.Returns the messages from a stream within a range of IDs in reverse order.Returns the messages from a stream within a range of IDs in reverse order.An internal command for replicating stream values.An internal command for replicating stream values.Deletes messages from the beginning of a stream.Deletes messages from the beginning of a stream.Adds one or more members to a sorted set, or updates their scores.Adds one or more members to a sorted set, or updates their scores.Returns the number of members in a sorted set.Returns the number of members in a sorted set.Returns the count of members in a sorted set that have scores within a range.Returns the count of members in a sorted set that have scores within a range.Returns the difference between multiple sorted sets.Returns the difference between multiple sorted sets.RedisAPI.zdiffstore(List<String> args) Stores the difference of multiple sorted sets in a key.ValkeyAPI.zdiffstore(List<String> args) Stores the difference of multiple sorted sets in a key.Increments the score of a member in a sorted set.Increments the score of a member in a sorted set.Returns the intersect of multiple sorted sets.Returns the intersect of multiple sorted sets.RedisAPI.zintercard(List<String> args) Returns the number of members of the intersect of multiple sorted sets.ValkeyAPI.zintercard(List<String> args) Returns the number of members of the intersect of multiple sorted sets.RedisAPI.zinterstore(List<String> args) Stores the intersect of multiple sorted sets in a key.ValkeyAPI.zinterstore(List<String> args) Stores the intersect of multiple sorted sets in a key.Returns the number of members in a sorted set within a lexicographical range.Returns the number of members in a sorted set within a lexicographical range.Returns the highest- or lowest-scoring members from one or more sorted sets after removing them.Returns the highest- or lowest-scoring members from one or more sorted sets after removing them.Returns the score of one or more members in a sorted set.Returns the score of one or more members in a sorted set.Returns the highest-scoring members from a sorted set after removing them.Returns the highest-scoring members from a sorted set after removing them.Returns the lowest-scoring members from a sorted set after removing them.Returns the lowest-scoring members from a sorted set after removing them.RedisAPI.zrandmember(List<String> args) Returns one or more random members from a sorted set.ValkeyAPI.zrandmember(List<String> args) Returns one or more random members from a sorted set.Returns members in a sorted set within a range of indexes.Returns members in a sorted set within a range of indexes.RedisAPI.zrangebylex(List<String> args) Returns members in a sorted set within a lexicographical range.ValkeyAPI.zrangebylex(List<String> args) Returns members in a sorted set within a lexicographical range.RedisAPI.zrangebyscore(List<String> args) Returns members in a sorted set within a range of scores.ValkeyAPI.zrangebyscore(List<String> args) Returns members in a sorted set within a range of scores.RedisAPI.zrangestore(List<String> args) Stores a range of members from sorted set in a key.ValkeyAPI.zrangestore(List<String> args) Stores a range of members from sorted set in a key.Returns the index of a member in a sorted set ordered by ascending scores.Returns the index of a member in a sorted set ordered by ascending scores.Returns the index of a member in a sorted set ordered by ascending scores.Removes one or more members from a sorted set.Removes one or more members from a sorted set.RedisAPI.zremrangebylex(String arg0, String arg1, String arg2) Removes members in a sorted set within a lexicographical range.ValkeyAPI.zremrangebylex(String arg0, String arg1, String arg2) Removes members in a sorted set within a lexicographical range.RedisAPI.zremrangebyrank(String arg0, String arg1, String arg2) Removes members in a sorted set within a range of indexes.ValkeyAPI.zremrangebyrank(String arg0, String arg1, String arg2) Removes members in a sorted set within a range of indexes.RedisAPI.zremrangebyscore(String arg0, String arg1, String arg2) Removes members in a sorted set within a range of scores.ValkeyAPI.zremrangebyscore(String arg0, String arg1, String arg2) Removes members in a sorted set within a range of scores.Returns members in a sorted set within a range of indexes in reverse order.Returns members in a sorted set within a range of indexes in reverse order.RedisAPI.zrevrangebylex(List<String> args) Returns members in a sorted set within a lexicographical range in reverse order.ValkeyAPI.zrevrangebylex(List<String> args) Returns members in a sorted set within a lexicographical range in reverse order.RedisAPI.zrevrangebyscore(List<String> args) Returns members in a sorted set within a range of scores in reverse order.ValkeyAPI.zrevrangebyscore(List<String> args) Returns members in a sorted set within a range of scores in reverse order.Returns the index of a member in a sorted set ordered by descending scores.Returns the index of a member in a sorted set ordered by descending scores.Returns the index of a member in a sorted set ordered by descending scores.Iterates over members and scores of a sorted set.Iterates over members and scores of a sorted set.Returns the score of a member in a sorted set.Returns the score of a member in a sorted set.Returns the union of multiple sorted sets.Returns the union of multiple sorted sets.RedisAPI.zunionstore(List<String> args) Stores the union of multiple sorted sets in a key.ValkeyAPI.zunionstore(List<String> args) Stores the union of multiple sorted sets in a key.Method parameters in io.vertx.reactivex.redis.client with type arguments of type FutureModifier and TypeMethodDescriptionstatic RedisRedis.createClusterClient(Vertx vertx, RedisOptions options, Supplier<Future<RedisClusterConnectOptions>> connectOptions) Creates a new cluster Redis client.static RedisRedis.createReplicationClient(Vertx vertx, RedisOptions options, Supplier<Future<RedisReplicationConnectOptions>> connectOptions) Creates a new replication Redis client.static RedisRedis.createSentinelClient(Vertx vertx, RedisOptions options, Supplier<Future<RedisSentinelConnectOptions>> connectOptions) Creates a new sentinel Redis client.static RedisRedis.createStandaloneClient(Vertx vertx, RedisOptions options, Supplier<Future<RedisStandaloneConnectOptions>> connectOptions) Creates a new standalone Redis client. -
Uses of Future in io.vertx.reactivex.servicediscovery
Methods in io.vertx.reactivex.servicediscovery that return FutureModifier and TypeMethodDescriptionServiceDiscovery.getRecord(JsonObject filter) Lookups for a single record.Looks up for a single record by its registrationid.Lookups for a single record.Lookups for a single record.ServiceDiscovery.getRecords(JsonObject filter) Lookups for a set of records.ServiceDiscovery.getRecords(Function<Record, Boolean> filter) Lookups for a set of records.ServiceDiscovery.getRecords(Function<Record, Boolean> filter, boolean includeOutOfService) Lookups for a set of records.Publishes a record.ServiceDiscovery.registerServiceExporter(ServiceExporter exporter, JsonObject configuration) Registers a discovery bridge.ServiceDiscovery.registerServiceImporter(ServiceImporter importer, JsonObject configuration) Registers a discovery service importer.Un-publishes a record.Updates the given record. -
Uses of Future in io.vertx.reactivex.servicediscovery.spi
Methods in io.vertx.reactivex.servicediscovery.spi that return Future -
Uses of Future in io.vertx.reactivex.servicediscovery.types
Methods in io.vertx.reactivex.servicediscovery.types that return FutureModifier and TypeMethodDescriptionstatic Future<HttpClient> HttpEndpoint.getClient(ServiceDiscovery discovery, JsonObject filter) Convenient method that looks for a HTTP endpoint and provides the configured .static Future<HttpClient> HttpEndpoint.getClient(ServiceDiscovery discovery, JsonObject filter, JsonObject conf) Convenient method that looks for a HTTP endpoint and provides the configured .static Future<HttpClient> HttpEndpoint.getClient(ServiceDiscovery discovery, Function<Record, Boolean> filter) Convenient method that looks for a HTTP endpoint and provides the configured .static Future<HttpClient> HttpEndpoint.getClient(ServiceDiscovery discovery, Function<Record, Boolean> filter, JsonObject conf) Convenient method that looks for a HTTP endpoint and provides the configured .static <T> Future<MessageConsumer<T>> MessageSource.getConsumer(ServiceDiscovery discovery, JsonObject filter) Convenient method that looks for a message source and provides the configured .static <T> Future<MessageConsumer<T>> MessageSource.getConsumer(ServiceDiscovery discovery, Function<Record, Boolean> filter) Convenient method that looks for a message source and provides the configured .static Future<MongoClient> MongoDataSource.getMongoClient(ServiceDiscovery discovery, JsonObject filter) Convenient method that looks for a Mongo datasource source and provides the configuredMongoClient.static Future<MongoClient> MongoDataSource.getMongoClient(ServiceDiscovery discovery, JsonObject filter, JsonObject consumerConfiguration) Convenient method that looks for a Mongo datasource source and provides the configuredMongoClient.static Future<MongoClient> MongoDataSource.getMongoClient(ServiceDiscovery discovery, Function<Record, Boolean> filter) Convenient method that looks for a Mongo datasource source and provides the configuredMongoClient.RedisDataSource.getRedisClient(ServiceDiscovery discovery, JsonObject filter) Convenient method that looks for a Redis data source and provides the configuredRedis.RedisDataSource.getRedisClient(ServiceDiscovery discovery, JsonObject filter, JsonObject consumerConfiguration) Convenient method that looks for a Redis data source and provides the configuredRedis.RedisDataSource.getRedisClient(ServiceDiscovery discovery, Function<Record, Boolean> filter) Convenient method that looks for a Redis data source and provides the configuredRedis.RedisDataSource.getRedisClient(ServiceDiscovery discovery, Function<Record, Boolean> filter, JsonObject consumerConfiguration) Convenient method that looks for a Redis data source and provides the configuredRedis.static <T> Future<T> EventBusService.getServiceProxy(ServiceDiscovery discovery, Function<Record, Boolean> filter, Class<T> clientClass) Lookup for a service record and if found, retrieve it and return the service object (used to consume the service).static <T> Future<T> EventBusService.getServiceProxy(ServiceDiscovery discovery, Function<Record, Boolean> filter, Class<T> clientClass, JsonObject conf) Lookup for a service record and if found, retrieve it and return the service object (used to consume the service).static <T> Future<T> EventBusService.getServiceProxyWithJsonFilter(ServiceDiscovery discovery, JsonObject filter, Class<T> clientClass) Lookup for a service record and if found, retrieve it and return the service object (used to consume the service).static <T> Future<T> EventBusService.getServiceProxyWithJsonFilter(ServiceDiscovery discovery, JsonObject filter, Class<T> clientClass, JsonObject conf) Lookup for a service record and if found, retrieve it and return the service object (used to consume the service).HttpEndpoint.getWebClient(ServiceDiscovery discovery, JsonObject filter) Convenient method that looks for a HTTP endpoint and provides the configured .HttpEndpoint.getWebClient(ServiceDiscovery discovery, JsonObject filter, JsonObject conf) Convenient method that looks for a HTTP endpoint and provides the configured .HttpEndpoint.getWebClient(ServiceDiscovery discovery, Function<Record, Boolean> filter) Convenient method that looks for a HTTP endpoint and provides the configured .HttpEndpoint.getWebClient(ServiceDiscovery discovery, Function<Record, Boolean> filter, JsonObject conf) Convenient method that looks for a HTTP endpoint and provides the configured . -
Uses of Future in io.vertx.reactivex.sqlclient
Methods in io.vertx.reactivex.sqlclient that return FutureModifier and TypeMethodDescriptionSqlConnection.begin()Begin a transaction and returns aTransactionfor controlling and tracking this transaction.Cursor.close()Release the cursor.PreparedStatement.close()Close the prepared query and release its resources.RowStream.close()Close the stream and release the resources.SqlClient.close()Close the client and release the associated resources.Transaction.commit()Commit the current transaction.Transaction.completion()Return the transaction completionFuturethat succeeds when the transaction commits and fails withTransactionRollbackExceptionwhen the transaction rolls back.PreparedQuery.execute()Execute the query.Execute the query.Query.execute()Execute the query.PreparedQuery.executeBatch(List<Tuple> batch) Execute the query with a batch of tuples.Pool.getConnection()Get a connection from the pool.RowStream.pipeTo(WriteStream<T> dst) Pipe thisReadStreamto theWriteStream.Create a prepared statement using the givensqlstring.SqlConnection.prepare(String sql, PrepareOptions options) Create a prepared statement using the givensqlstring.Cursor.read(int count) Read rows from the cursor, the result is provided asynchronously to thehandler.Transaction.rollback()Rollback the transaction and release the associated resources.<T> Future<T> Pool.withConnection(Function<SqlConnection, Maybe<T>> function) Get a connection from the pool and execute the givenfunction.<T> Future<T> Pool.withConnection(Function<SqlConnection, Future<T>> function) Get a connection from the pool and execute the givenfunction.<T> Future<T> Pool.withTransaction(Function<SqlConnection, Maybe<T>> function) Execute the givenfunctionwithin a transaction.<T> Future<T> Pool.withTransaction(TransactionPropagation txPropagation, Function<SqlConnection, Maybe<T>> function) LikePool.withTransaction(Function)but allows for setting the mode, defining how the acquired connection is managed during the execution of the function.<T> Future<T> Pool.withTransaction(TransactionPropagation txPropagation, Function<SqlConnection, Future<T>> function) LikePool.withTransaction(Function)but allows for setting the mode, defining how the acquired connection is managed during the execution of the function.<T> Future<T> Pool.withTransaction(Function<SqlConnection, Future<T>> function) Execute the givenfunctionwithin a transaction.Method parameters in io.vertx.reactivex.sqlclient with type arguments of type FutureModifier and TypeMethodDescriptionClientBuilder.connectingTo(Supplier<Future<SqlConnectOptions>> supplier) Configure thedatabasethe client should connect to.<T> Maybe<T> Pool.rxWithConnection(Function<SqlConnection, Future<T>> function) Get a connection from the pool and execute the givenfunction.<T> Maybe<T> Pool.rxWithTransaction(TransactionPropagation txPropagation, Function<SqlConnection, Future<T>> function) LikePool.withTransaction(Function)but allows for setting the mode, defining how the acquired connection is managed during the execution of the function.<T> Maybe<T> Pool.rxWithTransaction(Function<SqlConnection, Future<T>> function) Execute the givenfunctionwithin a transaction.<T> Future<T> Pool.withConnection(Function<SqlConnection, Future<T>> function) Get a connection from the pool and execute the givenfunction.<T> Future<T> Pool.withTransaction(TransactionPropagation txPropagation, Function<SqlConnection, Future<T>> function) LikePool.withTransaction(Function)but allows for setting the mode, defining how the acquired connection is managed during the execution of the function.<T> Future<T> Pool.withTransaction(Function<SqlConnection, Future<T>> function) Execute the givenfunctionwithin a transaction. -
Uses of Future in io.vertx.reactivex.sqlclient.templates
Methods in io.vertx.reactivex.sqlclient.templates that return Future -
Uses of Future in io.vertx.redis.client
Methods in io.vertx.redis.client that return FutureModifier and TypeMethodDescriptionA container for Access List Control commands.A container for Access List Control commands.Appends a string to the value of a key.Appends a string to the value of a key.RedisAPI.asking()Signals that a cluster client is following an -ASK redirect.ValkeyAPI.asking()Signals that a cluster client is following an -ASK redirect.Authenticates the connection.Authenticates the connection.Sends a list of commands in a single IO operation, this prevents any inter twinning to happen from other client users.Sends a list of commands in a single IO operation, this prevents any inter twinning to happen from other client users.Adds an item to a Bloom Filter.Adds an item to a Bloom Filter.Returns the cardinality of a Bloom filter.Returns the cardinality of a Bloom filter.Checks whether an item exists in a Bloom Filter.Checks whether an item exists in a Bloom Filter.Returns information about a Bloom Filter.Adds one or more items to a Bloom Filter.RedisAPI.bfLoadchunk(String arg0, String arg1, String arg2) Restores a filter previously saved using SCANDUMP.RedisAPI.bfLoadchunk(List<String> args) Restores a filter previously saved using SCANDUMP.Adds one or more items to a Bloom Filter.Checks whether one or more items exist in a Bloom Filter.Creates a new Bloom Filter.RedisAPI.bfScandump(String arg0, String arg1) Begins an incremental save of the bloom filter.RedisAPI.bfScandump(List<String> args) Begins an incremental save of the bloom filter.RedisAPI.bgrewriteaof()Asynchronously rewrites the append-only file to disk.ValkeyAPI.bgrewriteaof()Asynchronously rewrites the append-only file to disk.Asynchronously saves the database(s) to disk.Asynchronously saves the database(s) to disk.Counts the number of set bits (population counting) in a string.Counts the number of set bits (population counting) in a string.Performs arbitrary bitfield integer operations on strings.Performs arbitrary bitfield integer operations on strings.RedisAPI.bitfieldRo(List<String> args) Performs arbitrary read-only bitfield integer operations on strings.ValkeyAPI.bitfieldRo(List<String> args) Performs arbitrary read-only bitfield integer operations on strings.Performs bitwise operations on multiple strings, and stores the result.Performs bitwise operations on multiple strings, and stores the result.Finds the first set (1) or clear (0) bit in a string.Finds the first set (1) or clear (0) bit in a string.Pops an element from a list, pushes it to another list and returns it.Pops an element from a list, pushes it to another list and returns it.Pops the first element from one of multiple lists.Pops the first element from one of multiple lists.Removes and returns the first element in a list.Removes and returns the first element in a list.Removes and returns the last element in a list.Removes and returns the last element in a list.RedisAPI.brpoplpush(String arg0, String arg1, String arg2) Deprecated.since Redis 6.2.0, replaced by:BLMOVEwith theRIGHTandLEFTargumentsValkeyAPI.brpoplpush(String arg0, String arg1, String arg2) Pops an element from a list, pushes it to another list and returns it.Removes and returns a member by score from one or more sorted sets.Removes and returns a member by score from one or more sorted sets.Removes and returns the member with the highest score from one or more sorted sets.Removes and returns the member with the highest score from one or more sorted sets.Removes and returns the member with the lowest score from one or more sorted sets.Removes and returns the member with the lowest score from one or more sorted sets.Adds an item to a Cuckoo Filter.Adds an item to a Cuckoo Filter.Adds an item to a Cuckoo Filter if the item did not exist previously.Adds an item to a Cuckoo Filter if the item did not exist previously.Return the number of times an item might be in a Cuckoo Filter.Return the number of times an item might be in a Cuckoo Filter.Deletes an item from a Cuckoo Filter.Deletes an item from a Cuckoo Filter.Checks whether one or more items exist in a Cuckoo Filter.Checks whether one or more items exist in a Cuckoo Filter.Returns information about a Cuckoo Filter.Returns information about a Cuckoo Filter.Adds one or more items to a Cuckoo Filter.RedisAPI.cfInsertnx(List<String> args) Adds one or more items to a Cuckoo Filter if the items did not exist previously.RedisAPI.cfLoadchunk(String arg0, String arg1, String arg2) Restores a filter previously saved using SCANDUMP.RedisAPI.cfLoadchunk(List<String> args) Restores a filter previously saved using SCANDUMP.Checks whether one or more items exist in a Cuckoo Filter.Creates a new Cuckoo Filter.RedisAPI.cfScandump(String arg0, String arg1) Begins an incremental save of the bloom filter.RedisAPI.cfScandump(List<String> args) Begins an incremental save of the bloom filter.A container for client connection commands.A container for client connection commands.Redis.close()Closes the client and terminates any connection.RedisConnection.close()Closes the connection or returns to the pool.A container for Redis Cluster commands.A container for Cluster commands.Increases the count of one or more items by increment.Returns information about a sketch.Returns information about a sketch.RedisAPI.cmsInitbydim(String arg0, String arg1, String arg2) Initializes a Count-Min Sketch to dimensions specified by user.RedisAPI.cmsInitbydim(List<String> args) Initializes a Count-Min Sketch to dimensions specified by user.RedisAPI.cmsInitbyprob(String arg0, String arg1, String arg2) Initializes a Count-Min Sketch to accommodate requested tolerances.RedisAPI.cmsInitbyprob(List<String> args) Initializes a Count-Min Sketch to accommodate requested tolerances.Merges several sketches into one sketch.Returns the count for one or more items in a sketch.Returns detailed information about all commands.Returns detailed information about all commands.ValkeyAPI.commandlog(List<String> args) A container for command log commands.A container for server configuration commands.A container for server configuration commands.Redis.connect()Connects to the Redis server.Copies the value of a key to a new key.Copies the value of a key to a new key.RedisAPI.dbsize()Returns the number of keys in the database.ValkeyAPI.dbsize()Returns the number of keys in the database.A container for debugging commands.A container for debugging commands.Decrements the integer value of a key by one.Decrements the integer value of a key by one.Decrements a number from the integer value of a key.Decrements a number from the integer value of a key.Deletes one or more keys.Deletes one or more keys.Conditionally removes the specified key based on value or digest comparison.Delete key if value matches string.Returns the XXH3 hash of a string value.RedisAPI.discard()Discards a transaction.ValkeyAPI.discard()Discards a transaction.Returns a serialized representation of the value stored at a key.Returns a serialized representation of the value stored at a key.Returns the given string.Returns the given string.Executes a server-side Lua script.Executes a server-side Lua script.Executes a read-only server-side Lua script.Executes a read-only server-side Lua script.Executes a server-side Lua script by SHA1 digest.Executes a server-side Lua script by SHA1 digest.Executes a read-only server-side Lua script by SHA1 digest.Executes a read-only server-side Lua script by SHA1 digest.RedisAPI.exec()Executes all commands in a transaction.ValkeyAPI.exec()Executes all commands in a transaction.Determines whether one or more keys exist.Determines whether one or more keys exist.Sets the expiration time of a key in seconds.Sets the expiration time of a key in seconds.Sets the expiration time of a key to a Unix timestamp.Sets the expiration time of a key to a Unix timestamp.RedisAPI.expiretime(String arg0) Returns the expiration time of a key as a Unix timestamp.ValkeyAPI.expiretime(String arg0) Returns the expiration time of a key as a Unix timestamp.Starts a coordinated failover from a server to one of its replicas.Starts a coordinated failover from a server to one of its replicas.Invokes a function.Invokes a function.Invokes a read-only function.Invokes a read-only function.Removes all keys from all databases.Removes all keys from all databases.Remove all keys from the current database.Remove all keys from the current database.RedisAPI.ftAggregate(List<String> args) Run a search query on an index and perform aggregate transformations on the results.RedisAPI.ftAliasadd(List<String> args) Adds an alias to the index.RedisAPI.ftAliasaddifnx(List<String> args) Adds an alias to the index.RedisAPI.ftAliasdel(List<String> args) Deletes an alias from the index.RedisAPI.ftAliasdelifx(List<String> args) Deletes an alias from the index.RedisAPI.ftAliasupdate(List<String> args) Adds or updates an alias to the index.Adds a new field to the index.RedisAPI.ftAlterifnx(List<String> args) Adds a new field to the index.Creates an index with the given spec.RedisAPI.ftCreateifnx(List<String> args) Creates an index with the given spec.Deprecated.this command no longer exists in the latest Redis releaseAdds terms to a dictionary.Deletes terms from a dictionary.RedisAPI.ftDictdump(List<String> args) Dumps all terms in the given dictionary.RedisAPI.ftDropindex(List<String> args) Deletes the index.RedisAPI.ftDropindexifx(List<String> args) Deletes the index.Returns the execution plan for a complex query.RedisAPI.ftExplaincli(List<String> args) Returns the execution plan for a complex query.Performs hybrid search combining text search and vector similarity search.Returns information and statistics on the index.Returns a list of all existing indexes.Performs a `FT.SEARCH` or `FT.AGGREGATE` command and collects performance information.Searches the index with a textual query, returning either documents or just ids.RedisAPI.ftSpellcheck(List<String> args) Performs spelling correction on a query, returning suggestions for misspelled terms.Adds a suggestion string to an auto-complete suggestion dictionary.Deletes a string from a suggestion index.Gets completion suggestions for a prefix.Gets the size of an auto-complete suggestion dictionary.Dumps the contents of a synonym group.RedisAPI.ftSynupdate(List<String> args) Creates or updates a synonym group with additional terms.Returns the distinct tags indexed in a Tag field.A container for function commands.A container for function commands.Adds one or more members to a geospatial index.Adds one or more members to a geospatial index.Returns the distance between two members of a geospatial index.Returns the distance between two members of a geospatial index.Returns members from a geospatial index as geohash strings.Returns members from a geospatial index as geohash strings.Returns the longitude and latitude of members from a geospatial index.Returns the longitude and latitude of members from a geospatial index.Deprecated.since Redis 6.2.0, replaced by:GEOSEARCHandGEOSEARCHSTOREwith theBYRADIUSargumentQueries a geospatial index for members within a distance from a coordinate, optionally stores the result.RedisAPI.georadiusbymember(List<String> args) Deprecated.since Redis 6.2.0, replaced by:GEOSEARCHandGEOSEARCHSTOREwith theBYRADIUSandFROMMEMBERargumentsValkeyAPI.georadiusbymember(List<String> args) Queries a geospatial index for members within a distance from a member, optionally stores the result.RedisAPI.georadiusbymemberRo(List<String> args) Deprecated.since Redis 6.2.0, replaced by:GEOSEARCHwith theBYRADIUSandFROMMEMBERargumentsValkeyAPI.georadiusbymemberRo(List<String> args) Returns members from a geospatial index that are within a distance from a member.RedisAPI.georadiusRo(List<String> args) Deprecated.since Redis 6.2.0, replaced by:GEOSEARCHwith theBYRADIUSargumentValkeyAPI.georadiusRo(List<String> args) Returns members from a geospatial index that are within a distance from a coordinate.Queries a geospatial index for members inside an area of a box or a circle.Queries a geospatial index for members inside an area of a box, circle, or a polygon.RedisAPI.geosearchstore(List<String> args) Queries a geospatial index for members inside an area of a box or a circle, optionally stores the result.ValkeyAPI.geosearchstore(List<String> args) Queries a geospatial index for members inside an area of a box, a circle, or a polygon, optionally stores the result.Returns the string value of a key.Returns the string value of a key.Returns a bit value by offset.Returns a bit value by offset.Returns the string value of a key after deleting the key.Returns the string value of a key after deleting the key.Returns the string value of a key after setting its expiration time.Returns the string value of a key after setting its expiration time.Returns a substring of the string stored at a key.Returns a substring of the string stored at a key.Deprecated.since Redis 6.2.0, replaced by:SETwith the!GETargumentReturns the previous string value of a key after setting it to a new value.Deprecated.this command no longer exists in the latest Redis releaseRedisAPI.graphConfig(List<String> args) Deprecated.this command no longer exists in the latest Redis releaseRedisAPI.graphDebug(List<String> args) Deprecated.this command no longer exists in the latest Redis releaseRedisAPI.graphDelete(List<String> args) Deprecated.this command no longer exists in the latest Redis releaseRedisAPI.graphExplain(List<String> args) Deprecated.this command no longer exists in the latest Redis releaseDeprecated.this command no longer exists in the latest Redis releaseRedisAPI.graphProfile(List<String> args) Deprecated.this command no longer exists in the latest Redis releaseRedisAPI.graphQuery(List<String> args) Deprecated.this command no longer exists in the latest Redis releaseRedisAPI.graphRoQuery(List<String> args) Deprecated.this command no longer exists in the latest Redis releaseRedisAPI.graphSlowlog(List<String> args) Deprecated.this command no longer exists in the latest Redis releaseRedisCluster.groupByNodes(List<Request> requests) Groups therequestsinto aRequestGrouping, which contains: keyed requests: requests that include a key and it is therefore possible to determine to which master node they should be sent; all requests in each inner list in thekeyedcollection are guaranteed to be sent to the same master node; unkeyed requests: requests that do not include a key and it is therefore not possible to determine to which master node they should be sent. If any of therequestsincludes multiple keys that belong to different master nodes, the resulting future will fail.Deletes one or more fields and their values from a hash.Deletes one or more fields and their values from a hash.Handshakes with the Redis server.Handshakes with the server.Determines whether a field exists in a hash.Determines whether a field exists in a hash.Set expiry for hash field using relative time to expire (seconds).Set expiry time on hash fields.Set expiry for hash field using an absolute Unix timestamp (seconds).Set expiry time on hash fields.RedisAPI.hexpiretime(List<String> args) Returns the expiration time of a hash field as a Unix timestamp, in seconds.ValkeyAPI.hexpiretime(List<String> args) Returns Unix timestamps in seconds since the epoch at which the given key's field(s) will expire.Returns the value of a field in a hash.Returns the value of a field in a hash.Returns all fields and values in a hash.Returns all fields and values in a hash.Returns the value of a field and deletes it from the hash.Get the value of one or more fields of a given hash key, and optionally set their expiration.Get the value of one or more fields of a given hash key, and optionally set their expiration time or time-to-live (TTL).Increments the integer value of a field in a hash by a number.Increments the integer value of a field in a hash by a number.RedisAPI.hincrbyfloat(String arg0, String arg1, String arg2) Increments the floating point value of a field by a number.ValkeyAPI.hincrbyfloat(String arg0, String arg1, String arg2) Increments the floating point value of a field by a number.Returns all fields in a hash.Returns all fields in a hash.Returns the number of fields in a hash.Returns the number of fields in a hash.Returns the values of all fields in a hash.Returns the values of all fields in a hash.Deprecated.since Redis 4.0.0, replaced by:HSETwith multiple field-value pairsSets the values of multiple fields.A container for hotkeys tracking commands.Removes the expiration time for each specified field.Remove the existing expiration on a hash key's field(s).Set expiry for hash field using relative time to expire (milliseconds).Set expiry time on hash object.RedisAPI.hpexpireat(List<String> args) Set expiry for hash field using an absolute Unix timestamp (milliseconds).ValkeyAPI.hpexpireat(List<String> args) Set expiration time on hash field.RedisAPI.hpexpiretime(List<String> args) Returns the expiration time of a hash field as a Unix timestamp, in msec.ValkeyAPI.hpexpiretime(List<String> args) Returns the Unix timestamp in milliseconds since Unix epoch at which the given key's field(s) will expire.Returns the TTL in milliseconds of a hash field.Returns the remaining time to live in milliseconds of a hash key's field(s) that have an associated expiration.RedisAPI.hrandfield(List<String> args) Returns one or more random fields from a hash.ValkeyAPI.hrandfield(List<String> args) Returns one or more random fields from a hash.Iterates over fields and values of a hash.Iterates over fields and values of a hash.Creates or modifies the value of a field in a hash.Creates or modifies the value of a field in a hash.Set the value of one or more fields of a given hash key, and optionally set their expiration.Set the value of one or more fields of a given hash key, and optionally set their expiration time.Sets the value of a field in a hash only when the field doesn't exist.Sets the value of a field in a hash only when the field doesn't exist.Returns the length of the value of a field.Returns the length of the value of a field.Returns the TTL in seconds of a hash field.Returns the remaining time to live (in seconds) of a hash key's field(s) that have an associated expiration.Returns all values in a hash.Returns all values in a hash.Increments the integer value of a key by one.Increments the integer value of a key by one.Increments the integer value of a key by a number.Increments the integer value of a key by a number.RedisAPI.incrbyfloat(String arg0, String arg1) Increment the floating point value of a key by a number.ValkeyAPI.incrbyfloat(String arg0, String arg1) Increment the floating point value of a key by a number.Returns information and statistics about the server.Returns information and statistics about the server.RedisAPI.jsonArrappend(List<String> args) Append the JSON values into the array at path after the last element in it.RedisAPI.jsonArrindex(List<String> args) Search for the first occurrence of a JSON value in an array.RedisAPI.jsonArrinsert(List<String> args) Insert the json values into the array at path before the index (shifts to the right).RedisAPI.jsonArrlen(List<String> args) Report the length of the JSON array at path in key.RedisAPI.jsonArrpop(List<String> args) Remove and return the element at the specified index in the array at path.RedisAPI.jsonArrtrim(String arg0, String arg1, String arg2, String arg3) Trim an array so that it contains only the specified inclusive range of elements.RedisAPI.jsonArrtrim(List<String> args) Trim an array so that it contains only the specified inclusive range of elements.Clear container values (arrays/objects) and set numeric values to 0.This is a container command for debugging related tasks.Delete a value.RedisAPI.jsonForget(List<String> args) Delete a value.Get JSON value at path.Merge a given JSON value into matching paths.Return the values at path from multiple key arguments.Set or update one or more JSON values according to the specified key-path-value triplets.RedisAPI.jsonNumincrby(String arg0, String arg1, String arg2) Increment the number value stored at path by number.RedisAPI.jsonNumincrby(List<String> args) Increment the number value stored at path by number.RedisAPI.jsonNummultby(String arg0, String arg1, String arg2) Multiply the number value stored at path by number.RedisAPI.jsonNummultby(List<String> args) Multiply the number value stored at path by number.RedisAPI.jsonNumpowby(String arg0, String arg1, String arg2) Raise the number value stored at path to the power of number.RedisAPI.jsonNumpowby(List<String> args) Raise the number value stored at path to the power of number.RedisAPI.jsonObjkeys(List<String> args) Return the keys in the object that's referenced by path.RedisAPI.jsonObjlen(List<String> args) Report the number of keys in the JSON object at path in key.Return the JSON in key in Redis serialization protocol specification form.Set the JSON value at path in key.RedisAPI.jsonStrappend(List<String> args) Append the json-string values to the string at path.RedisAPI.jsonStrlen(List<String> args) Report the length of the JSON String at path in key.RedisAPI.jsonToggle(String arg0, String arg1) Toggle the boolean value stored at path.RedisAPI.jsonToggle(List<String> args) Toggle the boolean value stored at path.Report the type of JSON value at path.Returns all key names that match a pattern.Returns all key names that match a pattern.RedisAPI.lastsave()Returns the Unix timestamp of the last successful save to disk.ValkeyAPI.lastsave()Returns the Unix timestamp of the last successful save to disk.A container for latency diagnostics commands.A container for latency diagnostics commands.Finds the longest common substring.Finds the longest common substring.Returns an element from a list by its index.Returns an element from a list by its index.Inserts an element before or after another element in a list.Inserts an element before or after another element in a list.Returns the length of a list.Returns the length of a list.Returns an element after popping it from one list and pushing it to another.Returns an element after popping it from one list and pushing it to another.Returns multiple elements from a list after removing them.Returns multiple elements from a list after removing them.Displays computer art and the Redis version.Displays computer art and the server version.Returns the first elements in a list after removing it.Returns and removes one or more elements from the beginning of a list.Returns the index of matching elements in a list.Returns the index of matching elements in a list.Prepends one or more elements to a list.Prepends one or more elements to a list.Prepends one or more elements to a list only when the list exists.Prepends one or more elements to a list only when the list exists.Returns a range of elements from a list.Returns a range of elements from a list.Removes elements from a list.Removes elements from a list.Sets the value of an element in a list by its index.Sets the value of an element in a list by its index.Removes elements from both ends a list.Removes elements from both ends a list.A container for memory diagnostics commands.A container for memory diagnostics commands.Atomically returns the string values of one or more keys.Atomically returns the string values of one or more keys.Atomically transfers a key from one Redis instance to another.Atomically transfers a key from one instance to another.A container for module commands.A container for module commands.RedisAPI.monitor()Listens for all requests received by the server in real-time.ValkeyAPI.monitor()Listens for all requests received by the server in real-time.Moves a key to another database.Moves a key to another database.Atomically creates or modifies the string values of one or more keys.Atomically creates or modifies the string values of one or more keys.Atomically sets multiple string keys with a shared expiration in a single operation.Atomically modifies the string values of one or more keys only when all keys don't exist.Atomically modifies the string values of one or more keys only when all keys don't exist.RedisAPI.multi()Starts a transaction.ValkeyAPI.multi()Starts a transaction.A container for object introspection commands.A container for object introspection commands.RedisCluster.onAllMasterNodes(Request request) Runs therequestagainst all master nodes in the cluster.RedisCluster.onAllNodes(Request request) Runs therequestagainst all nodes in the cluster.Removes the expiration time of a key.Removes the expiration time of a key.Sets the expiration time of a key in milliseconds.Sets the expiration time of a key in milliseconds.Sets the expiration time of a key to a Unix milliseconds timestamp.Sets the expiration time of a key to a Unix milliseconds timestamp.RedisAPI.pexpiretime(String arg0) Returns the expiration time of a key as a Unix milliseconds timestamp.ValkeyAPI.pexpiretime(String arg0) Returns the expiration time of a key as a Unix milliseconds timestamp.Adds elements to a HyperLogLog key.Adds elements to a HyperLogLog key.Returns the approximated cardinality of the set(s) observed by the HyperLogLog key(s).Returns the approximated cardinality of the set(s) observed by the HyperLogLog key(s).Internal commands for debugging HyperLogLog values.Internal commands for debugging HyperLogLog values.Merges one or more HyperLogLog values into a single key.Merges one or more HyperLogLog values into a single key.RedisAPI.pfselftest()An internal command for testing HyperLogLog values.ValkeyAPI.pfselftest()An internal command for testing HyperLogLog values.Returns the server's liveliness response.Returns the server's liveliness response.Deprecated.since Redis 2.6.12, replaced by:SETwith thePXargumentSets both string value and expiration time in milliseconds of a key.RedisAPI.psubscribe(List<String> args) Listens for messages published to channels that match one or more patterns.ValkeyAPI.psubscribe(List<String> args) Listens for messages published to channels that match one or more patterns.An internal command used in replication.An internal command used in replication.Returns the expiration time in milliseconds of a key.Returns the expiration time in milliseconds of a key.Posts a message to a channel.Posts a message to a channel.A container for Pub/Sub commands.A container for Pub/Sub commands.RedisAPI.punsubscribe(List<String> args) Stops listening to messages published to channels that match one or more patterns.ValkeyAPI.punsubscribe(List<String> args) Stops listening to messages published to channels that match one or more patterns.Deprecated.since Redis 7.2.0, replaced by: just closing the connectionCloses the connection.RedisAPI.randomkey()Returns a random key name from the database.ValkeyAPI.randomkey()Returns a random key name from the database.RedisAPI.readonly()Enables read-only queries for a connection to a Redis Cluster replica node.ValkeyAPI.readonly()Enables read-only queries for a connection to a Valkey replica node.RedisAPI.readwrite()Enables read-write queries for a connection to a Reids Cluster replica node.ValkeyAPI.readwrite()Enables read-write queries for a connection to a Valkey replica node.Renames a key and overwrites the destination.Renames a key and overwrites the destination.Renames a key only when the target key name doesn't exist.Renames a key only when the target key name doesn't exist.An internal command for configuring the replication stream.An internal command for configuring the replication stream.Configures a server as replica of another, or promotes it to a master.Configures a server as replica of another, or promotes it to a primary.RedisAPI.reset()Resets the connection.ValkeyAPI.reset()Resets the connection.Creates a key from the serialized representation of a value.Creates a key from the serialized representation of a value.RedisAPI.restoreAsking(List<String> args) An internal command for migrating keys in a cluster.ValkeyAPI.restoreAsking(List<String> args) An internal command for migrating keys in a cluster.RedisAPI.role()Returns the replication role.ValkeyAPI.role()Returns the replication role.Returns and removes the last elements of a list.Returns and removes one or more elements from the end of a list.Deprecated.since Redis 6.2.0, replaced by:LMOVEwith theRIGHTandLEFTargumentsReturns the last element of a list after removing and pushing it to another list.Appends one or more elements to a list.Appends one or more elements to a list.Appends an element to a list only when the list exists.Appends one or more elements to a list only when the list exists.Adds one or more members to a set.Adds one or more members to a set.RedisAPI.save()Synchronously saves the database(s) to disk.ValkeyAPI.save()Synchronously saves the database(s) to disk.Iterates over the key names in the database.Iterates over the key names in the database.Returns the number of members in a set.Returns the number of members in a set.A container for Lua scripts management commands.A container for Lua scripts management commands.Returns the difference of multiple sets.Returns the difference of multiple sets.RedisAPI.sdiffstore(List<String> args) Stores the difference of multiple sets in a key.ValkeyAPI.sdiffstore(List<String> args) Stores the difference of multiple sets in a key.RedisAPI.searchClusterinfo(List<String> args) RedisAPI.searchClusterrefresh(List<String> args) RedisAPI.searchClusterset(List<String> args) Changes the selected database.Changes the selected database.Send the given command to the Redis server or cluster.Send untyped command to Redis.Send the given command to the redis server or cluster.Send untyped command to Valkey.Sets the string value of a key, ignoring its type.Sets the string value of a key, ignoring its type.Sets or clears the bit at offset of the string value.Sets or clears the bit at offset of the string value.Deprecated.since Redis 2.6.12, replaced by:SETwith theEXargumentSets the string value and expiration time of a key.Deprecated.since Redis 2.6.12, replaced by:SETwith theNXargumentSet the string value of a key only when the key doesn't exist.Overwrites a part of a string value with another by an offset.Overwrites a part of a string value with another by an offset.Synchronously saves the database(s) to disk and shuts down the Redis server.Synchronously saves the database(s) to disk and shuts down the server.Returns the intersect of multiple sets.Returns the intersect of multiple sets.RedisAPI.sintercard(List<String> args) Returns the number of members of the intersect of multiple sets.ValkeyAPI.sintercard(List<String> args) Returns the number of members of the intersect of multiple sets.RedisAPI.sinterstore(List<String> args) Stores the intersect of multiple sets in a key.ValkeyAPI.sinterstore(List<String> args) Stores the intersect of multiple sets in a key.Determines whether a member belongs to a set.Determines whether a member belongs to a set.Deprecated.since Redis 5.0.0, replaced by:REPLICAOFDeprecated.since Redis 5.0.0, replaced by:REPLICAOFA container for slow log commands.A container for slow log commands.Returns all members of a set.Returns all members of a set.RedisAPI.smismember(List<String> args) Determines whether multiple members belong to a set.ValkeyAPI.smismember(List<String> args) Determines whether multiple members belong to a set.Moves a member from one set to another.Moves a member from one set to another.Sorts the elements in a list, a set, or a sorted set, optionally storing the result.Sorts the elements in a list, a set, or a sorted set, optionally storing the result.Returns the sorted elements of a list, a set, or a sorted set.Returns the sorted elements of a list, a set, or a sorted set.Returns one or more random members from a set after removing them.Returns one or more random members from a set after removing them.Post a message to a shard channel.Post a message to a shard channel.RedisAPI.srandmember(List<String> args) Get one or multiple random members from a set.ValkeyAPI.srandmember(List<String> args) Get one or multiple random members from a set.Removes one or more members from a set.Removes one or more members from a set.Iterates over members of a set.Iterates over members of a set.RedisAPI.ssubscribe(List<String> args) Listens for messages published to shard channels.ValkeyAPI.ssubscribe(List<String> args) Listens for messages published to shard channels.Returns the length of a string value.Returns the length of a string value.Listens for messages published to channels.Listens for messages published to channels.Deprecated.since Redis 2.0.0, replaced by:GETRANGEReturns a substring from a string value.Returns the union of multiple sets.Returns the union of multiple sets.RedisAPI.sunionstore(List<String> args) Stores the union of multiple sets in a key.ValkeyAPI.sunionstore(List<String> args) Stores the union of multiple sets in a key.RedisAPI.sunsubscribe(List<String> args) Stops listening to messages posted to shard channels.ValkeyAPI.sunsubscribe(List<String> args) Stops listening to messages posted to shard channels.Swaps two Redis databases.Swaps two databases.RedisAPI.sync()An internal command used in replication.ValkeyAPI.sync()An internal command used in replication.RedisAPI.tdigestAdd(List<String> args) Adds one or more observations to a t-digest sketch.RedisAPI.tdigestByrank(List<String> args) Returns, for each input rank, an estimation of the value (floating-point) with that rank.RedisAPI.tdigestByrevrank(List<String> args) Returns, for each input reverse rank, an estimation of the value (floating-point) with that reverse rank.RedisAPI.tdigestCdf(List<String> args) Returns, for each input value, an estimation of the floating-point fraction of (observations smaller than the given value + half the observations equal to the given value).RedisAPI.tdigestCreate(List<String> args) Allocates memory and initializes a new t-digest sketch.RedisAPI.tdigestInfo(String arg0) Returns information and statistics about a t-digest sketch.RedisAPI.tdigestInfo(List<String> args) Returns information and statistics about a t-digest sketch.RedisAPI.tdigestMax(String arg0) Returns the maximum observation value from a t-digest sketch.RedisAPI.tdigestMax(List<String> args) Returns the maximum observation value from a t-digest sketch.RedisAPI.tdigestMerge(List<String> args) Merges multiple t-digest sketches into a single sketch.RedisAPI.tdigestMin(String arg0) Returns the minimum observation value from a t-digest sketch.RedisAPI.tdigestMin(List<String> args) Returns the minimum observation value from a t-digest sketch.RedisAPI.tdigestQuantile(List<String> args) Returns, for each input fraction, an estimation of the value (floating point) that is smaller than the given fraction of observations.RedisAPI.tdigestRank(List<String> args) Returns, for each input value (floating-point), the estimated rank of the value (the number of observations in the sketch that are smaller than the value + half the number of observations that are equal to the value).RedisAPI.tdigestReset(String arg0) Resets a t-digest sketch: empty the sketch and re-initializes it.RedisAPI.tdigestReset(List<String> args) Resets a t-digest sketch: empty the sketch and re-initializes it.RedisAPI.tdigestRevrank(List<String> args) Returns, for each input value (floating-point), the estimated reverse rank of the value (the number of observations in the sketch that are larger than the value + half the number of observations that are equal to the value).RedisAPI.tdigestTrimmedMean(String arg0, String arg1, String arg2) Returns an estimation of the mean value from the sketch, excluding observation values outside the low and high cutoff quantiles.RedisAPI.tdigestTrimmedMean(List<String> args) Returns an estimation of the mean value from the sketch, excluding observation values outside the low and high cutoff quantiles.RedisAPI.time()Returns the server time.ValkeyAPI.time()Returns the server time.RedisAPI.timeseriesClusterset(List<String> args) RedisAPI.timeseriesClustersetfromshard(List<String> args) Deprecated.this command no longer exists in the latest Redis releaseRedisAPI.timeseriesHello(List<String> args) Deprecated.this command no longer exists in the latest Redis releaseRedisAPI.timeseriesInfocluster(List<String> args) Deprecated.this command no longer exists in the latest Redis releaseRedisAPI.timeseriesInnercommunication(List<String> args) Deprecated.this command no longer exists in the latest Redis releaseRedisAPI.timeseriesNetworktest(List<String> args) Deprecated.this command no longer exists in the latest Redis releaseRedisAPI.timeseriesRefreshcluster(List<String> args) Adds an item to a Top-k sketch.Return the count for one or more items are in a sketch.RedisAPI.topkIncrby(List<String> args) Increases the count of one or more items by increment.Returns information about a sketch.Returns information about a sketch.Return the full list of items in Top-K sketch.Checks whether one or more items are in a sketch.RedisAPI.topkReserve(List<String> args) Initializes a Top-K sketch with specified parameters.Returns the number of existing keys out of those specified after updating the time they were last accessed.Returns the number of existing keys out of those specified after updating the time they were last accessed.Trim the keys that belong to specified slots.Append a sample to a time series.Update the retention, chunk size, duplicate policy, and labels of an existing time series.Create a new time series.RedisAPI.tsCreaterule(List<String> args) Create a compaction rule.Decrease the value of the latest sample.Delete all samples between two timestamps for a given time series.Delete all samples between two timestamps for a given time series.RedisAPI.tsDeleterule(String arg0, String arg1) Delete a compaction rule.RedisAPI.tsDeleterule(List<String> args) Delete a compaction rule.Get the sample with the highest timestamp from a given time series.Increase the value of the latest sample.Returns information and statistics for a time series.Append new samples to one or more time series.Get the sample with the highest timestamp from each time series matching a specific filter.Query a range across multiple time series by filters in forward direction.RedisAPI.tsMrevrange(List<String> args) Query a range across multiple time series by filters in reverse direction.RedisAPI.tsQueryindex(List<String> args) Get all time series keys matching a filter list.Query a range in forward direction.RedisAPI.tsRevrange(List<String> args) Query a range in reverse direction.Returns the expiration time in seconds of a key.Returns the expiration time in seconds of a key.Determines the type of value stored at a key.Determines the type of value stored at a key.Asynchronously deletes one or more keys.Asynchronously deletes one or more keys.RedisAPI.unsubscribe(List<String> args) Stops listening to messages posted to channels.ValkeyAPI.unsubscribe(List<String> args) Stops listening to messages posted to channels.RedisAPI.unwatch()Forgets about watched keys of a transaction.ValkeyAPI.unwatch()Forgets about watched keys of a transaction.Add one or more elements to a vector set, or update its vector if it already exists.Return the number of elements in a vector set.Return the dimension of vectors in the vector set.Return the vector associated with an element.Retrieve the JSON attributes of elements.Return information about a vector set.Check if an element exists in a vector set.Return the neighbors of an element at each layer in the HNSW graph.RedisAPI.vrandmember(List<String> args) Return one or multiple random members from a vector set.Return vector set elements in a lex range.Remove an element from a vector set.Associate or remove the JSON attributes of elements.Return elements by vector similarity.Blocks until the asynchronous replication of all preceding write commands sent by the connection is completed.Blocks until the asynchronous replication of all preceding write commands sent by the connection is completed.Blocks until all of the preceding write commands sent by the connection are written to the append-only file of the master and/or replicas.Blocks until all of the preceding write commands sent by the connection are written to the append-only file of the primary and/or replicas.Monitors changes to keys to determine the execution of a transaction.Monitors changes to keys to determine the execution of a transaction.Returns the number of messages that were successfully acknowledged by the consumer group member of a stream.Returns the number of messages that were successfully acknowledged by the consumer group member of a stream.Acknowledges and deletes one or multiple messages for a stream consumer group.Appends a new message to a stream.Appends a new message to a stream.RedisAPI.xautoclaim(List<String> args) Changes, or acquires, ownership of messages in a consumer group, as if the messages were delivered to as consumer group member.ValkeyAPI.xautoclaim(List<String> args) Changes, or acquires, ownership of messages in a consumer group, as if the messages were delivered to as consumer group member.Sets the IDMP configuration parameters for a stream.Changes, or acquires, ownership of a message in a consumer group, as if the message was delivered a consumer group member.Changes, or acquires, ownership of a message in a consumer group, as if the message was delivered a consumer group member.Returns the number of messages after removing them from a stream.Returns the number of messages after removing them from a stream.Deletes one or multiple entries from the stream.A container for consumer groups commands.A container for consumer groups commands.RedisAPI.xidmprecord(String arg0, String arg1, String arg2, String arg3) An internal command for setting IDMP metadata on an existing stream message.A container for stream introspection commands.A container for stream introspection commands.Return the number of messages in a stream.Return the number of messages in a stream.Returns the information and entries from a stream consumer group's pending entries list.Returns the information and entries from a stream consumer group's pending entries list.Returns the messages from a stream within a range of IDs.Returns the messages from a stream within a range of IDs.Returns messages from multiple streams with IDs greater than the ones requested.Returns messages from multiple streams with IDs greater than the ones requested.RedisAPI.xreadgroup(List<String> args) Returns new or historical messages from a stream for a consumer in a group.ValkeyAPI.xreadgroup(List<String> args) Returns new or historical messages from a stream for a consumer in a group.Returns the messages from a stream within a range of IDs in reverse order.Returns the messages from a stream within a range of IDs in reverse order.An internal command for replicating stream values.An internal command for replicating stream values.Deletes messages from the beginning of a stream.Deletes messages from the beginning of a stream.Adds one or more members to a sorted set, or updates their scores.Adds one or more members to a sorted set, or updates their scores.Returns the number of members in a sorted set.Returns the number of members in a sorted set.Returns the count of members in a sorted set that have scores within a range.Returns the count of members in a sorted set that have scores within a range.Returns the difference between multiple sorted sets.Returns the difference between multiple sorted sets.RedisAPI.zdiffstore(List<String> args) Stores the difference of multiple sorted sets in a key.ValkeyAPI.zdiffstore(List<String> args) Stores the difference of multiple sorted sets in a key.Increments the score of a member in a sorted set.Increments the score of a member in a sorted set.Returns the intersect of multiple sorted sets.Returns the intersect of multiple sorted sets.RedisAPI.zintercard(List<String> args) Returns the number of members of the intersect of multiple sorted sets.ValkeyAPI.zintercard(List<String> args) Returns the number of members of the intersect of multiple sorted sets.RedisAPI.zinterstore(List<String> args) Stores the intersect of multiple sorted sets in a key.ValkeyAPI.zinterstore(List<String> args) Stores the intersect of multiple sorted sets in a key.Returns the number of members in a sorted set within a lexicographical range.Returns the number of members in a sorted set within a lexicographical range.Returns the highest- or lowest-scoring members from one or more sorted sets after removing them.Returns the highest- or lowest-scoring members from one or more sorted sets after removing them.Returns the score of one or more members in a sorted set.Returns the score of one or more members in a sorted set.Returns the highest-scoring members from a sorted set after removing them.Returns the highest-scoring members from a sorted set after removing them.Returns the lowest-scoring members from a sorted set after removing them.Returns the lowest-scoring members from a sorted set after removing them.RedisAPI.zrandmember(List<String> args) Returns one or more random members from a sorted set.ValkeyAPI.zrandmember(List<String> args) Returns one or more random members from a sorted set.Returns members in a sorted set within a range of indexes.Returns members in a sorted set within a range of indexes.RedisAPI.zrangebylex(List<String> args) Deprecated.since Redis 6.2.0, replaced by:ZRANGEwith theBYLEXargumentValkeyAPI.zrangebylex(List<String> args) Returns members in a sorted set within a lexicographical range.RedisAPI.zrangebyscore(List<String> args) Deprecated.since Redis 6.2.0, replaced by:ZRANGEwith theBYSCOREargumentValkeyAPI.zrangebyscore(List<String> args) Returns members in a sorted set within a range of scores.RedisAPI.zrangestore(List<String> args) Stores a range of members from sorted set in a key.ValkeyAPI.zrangestore(List<String> args) Stores a range of members from sorted set in a key.Returns the index of a member in a sorted set ordered by ascending scores.Returns the index of a member in a sorted set ordered by ascending scores.Returns the index of a member in a sorted set ordered by ascending scores.Removes one or more members from a sorted set.Removes one or more members from a sorted set.RedisAPI.zremrangebylex(String arg0, String arg1, String arg2) Removes members in a sorted set within a lexicographical range.ValkeyAPI.zremrangebylex(String arg0, String arg1, String arg2) Removes members in a sorted set within a lexicographical range.RedisAPI.zremrangebyrank(String arg0, String arg1, String arg2) Removes members in a sorted set within a range of indexes.ValkeyAPI.zremrangebyrank(String arg0, String arg1, String arg2) Removes members in a sorted set within a range of indexes.RedisAPI.zremrangebyscore(String arg0, String arg1, String arg2) Removes members in a sorted set within a range of scores.ValkeyAPI.zremrangebyscore(String arg0, String arg1, String arg2) Removes members in a sorted set within a range of scores.Deprecated.since Redis 6.2.0, replaced by:ZRANGEwith theREVargumentReturns members in a sorted set within a range of indexes in reverse order.RedisAPI.zrevrangebylex(List<String> args) Deprecated.since Redis 6.2.0, replaced by:ZRANGEwith theREVandBYLEXargumentsValkeyAPI.zrevrangebylex(List<String> args) Returns members in a sorted set within a lexicographical range in reverse order.RedisAPI.zrevrangebyscore(List<String> args) Deprecated.since Redis 6.2.0, replaced by:ZRANGEwith theREVandBYSCOREargumentsValkeyAPI.zrevrangebyscore(List<String> args) Returns members in a sorted set within a range of scores in reverse order.Returns the index of a member in a sorted set ordered by descending scores.Returns the index of a member in a sorted set ordered by descending scores.Returns the index of a member in a sorted set ordered by descending scores.Iterates over members and scores of a sorted set.Iterates over members and scores of a sorted set.Returns the score of a member in a sorted set.Returns the score of a member in a sorted set.Returns the union of multiple sorted sets.Returns the union of multiple sorted sets.RedisAPI.zunionstore(List<String> args) Stores the union of multiple sorted sets in a key.ValkeyAPI.zunionstore(List<String> args) Stores the union of multiple sorted sets in a key.Method parameters in io.vertx.redis.client with type arguments of type FutureModifier and TypeMethodDescriptionstatic RedisRedis.createClusterClient(Vertx vertx, RedisOptions options, Supplier<Future<RedisClusterConnectOptions>> connectOptions) Creates a new cluster Redis client.static RedisRedis.createReplicationClient(Vertx vertx, RedisOptions options, Supplier<Future<RedisReplicationConnectOptions>> connectOptions) Creates a new replication Redis client.static RedisRedis.createSentinelClient(Vertx vertx, RedisOptions options, Supplier<Future<RedisSentinelConnectOptions>> connectOptions) Creates a new sentinel Redis client.static RedisRedis.createStandaloneClient(Vertx vertx, RedisOptions options, Supplier<Future<RedisStandaloneConnectOptions>> connectOptions) Creates a new standalone Redis client. -
Uses of Future in io.vertx.rxjava3
Methods in io.vertx.rxjava3 that return FutureModifier and TypeMethodDescriptionCompletableHelper.toFuture(Completable maybe) static <T> Future<T> Adapts an RxJava2Maybe<T>to a Vert.xFuture<T>.static <T,U> Future <U> LikeMaybeHelper.toFuture(Maybe)but with anadapterof the result.static <T> Future<T> Adapts an RxJava2Single<T>to a Vert.xFuture<T>.static <T,U> Future <U> LikeSingleHelper.toFuture(Single)but with anadapterof the result.Method parameters in io.vertx.rxjava3 with type arguments of type FutureModifier and TypeMethodDescriptionstatic <T> Flowable<T> FlowableHelper.toFlowable(Supplier<Future<ReadStream<T>>> supplier) Adapts a Vert.xReadStream<T>to an RxJavaFlowable<T>. -
Uses of Future in io.vertx.servicediscovery
Methods in io.vertx.servicediscovery that return FutureModifier and TypeMethodDescriptionServiceDiscovery.getRecord(JsonObject filter) Lookups for a single record.Looks up for a single record by its registrationid.Lookups for a single record.Lookups for a single record.ServiceDiscovery.getRecords(JsonObject filter) Lookups for a set of records.ServiceDiscovery.getRecords(Function<Record, Boolean> filter) Lookups for a set of records.ServiceDiscovery.getRecords(Function<Record, Boolean> filter, boolean includeOutOfService) Lookups for a set of records.Publishes a record.ServiceDiscovery.registerServiceExporter(ServiceExporter exporter, JsonObject configuration) Registers a discovery bridge.ServiceDiscovery.registerServiceImporter(ServiceImporter importer, JsonObject configuration) Registers a discovery service importer.Un-publishes a record.Updates the given record. -
Uses of Future in io.vertx.servicediscovery.spi
Methods in io.vertx.servicediscovery.spi that return Future -
Uses of Future in io.vertx.servicediscovery.types
Methods in io.vertx.servicediscovery.types that return FutureModifier and TypeMethodDescriptionstatic Future<HttpClient> HttpEndpoint.getClient(ServiceDiscovery discovery, JsonObject filter) Convenient method that looks for a HTTP endpoint and provides the configuredHttpClient.static Future<HttpClient> HttpEndpoint.getClient(ServiceDiscovery discovery, JsonObject filter, JsonObject conf) Convenient method that looks for a HTTP endpoint and provides the configuredHttpClient.static Future<HttpClient> HttpEndpoint.getClient(ServiceDiscovery discovery, Function<Record, Boolean> filter) Convenient method that looks for a HTTP endpoint and provides the configuredHttpClient.static Future<HttpClient> HttpEndpoint.getClient(ServiceDiscovery discovery, Function<Record, Boolean> filter, JsonObject conf) Convenient method that looks for a HTTP endpoint and provides the configuredHttpClient.static <T> Future<MessageConsumer<T>> MessageSource.getConsumer(ServiceDiscovery discovery, JsonObject filter) Convenient method that looks for a message source and provides the configuredMessageConsumer.static <T> Future<MessageConsumer<T>> MessageSource.getConsumer(ServiceDiscovery discovery, Function<Record, Boolean> filter) Convenient method that looks for a message source and provides the configuredMessageConsumer.static Future<MongoClient> MongoDataSource.getMongoClient(ServiceDiscovery discovery, JsonObject filter) Convenient method that looks for a Mongo datasource source and provides the configuredMongoClient.static Future<MongoClient> MongoDataSource.getMongoClient(ServiceDiscovery discovery, JsonObject filter, JsonObject consumerConfiguration) Convenient method that looks for a Mongo datasource source and provides the configuredMongoClient.static Future<MongoClient> MongoDataSource.getMongoClient(ServiceDiscovery discovery, Function<Record, Boolean> filter) Convenient method that looks for a Mongo datasource source and provides the configuredMongoClient.static <T> Future<T> EventBusService.getProxy(ServiceDiscovery discovery, Class<T> itf) Lookup for a service record and if found, retrieve it and return the service object (used to consume the service).static <T> Future<T> EventBusService.getProxy(ServiceDiscovery discovery, Class<T> itf, JsonObject conf) Lookup for a service record and if found, retrieve it and return the service object (used to consume the service).RedisDataSource.getRedisClient(ServiceDiscovery discovery, JsonObject filter) Convenient method that looks for a Redis data source and provides the configuredRedis.RedisDataSource.getRedisClient(ServiceDiscovery discovery, JsonObject filter, JsonObject consumerConfiguration) Convenient method that looks for a Redis data source and provides the configuredRedis.RedisDataSource.getRedisClient(ServiceDiscovery discovery, Function<Record, Boolean> filter) Convenient method that looks for a Redis data source and provides the configuredRedis.RedisDataSource.getRedisClient(ServiceDiscovery discovery, Function<Record, Boolean> filter, JsonObject consumerConfiguration) Convenient method that looks for a Redis data source and provides the configuredRedis.static <T> Future<T> EventBusService.getServiceProxy(ServiceDiscovery discovery, Function<Record, Boolean> filter, Class<T> clientClass) Lookup for a service record and if found, retrieve it and return the service object (used to consume the service).static <T> Future<T> EventBusService.getServiceProxy(ServiceDiscovery discovery, Function<Record, Boolean> filter, Class<T> clientClass, JsonObject conf) Lookup for a service record and if found, retrieve it and return the service object (used to consume the service).static <T> Future<T> EventBusService.getServiceProxyWithJsonFilter(ServiceDiscovery discovery, JsonObject filter, Class<T> clientClass) Lookup for a service record and if found, retrieve it and return the service object (used to consume the service).static <T> Future<T> EventBusService.getServiceProxyWithJsonFilter(ServiceDiscovery discovery, JsonObject filter, Class<T> clientClass, JsonObject conf) Lookup for a service record and if found, retrieve it and return the service object (used to consume the service).HttpEndpoint.getWebClient(ServiceDiscovery discovery, JsonObject filter) Convenient method that looks for a HTTP endpoint and provides the configured .HttpEndpoint.getWebClient(ServiceDiscovery discovery, JsonObject filter, JsonObject conf) Convenient method that looks for a HTTP endpoint and provides the configuredWebClient.HttpEndpoint.getWebClient(ServiceDiscovery discovery, Function<Record, Boolean> filter) Convenient method that looks for a HTTP endpoint and provides the configuredWebClient.HttpEndpoint.getWebClient(ServiceDiscovery discovery, Function<Record, Boolean> filter, JsonObject conf) Convenient method that looks for a HTTP endpoint and provides the configuredWebClient. -
Uses of Future in io.vertx.serviceproxy
Methods in io.vertx.serviceproxy that return FutureModifier and TypeMethodDescriptionstatic <T> Future<T> Create a failed Future containing a ServiceException.static <T> Future<T> ServiceException.fail(int failureCode, String message, JsonObject debugInfo) Create a failed Future containing a ServiceException.ServiceInterceptor.intercept(Vertx vertx, Map<String, Object> interceptorContext, Message<JsonObject> body) Perform the interceptor handling -
Uses of Future in io.vertx.serviceresolver
Methods in io.vertx.serviceresolver that return FutureModifier and TypeMethodDescriptionServiceResolverClient.close()Close the client and release the resources.ServiceResolverClient.resolveEndpoint(ServiceAddress address) -
Uses of Future in io.vertx.sqlclient
Methods in io.vertx.sqlclient that return FutureModifier and TypeMethodDescriptionSqlConnection.begin()Begin a transaction and returns aTransactionfor controlling and tracking this transaction.Cursor.close()Release the cursor.PreparedStatement.close()Close the prepared query and release its resources.RowStream.close()Close the stream and release the resources.SqlClient.close()Close the client and release the associated resources.Transaction.commit()Commit the current transaction.Transaction.completion()Return the transaction completionFuturethat succeeds when the transaction commits and fails withTransactionRollbackExceptionwhen the transaction rolls back.Execute the query.Query.execute()Execute the query.PreparedQuery.executeBatch(List<Tuple> batch) Execute the query with a batch of tuples.Pool.getConnection()Get a connection from the pool.Create a prepared statement using the givensqlstring.SqlConnection.prepare(String sql, PrepareOptions options) Create a prepared statement using the givensqlstring.Cursor.read(int count) Read rows from the cursor, the result is provided asynchronously to thehandler.Transaction.rollback()Rollback the transaction and release the associated resources.default <T> Future<T> Pool.withConnection(Function<SqlConnection, Future<T>> function) Get a connection from the pool and execute the givenfunction.default <T> Future<T> Pool.withTransaction(TransactionPropagation txPropagation, Function<SqlConnection, Future<T>> function) LikePool.withTransaction(Function)but allows for setting the mode, defining how the acquired connection is managed during the execution of the function.default <T> Future<T> Pool.withTransaction(Function<SqlConnection, Future<T>> function) Execute the givenfunctionwithin a transaction.Method parameters in io.vertx.sqlclient with type arguments of type FutureModifier and TypeMethodDescriptionClientBuilder.connectingTo(Supplier<Future<SqlConnectOptions>> supplier) Configure thedatabasethe client should connect to.default <T> Future<T> Pool.withConnection(Function<SqlConnection, Future<T>> function) Get a connection from the pool and execute the givenfunction.default <T> Future<T> Pool.withTransaction(TransactionPropagation txPropagation, Function<SqlConnection, Future<T>> function) LikePool.withTransaction(Function)but allows for setting the mode, defining how the acquired connection is managed during the execution of the function.default <T> Future<T> Pool.withTransaction(Function<SqlConnection, Future<T>> function) Execute the givenfunctionwithin a transaction. -
Uses of Future in io.vertx.sqlclient.spi
Method parameters in io.vertx.sqlclient.spi with type arguments of type FutureModifier and TypeMethodDescriptiondefault PoolDriver.createPool(Vertx vertx, Supplier<Future<C>> databases, PoolOptions poolOptions, NetClientOptions transportOptions, Handler<SqlConnection> connectHandler) Create a connection pool to the database configured with the givenconnectOptionsandpoolOptions.Driver.newPool(Vertx vertx, Supplier<Future<C>> databases, PoolOptions options, NetClientOptions transportOptions, Handler<SqlConnection> connectHandler, io.vertx.core.internal.CloseFuture closeFuture) Create a connection pool to the database configured with the givenconnectOptionsandpoolOptions.protected PoolDriverBase.newPool(io.vertx.core.internal.VertxInternal vertx, Handler<SqlConnection> connectHandler, Supplier<Future<O>> databases, PoolOptions poolOptions, NetClientOptions transportOptions, io.vertx.core.internal.CloseFuture closeFuture) DriverBase.newPool(Vertx vertx, Supplier<Future<O>> databases, PoolOptions options, NetClientOptions transportOptions, Handler<SqlConnection> connectHandler, io.vertx.core.internal.CloseFuture closeFuture) Constructor parameters in io.vertx.sqlclient.spi with type arguments of type FutureModifierConstructorDescriptionDriverBase(String discriminant, Function<Connection, Future<Void>> afterAcquire, Function<Connection, Future<Void>> beforeRecycle) -
Uses of Future in io.vertx.sqlclient.spi.connection
Methods in io.vertx.sqlclient.spi.connection that return FutureModifier and TypeMethodDescriptionCreate a connection using the givencontext.default Future<Connection> Methods in io.vertx.sqlclient.spi.connection with parameters of type Future -
Uses of Future in io.vertx.sqlclient.spi.protocol
Methods in io.vertx.sqlclient.spi.protocol that return FutureModifier and TypeMethodDescriptiondefault <R> Future<R> CommandScheduler.schedule(io.vertx.core.internal.ContextInternal context, CommandBase<R> cmd) -
Uses of Future in io.vertx.sqlclient.templates
Methods in io.vertx.sqlclient.templates that return Future
HttpClientRequest.writeHead(), this is scheduled for removal in Vert.x 6