Modifier and Type | Interface and Description |
---|---|
interface |
Future<T>
Represents the result of an action that may, or may not, have occurred yet.
|
Modifier and Type | Method and Description |
---|---|
void |
Vertx.close(Handler<AsyncResult<Void>> completionHandler)
Like
Vertx.close() but the completionHandler will be called when the close is complete |
static void |
Vertx.clusteredVertx(VertxOptions options,
Handler<AsyncResult<Vertx>> resultHandler)
Creates a clustered instance using the specified options.
|
void |
Vertx.deployVerticle(String name,
DeploymentOptions options,
Handler<AsyncResult<String>> completionHandler)
Like
Vertx.deployVerticle(String, Handler) but DeploymentOptions are provided to configure the
deployment. |
void |
Vertx.deployVerticle(String name,
Handler<AsyncResult<String>> completionHandler)
Like
Vertx.deployVerticle(String) but the completionHandler will be notified when the deployment is complete. |
void |
Vertx.deployVerticle(Verticle verticle,
DeploymentOptions options,
Handler<AsyncResult<String>> completionHandler)
Like
Vertx.deployVerticle(Verticle, Handler) but DeploymentOptions are provided to configure the
deployment. |
void |
Vertx.deployVerticle(Verticle verticle,
Handler<AsyncResult<String>> completionHandler)
Like
Vertx.deployVerticle(Verticle) but the completionHandler will be notified when the deployment is complete. |
<T> void |
Vertx.executeBlocking(Handler<Future<T>> blockingCodeHandler,
boolean ordered,
Handler<AsyncResult<T>> resultHandler)
Safely execute some blocking code.
|
<T> void |
Vertx.executeBlocking(Handler<Future<T>> blockingCodeHandler,
Handler<AsyncResult<T>> resultHandler)
Like
Vertx.executeBlocking(Handler, boolean, Handler) called with ordered = true. |
void |
Future.setHandler(Handler<AsyncResult<T>> handler)
Set a handler for the result.
|
void |
Vertx.undeploy(String deploymentID,
Handler<AsyncResult<Void>> completionHandler)
Like
Vertx.undeploy(String) but the completionHandler will be notified when the undeployment is complete. |
Modifier and Type | Method and Description |
---|---|
DatagramSocket |
DatagramSocket.blockMulticastGroup(String multicastAddress,
String sourceToBlock,
Handler<AsyncResult<DatagramSocket>> handler)
Block the given address for the given multicast address and notifies the
Handler once
the operation completes. |
DatagramSocket |
DatagramSocket.blockMulticastGroup(String multicastAddress,
String networkInterface,
String sourceToBlock,
Handler<AsyncResult<DatagramSocket>> handler)
Block the given address for the given multicast address on the given network interface and notifies
the
Handler once the operation completes. |
void |
DatagramSocket.close(Handler<AsyncResult<Void>> handler)
Closes the
DatagramSocket implementation asynchronous
and notifies the handler once done. |
DatagramSocket |
DatagramSocket.listen(int port,
String host,
Handler<AsyncResult<DatagramSocket>> handler)
Start listening on the given port and host.
|
DatagramSocket |
DatagramSocket.listenMulticastGroup(String multicastAddress,
Handler<AsyncResult<DatagramSocket>> handler)
Joins a multicast group and listens for packets send to it.
|
DatagramSocket |
DatagramSocket.listenMulticastGroup(String multicastAddress,
String networkInterface,
String source,
Handler<AsyncResult<DatagramSocket>> handler)
Joins a multicast group and listens for packets send to it on the given network interface.
|
DatagramSocket |
DatagramSocket.send(Buffer packet,
int port,
String host,
Handler<AsyncResult<DatagramSocket>> handler)
Write the given
Buffer to the SocketAddress . |
DatagramSocket |
DatagramSocket.send(String str,
int port,
String host,
Handler<AsyncResult<DatagramSocket>> handler)
Write the given
String to the SocketAddress using UTF8 encoding. |
DatagramSocket |
DatagramSocket.send(String str,
String enc,
int port,
String host,
Handler<AsyncResult<DatagramSocket>> handler)
Write the given
String to the SocketAddress using the given encoding. |
DatagramSocket |
DatagramSocket.unlistenMulticastGroup(String multicastAddress,
Handler<AsyncResult<DatagramSocket>> handler)
Leaves a multicast group and stops listening for packets send to it.
|
DatagramSocket |
DatagramSocket.unlistenMulticastGroup(String multicastAddress,
String networkInterface,
String source,
Handler<AsyncResult<DatagramSocket>> handler)
Leaves a multicast group and stops listening for packets send to it on the given network interface.
|
Modifier and Type | Method and Description |
---|---|
DnsClient |
DnsClient.lookup(String name,
Handler<AsyncResult<String>> handler)
Try to lookup the A (ipv4) or AAAA (ipv6) record for the given name.
|
DnsClient |
DnsClient.lookup4(String name,
Handler<AsyncResult<String>> handler)
Try to lookup the A (ipv4) record for the given name.
|
DnsClient |
DnsClient.lookup6(String name,
Handler<AsyncResult<String>> handler)
Try to lookup the AAAA (ipv6) record for the given name.
|
DnsClient |
DnsClient.resolveA(String name,
Handler<AsyncResult<List<String>>> handler)
Try to resolve all A (ipv4) records for the given name.
|
DnsClient |
DnsClient.resolveAAAA(String name,
Handler<AsyncResult<List<String>>> handler)
Try to resolve all AAAA (ipv6) records for the given name.
|
DnsClient |
DnsClient.resolveCNAME(String name,
Handler<AsyncResult<List<String>>> handler)
Try to resolve the CNAME record for the given name.
|
DnsClient |
DnsClient.resolveMX(String name,
Handler<AsyncResult<List<MxRecord>>> handler)
Try to resolve the MX records for the given name.
|
DnsClient |
DnsClient.resolveNS(String name,
Handler<AsyncResult<List<String>>> handler)
Try to resolve the NS records for the given name.
|
DnsClient |
DnsClient.resolvePTR(String name,
Handler<AsyncResult<String>> handler)
Try to resolve the PTR record for the given name.
|
DnsClient |
DnsClient.resolveSRV(String name,
Handler<AsyncResult<List<SrvRecord>>> handler)
Try to resolve the SRV records for the given name.
|
DnsClient |
DnsClient.resolveTXT(String name,
Handler<AsyncResult<List<String>>> handler)
Try to resolve the TXT records for the given name.
|
DnsClient |
DnsClient.reverseLookup(String ipaddress,
Handler<AsyncResult<String>> handler)
Try to do a reverse lookup of an IP address.
|
Modifier and Type | Method and Description |
---|---|
void |
EventBus.close(Handler<AsyncResult<Void>> completionHandler)
Close the event bus and release any resources held
|
void |
MessageConsumer.completionHandler(Handler<AsyncResult<Void>> completionHandler)
Optional method which can be called to indicate when the registration has been propagated across the cluster.
|
<R> void |
Message.reply(Object message,
DeliveryOptions options,
Handler<AsyncResult<Message<R>>> replyHandler)
The same as
reply(R message, DeliveryOptions) but you can specify handler for the reply - i.e. |
<R> void |
Message.reply(Object message,
Handler<AsyncResult<Message<R>>> replyHandler)
The same as
reply(R message) but you can specify handler for the reply - i.e. |
<T> EventBus |
EventBus.send(String address,
Object message,
DeliveryOptions options,
Handler<AsyncResult<Message<T>>> replyHandler)
Like
EventBus.send(String, Object, DeliveryOptions) but specifying a replyHandler that will be called if the recipient
subsequently replies to the message. |
<T> EventBus |
EventBus.send(String address,
Object message,
Handler<AsyncResult<Message<T>>> replyHandler)
Like
EventBus.send(String, Object) but specifying a replyHandler that will be called if the recipient
subsequently replies to the message. |
void |
MessageConsumer.unregister(Handler<AsyncResult<Void>> completionHandler)
Unregisters the handler which created this registration
|
Modifier and Type | Method and Description |
---|---|
FileSystem |
FileSystem.chmod(String path,
String perms,
Handler<AsyncResult<Void>> handler)
Change the permissions on the file represented by
path to perms , asynchronously. |
FileSystem |
FileSystem.chmodRecursive(String path,
String perms,
String dirPerms,
Handler<AsyncResult<Void>> handler)
Change the permissions on the file represented by
path to perms , asynchronously. |
FileSystem |
FileSystem.chown(String path,
String user,
String group,
Handler<AsyncResult<Void>> handler)
Change the ownership on the file represented by
path to user and {code group}, asynchronously. |
void |
AsyncFile.close(Handler<AsyncResult<Void>> handler)
Close the file.
|
FileSystem |
FileSystem.copy(String from,
String to,
Handler<AsyncResult<Void>> handler)
Copy a file from the path
from to path to , asynchronously. |
FileSystem |
FileSystem.copyRecursive(String from,
String to,
boolean recursive,
Handler<AsyncResult<Void>> handler)
Copy a file from the path
from to path to , asynchronously. |
FileSystem |
FileSystem.createFile(String path,
Handler<AsyncResult<Void>> handler)
Creates an empty file with the specified
path , asynchronously. |
FileSystem |
FileSystem.createFile(String path,
String perms,
Handler<AsyncResult<Void>> handler)
Creates an empty file with the specified
path and permissions perms , asynchronously. |
FileSystem |
FileSystem.delete(String path,
Handler<AsyncResult<Void>> handler)
Deletes the file represented by the specified
path , asynchronously. |
FileSystem |
FileSystem.deleteRecursive(String path,
boolean recursive,
Handler<AsyncResult<Void>> handler)
Deletes the file represented by the specified
path , asynchronously. |
FileSystem |
FileSystem.exists(String path,
Handler<AsyncResult<Boolean>> handler)
Determines whether the file as specified by the path
path exists, asynchronously. |
AsyncFile |
AsyncFile.flush(Handler<AsyncResult<Void>> handler)
Same as
AsyncFile.flush() but the handler will be called when the flush is complete or if an error occurs |
FileSystem |
FileSystem.fsProps(String path,
Handler<AsyncResult<FileSystemProps>> handler)
Returns properties of the file-system being used by the specified
path , asynchronously. |
FileSystem |
FileSystem.link(String link,
String existing,
Handler<AsyncResult<Void>> handler)
Create a hard link on the file system from
link to existing , asynchronously. |
FileSystem |
FileSystem.lprops(String path,
Handler<AsyncResult<FileProps>> handler)
Obtain properties for the link represented by
path , asynchronously. |
FileSystem |
FileSystem.mkdir(String path,
Handler<AsyncResult<Void>> handler)
Create the directory represented by
path , asynchronously. |
FileSystem |
FileSystem.mkdir(String path,
String perms,
Handler<AsyncResult<Void>> handler)
Create the directory represented by
path , asynchronously. |
FileSystem |
FileSystem.mkdirs(String path,
Handler<AsyncResult<Void>> handler)
Create the directory represented by
path and any non existent parents, asynchronously. |
FileSystem |
FileSystem.mkdirs(String path,
String perms,
Handler<AsyncResult<Void>> handler)
Create the directory represented by
path and any non existent parents, asynchronously. |
FileSystem |
FileSystem.move(String from,
String to,
Handler<AsyncResult<Void>> handler)
Move a file from the path
from to path to , asynchronously. |
FileSystem |
FileSystem.open(String path,
OpenOptions options,
Handler<AsyncResult<AsyncFile>> handler)
Open the file represented by
path , asynchronously. |
FileSystem |
FileSystem.props(String path,
Handler<AsyncResult<FileProps>> handler)
Obtain properties for the file represented by
path , asynchronously. |
AsyncFile |
AsyncFile.read(Buffer buffer,
int offset,
long position,
int length,
Handler<AsyncResult<Buffer>> handler)
Reads
length bytes of data from the file at position position in the file, asynchronously. |
FileSystem |
FileSystem.readDir(String path,
Handler<AsyncResult<List<String>>> handler)
Read the contents of the directory specified by
path , asynchronously. |
FileSystem |
FileSystem.readDir(String path,
String filter,
Handler<AsyncResult<List<String>>> handler)
Read the contents of the directory specified by
path , asynchronously. |
FileSystem |
FileSystem.readFile(String path,
Handler<AsyncResult<Buffer>> handler)
Reads the entire file as represented by the path
path as a Buffer , asynchronously. |
FileSystem |
FileSystem.readSymlink(String link,
Handler<AsyncResult<String>> handler)
Returns the path representing the file that the symbolic link specified by
link points to, asynchronously. |
FileSystem |
FileSystem.symlink(String link,
String existing,
Handler<AsyncResult<Void>> handler)
Create a symbolic link on the file system from
link to existing , asynchronously. |
FileSystem |
FileSystem.truncate(String path,
long len,
Handler<AsyncResult<Void>> handler)
Truncate the file represented by
path to length len in bytes, asynchronously. |
FileSystem |
FileSystem.unlink(String link,
Handler<AsyncResult<Void>> handler)
Unlinks the link on the file system represented by the path
link , asynchronously. |
AsyncFile |
AsyncFile.write(Buffer buffer,
long position,
Handler<AsyncResult<Void>> handler)
Write a
Buffer to the file at position position in the file, asynchronously. |
FileSystem |
FileSystem.writeFile(String path,
Buffer data,
Handler<AsyncResult<Void>> handler)
Creates the file, and writes the specified
Buffer data to the file represented by the path path ,
asynchronously. |
Modifier and Type | Method and Description |
---|---|
void |
HttpServer.close(Handler<AsyncResult<Void>> completionHandler)
Like
HttpServer.close() but supplying a handler that will be called when the server is actually closed (or has failed). |
HttpServer |
HttpServer.listen(Handler<AsyncResult<HttpServer>> listenHandler)
Like
HttpServer.listen() but supplying a handler that will be called when the server is actually listening (or has failed). |
HttpServer |
HttpServer.listen(int port,
Handler<AsyncResult<HttpServer>> listenHandler)
Like
HttpServer.listen(int) but supplying a handler that will be called when the server is actually listening (or has failed). |
HttpServer |
HttpServer.listen(int port,
String host,
Handler<AsyncResult<HttpServer>> listenHandler)
Like
HttpServer.listen(int, String) but supplying a handler that will be called when the server is actually
listening (or has failed). |
HttpServerResponse |
HttpServerResponse.sendFile(String filename,
Handler<AsyncResult<Void>> resultHandler)
Like
HttpServerResponse.sendFile(String) but providing a handler which will be notified once the file has been completely
written to the wire. |
Modifier and Type | Method and Description |
---|---|
void |
NetServer.close(Handler<AsyncResult<Void>> completionHandler)
Like
NetServer.close() but supplying a handler that will be notified when close is complete. |
NetClient |
NetClient.connect(int port,
String host,
Handler<AsyncResult<NetSocket>> connectHandler)
Open a connection to a server at the specific
port and host . |
NetServer |
NetServer.listen(Handler<AsyncResult<NetServer>> listenHandler)
Like
NetServer.listen() but providing a handler that will be notified when the server is listening, or fails. |
NetServer |
NetServer.listen(int port,
Handler<AsyncResult<NetServer>> listenHandler)
Like
NetServer.listen(int) but providing a handler that will be notified when the server is listening, or fails. |
NetServer |
NetServer.listen(int port,
String host,
Handler<AsyncResult<NetServer>> listenHandler)
Like
NetServer.listen(int, String) but providing a handler that will be notified when the server is listening, or fails. |
NetSocket |
NetSocket.sendFile(String filename,
Handler<AsyncResult<Void>> resultHandler)
Same as
NetSocket.sendFile(String) but also takes a handler that will be called when the send has completed or
a failure has occurred |
Modifier and Type | Method and Description |
---|---|
void |
Counter.addAndGet(long value,
Handler<AsyncResult<Long>> resultHandler)
Add the value to the counter atomically and return the new count
|
void |
AsyncMap.clear(Handler<AsyncResult<Void>> resultHandler)
Clear all entries in the map
|
void |
Counter.compareAndSet(long expected,
long value,
Handler<AsyncResult<Boolean>> resultHandler)
Set the counter to the specified value only if the current value is the expectec value.
|
void |
Counter.decrementAndGet(Handler<AsyncResult<Long>> resultHandler)
Decrement the counter atomically and return the new count
|
void |
Counter.get(Handler<AsyncResult<Long>> resultHandler)
Get the current value of the counter
|
void |
AsyncMap.get(K k,
Handler<AsyncResult<V>> resultHandler)
Get a value from the map, asynchronously.
|
void |
Counter.getAndAdd(long value,
Handler<AsyncResult<Long>> resultHandler)
Add the value to the counter atomically and return the value before the add
|
void |
Counter.getAndIncrement(Handler<AsyncResult<Long>> resultHandler)
Increment the counter atomically and return the value before the increment.
|
<K,V> void |
SharedData.getClusterWideMap(String name,
Handler<AsyncResult<AsyncMap<K,V>>> resultHandler)
Get the cluster wide map with the specified name.
|
void |
SharedData.getCounter(String name,
Handler<AsyncResult<Counter>> resultHandler)
Get a cluster wide counter.
|
void |
SharedData.getLock(String name,
Handler<AsyncResult<Lock>> resultHandler)
Get a cluster wide lock with the specified name.
|
void |
SharedData.getLockWithTimeout(String name,
long timeout,
Handler<AsyncResult<Lock>> resultHandler)
Like
SharedData.getLock(String, Handler) but specifying a timeout. |
void |
Counter.incrementAndGet(Handler<AsyncResult<Long>> resultHandler)
Increment the counter atomically and return the new count
|
void |
AsyncMap.put(K k,
V v,
Handler<AsyncResult<Void>> completionHandler)
Put a value in the map, asynchronously.
|
void |
AsyncMap.put(K k,
V v,
long timeout,
Handler<AsyncResult<Void>> completionHandler)
Like
AsyncMap.put(K, V, io.vertx.core.Handler<io.vertx.core.AsyncResult<java.lang.Void>>) but specifying a timeout. |
void |
AsyncMap.putIfAbsent(K k,
V v,
Handler<AsyncResult<V>> completionHandler)
Put the entry only if there is no entry with the key already present.
|
void |
AsyncMap.putIfAbsent(K k,
V v,
long timeout,
Handler<AsyncResult<V>> completionHandler)
Link
AsyncMap.putIfAbsent(K, V, io.vertx.core.Handler<io.vertx.core.AsyncResult<V>>) but specifying a timeout. |
void |
AsyncMap.remove(K k,
Handler<AsyncResult<V>> resultHandler)
Remove a value from the map, asynchronously.
|
void |
AsyncMap.removeIfPresent(K k,
V v,
Handler<AsyncResult<Boolean>> resultHandler)
Remove a value from the map, only if entry already exists with same value.
|
void |
AsyncMap.replace(K k,
V v,
Handler<AsyncResult<V>> resultHandler)
Replace the entry only if it is currently mapped to some value
|
void |
AsyncMap.replaceIfPresent(K k,
V oldValue,
V newValue,
Handler<AsyncResult<Boolean>> resultHandler)
Replace the entry only if it is currently mapped to a specific value
|
void |
AsyncMap.size(Handler<AsyncResult<Integer>> resultHandler)
Provide the number of entries in the map
|
Modifier and Type | Method and Description |
---|---|
void |
VertxFactory.clusteredVertx(VertxOptions options,
Handler<AsyncResult<Vertx>> resultHandler) |
Modifier and Type | Method and Description |
---|---|
void |
AsyncMultiMap.add(K k,
V v,
Handler<AsyncResult<Void>> completionHandler)
Add a value to the list of values for that key in the map
|
void |
AsyncMultiMap.get(K k,
Handler<AsyncResult<ChoosableIterable<V>>> resultHandler)
Get a list of values from the map for the key
|
<K,V> void |
ClusterManager.getAsyncMap(String name,
Handler<AsyncResult<AsyncMap<K,V>>> resultHandler)
Return an async map for the given name
|
<K,V> void |
ClusterManager.getAsyncMultiMap(String name,
Handler<AsyncResult<AsyncMultiMap<K,V>>> resultHandler)
Return an async multi-map for the given name
|
void |
ClusterManager.getCounter(String name,
Handler<AsyncResult<Counter>> resultHandler) |
void |
ClusterManager.getLockWithTimeout(String name,
long timeout,
Handler<AsyncResult<Lock>> resultHandler) |
void |
ClusterManager.join(Handler<AsyncResult<Void>> resultHandler)
Join the cluster
|
void |
ClusterManager.leave(Handler<AsyncResult<Void>> resultHandler)
Leave the cluster
|
void |
AsyncMultiMap.remove(K k,
V v,
Handler<AsyncResult<Boolean>> completionHandler)
Remove a value from the list of values for that key in the map.
|
void |
AsyncMultiMap.removeAllForValue(V v,
Handler<AsyncResult<Void>> completionHandler)
Remove all the specified values from all keys in the map
|
Modifier and Type | Method and Description |
---|---|
void |
AuthProvider.authenticate(JsonObject authInfo,
Handler<AsyncResult<User>> resultHandler)
Authenticate a user.
|
protected abstract void |
AbstractUser.doIsPermitted(String permission,
Handler<AsyncResult<Boolean>> resultHandler) |
User |
AbstractUser.isAuthorised(String authority,
Handler<AsyncResult<Boolean>> resultHandler) |
User |
User.isAuthorised(String authority,
Handler<AsyncResult<Boolean>> resultHandler)
Is the user authorised to
|
Modifier and Type | Method and Description |
---|---|
JDBCClient |
JDBCClient.getConnection(Handler<AsyncResult<io.vertx.ext.sql.SQLConnection>> handler)
Returns a connection that can be used to perform SQL operations on.
|
Modifier and Type | Method and Description |
---|---|
MailClient |
MailClient.sendMail(MailMessage email,
Handler<AsyncResult<MailResult>> resultHandler)
send a single mail via MailClient
|
MailService |
MailService.sendMail(MailMessage email,
Handler<AsyncResult<MailResult>> resultHandler) |
MailService |
MailServiceVertxEBProxy.sendMail(MailMessage email,
Handler<AsyncResult<MailResult>> resultHandler) |
Modifier and Type | Method and Description |
---|---|
MongoClient |
MongoClient.count(String collection,
JsonObject query,
Handler<AsyncResult<Long>> resultHandler)
Count matching documents in a collection.
|
MongoClient |
MongoClient.createCollection(String collectionName,
Handler<AsyncResult<Void>> resultHandler)
Create a new collection
|
MongoClient |
MongoClient.dropCollection(String collection,
Handler<AsyncResult<Void>> resultHandler)
Drop a collection
|
MongoClient |
MongoClient.find(String collection,
JsonObject query,
Handler<AsyncResult<List<JsonObject>>> resultHandler)
Find matching documents in the specified collection
|
MongoClient |
MongoClient.findOne(String collection,
JsonObject query,
JsonObject fields,
Handler<AsyncResult<JsonObject>> resultHandler)
Find a single matching document in the specified collection
|
MongoClient |
MongoClient.findWithOptions(String collection,
JsonObject query,
FindOptions options,
Handler<AsyncResult<List<JsonObject>>> resultHandler)
Find matching documents in the specified collection, specifying options
|
MongoClient |
MongoClient.getCollections(Handler<AsyncResult<List<String>>> resultHandler)
Get a list of all collections in the database.
|
MongoClient |
MongoClient.insert(String collection,
JsonObject document,
Handler<AsyncResult<String>> resultHandler)
Insert a document in the specified collection
|
MongoClient |
MongoClient.insertWithOptions(String collection,
JsonObject document,
WriteOption writeOption,
Handler<AsyncResult<String>> resultHandler)
Insert a document in the specified collection with the specified write option
|
MongoClient |
MongoClient.remove(String collection,
JsonObject query,
Handler<AsyncResult<Void>> resultHandler)
Remove matching documents from a collection
|
MongoClient |
MongoClient.removeOne(String collection,
JsonObject query,
Handler<AsyncResult<Void>> resultHandler)
Remove a single matching document from a collection
|
MongoClient |
MongoClient.removeOneWithOptions(String collection,
JsonObject query,
WriteOption writeOption,
Handler<AsyncResult<Void>> resultHandler)
Remove a single matching document from a collection with the specified write option
|
MongoClient |
MongoClient.removeWithOptions(String collection,
JsonObject query,
WriteOption writeOption,
Handler<AsyncResult<Void>> resultHandler)
Remove matching documents from a collection with the specified write option
|
MongoClient |
MongoClient.replace(String collection,
JsonObject query,
JsonObject replace,
Handler<AsyncResult<Void>> resultHandler)
Replace matching documents in the specified collection
|
MongoClient |
MongoClient.replaceWithOptions(String collection,
JsonObject query,
JsonObject replace,
UpdateOptions options,
Handler<AsyncResult<Void>> resultHandler)
Replace matching documents in the specified collection, specifying options
|
MongoClient |
MongoClient.runCommand(String commandName,
JsonObject command,
Handler<AsyncResult<JsonObject>> resultHandler)
Run an arbitrary MongoDB command.
|
MongoClient |
MongoClient.save(String collection,
JsonObject document,
Handler<AsyncResult<String>> resultHandler)
Save a document in the specified collection
|
MongoClient |
MongoClient.saveWithOptions(String collection,
JsonObject document,
WriteOption writeOption,
Handler<AsyncResult<String>> resultHandler)
Save a document in the specified collection with the specified write option
|
MongoClient |
MongoClient.update(String collection,
JsonObject query,
JsonObject update,
Handler<AsyncResult<Void>> resultHandler)
Update matching documents in the specified collection
|
MongoClient |
MongoClient.updateWithOptions(String collection,
JsonObject query,
JsonObject update,
UpdateOptions options,
Handler<AsyncResult<Void>> resultHandler)
Update matching documents in the specified collection, specifying options
|
Modifier and Type | Method and Description |
---|---|
<T> Handler<AsyncResult<T>> |
TestContext.asyncAssertFailure()
Creates and returns a new async handler, the returned handler controls the completion of the test.
When the returned handler is called back with a failed result it completes the async operation.
When the returned handler is called back with a succeeded result it fails the test.
|
<T> Handler<AsyncResult<T>> |
TestContext.asyncAssertFailure(Handler<Throwable> causeHandler)
Creates and returns a new async handler, the returned handler controls the completion of the test.
When the returned handler is called back with a failed result it completes the async operation.
When the returned handler is called back with a succeeded result it fails the test.
|
<T> Handler<AsyncResult<T>> |
TestContext.asyncAssertSuccess()
Creates and returns a new async handler, the returned handler controls the completion of the test.
When the returned handler is called back with a succeeded result it completes the async operation.
When the returned handler is called back with a failed result it fails the test with the cause of the failure.
|
<T> Handler<AsyncResult<T>> |
TestContext.asyncAssertSuccess(Handler<T> resultHandler)
Creates and returns a new async handler, the returned handler controls the completion of the test.
When the returned handler is called back with a succeeded result it invokes the
resultHandler argument
with the async result. |
Modifier and Type | Method and Description |
---|---|
void |
TestCompletion.handler(Handler<AsyncResult<Void>> completionHandler)
Completion handler for the end of the test, the result is successful when all test cases pass otherwise
it is failed.
|
Modifier and Type | Interface and Description |
---|---|
interface |
BridgeEvent
Represents an event that occurs on the event bus bridge.
|
Modifier and Type | Method and Description |
---|---|
void |
SessionStore.clear(Handler<AsyncResult<Boolean>> resultHandler)
Remove all sessions from the store
|
void |
SessionStore.delete(String id,
Handler<AsyncResult<Boolean>> resultHandler)
Delete the session with the specified ID
|
void |
SessionStore.get(String id,
Handler<AsyncResult<Session>> resultHandler)
Get the session with the specified ID
|
void |
SessionStore.put(Session session,
Handler<AsyncResult<Boolean>> resultHandler)
Add a session with the specified ID
|
void |
SessionStore.size(Handler<AsyncResult<Integer>> resultHandler)
Get the number of sessions in the store
|
Modifier and Type | Method and Description |
---|---|
void |
TemplateEngine.render(RoutingContext context,
String templateFileName,
Handler<AsyncResult<Buffer>> handler)
Render
|
Modifier and Type | Method and Description |
---|---|
static <V> AsyncResult<V> |
InternalHelper.failure(Throwable t) |
static <V> AsyncResult<V> |
InternalHelper.result(V value) |
Modifier and Type | Method and Description |
---|---|
static <V> Handler<AsyncResult<V>> |
InternalHelper.asyncResultHandler(CompletableFuture<V> f) |
Modifier and Type | Method and Description |
---|---|
RedisClient |
RedisClient.append(String key,
String value,
Handler<AsyncResult<Long>> handler)
Append a value to a key
|
RedisClient |
RedisClient.auth(String password,
Handler<AsyncResult<String>> handler)
Authenticate to the server
|
RedisClient |
RedisClient.bgrewriteaof(Handler<AsyncResult<String>> handler)
Asynchronously rewrite the append-only file
|
RedisClient |
RedisClient.bgsave(Handler<AsyncResult<String>> handler)
Asynchronously save the dataset to disk
|
RedisClient |
RedisClient.bitcount(String key,
Handler<AsyncResult<Long>> handler)
Count set bits in a string
|
RedisClient |
RedisClient.bitcountRange(String key,
long start,
long end,
Handler<AsyncResult<Long>> handler)
Count set bits in a string
|
RedisClient |
RedisClient.bitop(BitOperation operation,
String destkey,
List<String> keys,
Handler<AsyncResult<Long>> handler)
Perform bitwise operations between strings
|
RedisClient |
RedisClient.bitpos(String key,
int bit,
Handler<AsyncResult<Long>> handler)
Find first bit set or clear in a string
|
RedisClient |
RedisClient.bitposFrom(String key,
int bit,
int start,
Handler<AsyncResult<Long>> handler)
Find first bit set or clear in a string
See also bitposRange() method, which takes start, and stop offset.
|
RedisClient |
RedisClient.bitposRange(String key,
int bit,
int start,
int stop,
Handler<AsyncResult<Long>> handler)
Find first bit set or clear in a string
Note: when both start, and stop offsets are specified,
behaviour is slightly different than if only start is specified
|
RedisClient |
RedisClient.blpop(String key,
int seconds,
Handler<AsyncResult<JsonArray>> handler)
Remove and get the first element in a list, or block until one is available
|
RedisClient |
RedisClient.blpopMany(List<String> keys,
int seconds,
Handler<AsyncResult<JsonArray>> handler)
Remove and get the first element in any of the lists, or block until one is available
|
RedisClient |
RedisClient.brpop(String key,
int seconds,
Handler<AsyncResult<JsonArray>> handler)
Remove and get the last element in a list, or block until one is available
|
RedisClient |
RedisClient.brpoplpush(String key,
String destkey,
int seconds,
Handler<AsyncResult<Void>> handler)
Pop a value from a list, push it to another list and return it; or block until one is available
|
RedisClient |
RedisClient.brpopMany(List<String> keys,
int seconds,
Handler<AsyncResult<JsonArray>> handler)
Remove and get the last element in any of the lists, or block until one is available
|
RedisClient |
RedisClient.clientGetname(Handler<AsyncResult<String>> handler)
Get the current connection name
|
RedisClient |
RedisClient.clientKill(KillFilter filter,
Handler<AsyncResult<Long>> handler)
Kill the connection of a client
|
RedisClient |
RedisClient.clientList(Handler<AsyncResult<String>> handler)
Get the list of client connections
|
RedisClient |
RedisClient.clientPause(long millis,
Handler<AsyncResult<String>> handler)
Stop processing commands from clients for some time
|
RedisClient |
RedisClient.clientSetname(String name,
Handler<AsyncResult<String>> handler)
Set the current connection name
|
void |
RedisClient.close(Handler<AsyncResult<Void>> handler)
Close the client - when it is fully closed the handler will be called.
|
RedisClient |
RedisClient.clusterSlots(Handler<AsyncResult<JsonArray>> handler)
Get array of Cluster slot to node mappings
|
RedisClient |
RedisClient.command(Handler<AsyncResult<JsonArray>> handler)
Get array of Redis command details
|
RedisClient |
RedisClient.commandCount(Handler<AsyncResult<Long>> handler)
Get total number of Redis commands
|
RedisClient |
RedisClient.commandGetkeys(Handler<AsyncResult<JsonArray>> handler)
Extract keys given a full Redis command
|
RedisClient |
RedisClient.commandInfo(List<String> commands,
Handler<AsyncResult<JsonArray>> handler)
Get array of specific Redis command details
|
RedisClient |
RedisClient.configGet(String parameter,
Handler<AsyncResult<JsonArray>> handler)
Get the value of a configuration parameter
|
RedisClient |
RedisClient.configResetstat(Handler<AsyncResult<String>> handler)
Reset the stats returned by INFO
|
RedisClient |
RedisClient.configRewrite(Handler<AsyncResult<String>> handler)
Rewrite the configuration file with the in memory configuration
|
RedisClient |
RedisClient.configSet(String parameter,
String value,
Handler<AsyncResult<String>> handler)
Set a configuration parameter to the given value
|
RedisClient |
RedisClient.dbsize(Handler<AsyncResult<Long>> handler)
Return the number of keys in the selected database
|
RedisClient |
RedisClient.debugObject(String key,
Handler<AsyncResult<String>> handler)
Get debugging information about a key
|
RedisClient |
RedisClient.debugSegfault(Handler<AsyncResult<String>> handler)
Make the server crash
|
RedisClient |
RedisClient.decr(String key,
Handler<AsyncResult<Long>> handler)
Decrement the integer value of a key by one
|
RedisClient |
RedisClient.decrby(String key,
long decrement,
Handler<AsyncResult<Long>> handler)
Decrement the integer value of a key by the given number
|
RedisClient |
RedisClient.del(List<String> keys,
Handler<AsyncResult<Long>> handler)
Delete a key
|
RedisClient |
RedisClient.discard(Handler<AsyncResult<String>> handler)
Discard all commands issued after MULTI
|
RedisClient |
RedisClient.dump(String key,
Handler<AsyncResult<String>> handler)
Return a serialized version of the value stored at the specified key.
|
RedisClient |
RedisClient.echo(String message,
Handler<AsyncResult<String>> handler)
Echo the given string
|
RedisClient |
RedisClient.eval(String script,
List<String> keys,
List<String> args,
Handler<AsyncResult<Void>> handler)
Execute a Lua script server side
|
RedisClient |
RedisClient.evalsha(String sha1,
List<String> keys,
List<String> values,
Handler<AsyncResult<Void>> handler)
Execute a Lua script server side
|
RedisClient |
RedisClient.exec(Handler<AsyncResult<Void>> handler)
Execute all commands issued after MULTI
|
RedisClient |
RedisClient.exists(String key,
Handler<AsyncResult<Long>> handler)
Determine if a key exists
|
RedisClient |
RedisClient.expire(String key,
int seconds,
Handler<AsyncResult<Long>> handler)
Set a key's time to live in seconds
|
RedisClient |
RedisClient.expireat(String key,
long seconds,
Handler<AsyncResult<Long>> handler)
Set the expiration for a key as a UNIX timestamp
|
RedisClient |
RedisClient.flushall(Handler<AsyncResult<String>> handler)
Remove all keys from all databases
|
RedisClient |
RedisClient.flushdb(Handler<AsyncResult<String>> handler)
Remove all keys from the current database
|
RedisClient |
RedisClient.get(String key,
Handler<AsyncResult<String>> handler)
Get the value of a key
|
RedisClient |
RedisClient.getBinary(String key,
Handler<AsyncResult<String>> handler)
Get the value of a key - without decoding as utf-8
|
RedisClient |
RedisClient.getbit(String key,
long offset,
Handler<AsyncResult<Long>> handler)
Returns the bit value at offset in the string value stored at key
|
RedisClient |
RedisClient.getrange(String key,
long start,
long end,
Handler<AsyncResult<String>> handler)
Get a substring of the string stored at a key
|
RedisClient |
RedisClient.getset(String key,
String value,
Handler<AsyncResult<String>> handler)
Set the string value of a key and return its old value
|
RedisClient |
RedisClient.hdel(String key,
String field,
Handler<AsyncResult<Long>> handler)
Delete one or more hash fields
|
RedisClient |
RedisClient.hdelMany(String key,
List<String> fields,
Handler<AsyncResult<Long>> handler)
Delete one or more hash fields
|
RedisClient |
RedisClient.hexists(String key,
String field,
Handler<AsyncResult<Long>> handler)
Determine if a hash field exists
|
RedisClient |
RedisClient.hget(String key,
String field,
Handler<AsyncResult<String>> handler)
Get the value of a hash field
|
RedisClient |
RedisClient.hgetall(String key,
Handler<AsyncResult<JsonObject>> handler)
Get all the fields and values in a hash
|
RedisClient |
RedisClient.hincrby(String key,
String field,
long increment,
Handler<AsyncResult<Long>> handler)
Increment the integer value of a hash field by the given number
|
RedisClient |
RedisClient.hincrbyfloat(String key,
String field,
double increment,
Handler<AsyncResult<String>> handler)
Increment the float value of a hash field by the given amount
|
RedisClient |
RedisClient.hkeys(String key,
Handler<AsyncResult<JsonArray>> handler)
Get all the fields in a hash
|
RedisClient |
RedisClient.hlen(String key,
Handler<AsyncResult<Long>> handler)
Get the number of fields in a hash
|
RedisClient |
RedisClient.hmget(String key,
List<String> fields,
Handler<AsyncResult<JsonArray>> handler)
Get the values of all the given hash fields
|
RedisClient |
RedisClient.hmset(String key,
Map<String,String> values,
Handler<AsyncResult<String>> handler)
Set multiple hash fields to multiple values
|
RedisClient |
RedisClient.hscan(String key,
String cursor,
ScanOptions options,
Handler<AsyncResult<JsonArray>> handler)
Incrementally iterate hash fields and associated values
|
RedisClient |
RedisClient.hset(String key,
String field,
String value,
Handler<AsyncResult<Long>> handler)
Set the string value of a hash field
|
RedisClient |
RedisClient.hsetnx(String key,
String field,
String value,
Handler<AsyncResult<Long>> handler)
Set the value of a hash field, only if the field does not exist
|
RedisClient |
RedisClient.hvals(String key,
Handler<AsyncResult<JsonArray>> handler)
Get all the values in a hash
|
RedisClient |
RedisClient.incr(String key,
Handler<AsyncResult<Long>> handler)
Increment the integer value of a key by one
|
RedisClient |
RedisClient.incrby(String key,
long increment,
Handler<AsyncResult<Long>> handler)
Increment the integer value of a key by the given amount
|
RedisClient |
RedisClient.incrbyfloat(String key,
double increment,
Handler<AsyncResult<String>> handler)
Increment the float value of a key by the given amount
|
RedisClient |
RedisClient.info(Handler<AsyncResult<JsonObject>> handler)
Get information and statistics about the server
|
RedisClient |
RedisClient.infoSection(String section,
Handler<AsyncResult<JsonObject>> handler)
Get information and statistics about the server
|
RedisClient |
RedisClient.keys(String pattern,
Handler<AsyncResult<JsonArray>> handler)
Find all keys matching the given pattern
|
RedisClient |
RedisClient.lastsave(Handler<AsyncResult<Long>> handler)
Get the UNIX time stamp of the last successful save to disk
|
RedisClient |
RedisClient.lindex(String key,
int index,
Handler<AsyncResult<String>> handler)
Get an element from a list by its index
|
RedisClient |
RedisClient.linsert(String key,
InsertOptions option,
String pivot,
String value,
Handler<AsyncResult<Long>> handler)
Insert an element before or after another element in a list
|
RedisClient |
RedisClient.llen(String key,
Handler<AsyncResult<Long>> handler)
Get the length of a list
|
RedisClient |
RedisClient.lpop(String key,
Handler<AsyncResult<String>> handler)
Remove and get the first element in a list
|
RedisClient |
RedisClient.lpush(String key,
String value,
Handler<AsyncResult<Long>> handler)
Prepend one value to a list
|
RedisClient |
RedisClient.lpushMany(String key,
List<String> values,
Handler<AsyncResult<Long>> handler)
Prepend one or multiple values to a list
|
RedisClient |
RedisClient.lpushx(String key,
String value,
Handler<AsyncResult<Long>> handler)
Prepend a value to a list, only if the list exists
|
RedisClient |
RedisClient.lrange(String key,
long from,
long to,
Handler<AsyncResult<JsonArray>> handler)
Get a range of elements from a list
|
RedisClient |
RedisClient.lrem(String key,
long count,
String value,
Handler<AsyncResult<Long>> handler)
Remove elements from a list
|
RedisClient |
RedisClient.lset(String key,
long index,
String value,
Handler<AsyncResult<String>> handler)
Set the value of an element in a list by its index
|
RedisClient |
RedisClient.ltrim(String key,
long from,
long to,
Handler<AsyncResult<String>> handler)
Trim a list to the specified range
|
RedisClient |
RedisClient.mget(String key,
Handler<AsyncResult<JsonArray>> handler)
Get the value of the given key
|
RedisClient |
RedisClient.mgetMany(List<String> keys,
Handler<AsyncResult<JsonArray>> handler)
Get the values of all the given keys
|
RedisClient |
RedisClient.migrate(String host,
int port,
String key,
int destdb,
long timeout,
MigrateOptions options,
Handler<AsyncResult<String>> handler)
Atomically transfer a key from a Redis instance to another one.
|
RedisClient |
RedisClient.monitor(Handler<AsyncResult<Void>> handler)
Listen for all requests received by the server in real time
|
RedisClient |
RedisClient.move(String key,
int destdb,
Handler<AsyncResult<Long>> handler)
Move a key to another database
|
RedisClient |
RedisClient.mset(Map<String,String> keyvals,
Handler<AsyncResult<String>> handler)
Set multiple keys to multiple values
|
RedisClient |
RedisClient.msetnx(Map<String,String> keyvals,
Handler<AsyncResult<Long>> handler)
Set multiple keys to multiple values, only if none of the keys exist
|
RedisClient |
RedisClient.multi(Handler<AsyncResult<String>> handler)
Mark the start of a transaction block
|
RedisClient |
RedisClient.object(String key,
ObjectCmd cmd,
Handler<AsyncResult<Void>> handler)
Inspect the internals of Redis objects
|
RedisClient |
RedisClient.persist(String key,
Handler<AsyncResult<Long>> handler)
Remove the expiration from a key
|
RedisClient |
RedisClient.pexpire(String key,
long millis,
Handler<AsyncResult<Long>> handler)
Set a key's time to live in milliseconds
|
RedisClient |
RedisClient.pexpireat(String key,
long millis,
Handler<AsyncResult<Long>> handler)
Set the expiration for a key as a UNIX timestamp specified in milliseconds
|
RedisClient |
RedisClient.pfadd(String key,
String element,
Handler<AsyncResult<Long>> handler)
Adds the specified element to the specified HyperLogLog.
|
RedisClient |
RedisClient.pfaddMany(String key,
List<String> elements,
Handler<AsyncResult<Long>> handler)
Adds the specified elements to the specified HyperLogLog.
|
RedisClient |
RedisClient.pfcount(String key,
Handler<AsyncResult<Long>> handler)
Return the approximated cardinality of the set observed by the HyperLogLog at key.
|
RedisClient |
RedisClient.pfcountMany(List<String> keys,
Handler<AsyncResult<Long>> handler)
Return the approximated cardinality of the set(s) observed by the HyperLogLog at key(s).
|
RedisClient |
RedisClient.pfmerge(String destkey,
List<String> keys,
Handler<AsyncResult<String>> handler)
Merge N different HyperLogLogs into a single one.
|
RedisClient |
RedisClient.ping(Handler<AsyncResult<String>> handler)
Ping the server
|
RedisClient |
RedisClient.psetex(String key,
long millis,
String value,
Handler<AsyncResult<Void>> handler)
Set the value and expiration in milliseconds of a key
|
RedisClient |
RedisClient.psubscribe(String pattern,
Handler<AsyncResult<Void>> handler)
Listen for messages published to channels matching the given pattern
|
RedisClient |
RedisClient.psubscribeMany(List<String> patterns,
Handler<AsyncResult<Void>> handler)
Listen for messages published to channels matching the given patterns
|
RedisClient |
RedisClient.pttl(String key,
Handler<AsyncResult<Long>> handler)
Get the time to live for a key in milliseconds
|
RedisClient |
RedisClient.publish(String channel,
String message,
Handler<AsyncResult<Long>> handler)
Post a message to a channel
|
RedisClient |
RedisClient.pubsubChannels(String pattern,
Handler<AsyncResult<JsonArray>> handler)
Lists the currently active channels - only those matching the pattern
|
RedisClient |
RedisClient.pubsubNumpat(Handler<AsyncResult<Long>> handler)
Returns the number of subscriptions to patterns (that are performed using the PSUBSCRIBE command)
|
RedisClient |
RedisClient.pubsubNumsub(List<String> channels,
Handler<AsyncResult<JsonArray>> handler)
Returns the number of subscribers (not counting clients subscribed to patterns) for the specified channels
|
RedisClient |
RedisClient.punsubscribe(List<String> patterns,
Handler<AsyncResult<Void>> handler)
Stop listening for messages posted to channels matching the given patterns
|
RedisClient |
RedisClient.randomkey(Handler<AsyncResult<String>> handler)
Return a random key from the keyspace
|
RedisClient |
RedisClient.rename(String key,
String newkey,
Handler<AsyncResult<String>> handler)
Rename a key
|
RedisClient |
RedisClient.renamenx(String key,
String newkey,
Handler<AsyncResult<Long>> handler)
Rename a key, only if the new key does not exist
|
RedisClient |
RedisClient.restore(String key,
long millis,
String serialized,
Handler<AsyncResult<String>> handler)
Create a key using the provided serialized value, previously obtained using DUMP.
|
RedisClient |
RedisClient.role(Handler<AsyncResult<JsonArray>> handler)
Return the role of the instance in the context of replication
|
RedisClient |
RedisClient.rpop(String key,
Handler<AsyncResult<String>> handler)
Remove and get the last element in a list
|
RedisClient |
RedisClient.rpoplpush(String key,
String destkey,
Handler<AsyncResult<String>> handler)
Remove the last element in a list, append it to another list and return it
|
RedisClient |
RedisClient.rpush(String key,
String value,
Handler<AsyncResult<Long>> handler)
Append one or multiple values to a list
|
RedisClient |
RedisClient.rpushMany(String key,
List<String> values,
Handler<AsyncResult<Long>> handler)
Append one or multiple values to a list
|
RedisClient |
RedisClient.rpushx(String key,
String value,
Handler<AsyncResult<Long>> handler)
Append a value to a list, only if the list exists
|
RedisClient |
RedisClient.sadd(String key,
String member,
Handler<AsyncResult<Long>> handler)
Add a member to a set
|
RedisClient |
RedisClient.saddMany(String key,
List<String> members,
Handler<AsyncResult<Long>> handler)
Add one or more members to a set
|
RedisClient |
RedisClient.save(Handler<AsyncResult<String>> handler)
Synchronously save the dataset to disk
|
RedisClient |
RedisClient.scan(String cursor,
ScanOptions options,
Handler<AsyncResult<Void>> handler)
Incrementally iterate the keys space
|
RedisClient |
RedisClient.scard(String key,
Handler<AsyncResult<Long>> handler)
Get the number of members in a set
|
RedisClient |
RedisClient.scriptExists(String script,
Handler<AsyncResult<JsonArray>> handler)
Check existence of script in the script cache.
|
RedisClient |
RedisClient.scriptExistsMany(List<String> scripts,
Handler<AsyncResult<JsonArray>> handler)
Check existence of scripts in the script cache.
|
RedisClient |
RedisClient.scriptFlush(Handler<AsyncResult<String>> handler)
Remove all the scripts from the script cache.
|
RedisClient |
RedisClient.scriptKill(Handler<AsyncResult<String>> handler)
Kill the script currently in execution.
|
RedisClient |
RedisClient.scriptLoad(String script,
Handler<AsyncResult<String>> handler)
Load the specified Lua script into the script cache.
|
RedisClient |
RedisClient.sdiff(String key,
List<String> cmpkeys,
Handler<AsyncResult<JsonArray>> handler)
Subtract multiple sets
|
RedisClient |
RedisClient.sdiffstore(String destkey,
String key,
List<String> cmpkeys,
Handler<AsyncResult<Long>> handler)
Subtract multiple sets and store the resulting set in a key
|
RedisClient |
RedisClient.select(int dbindex,
Handler<AsyncResult<String>> handler)
Change the selected database for the current connection
|
RedisClient |
RedisClient.set(String key,
String value,
Handler<AsyncResult<Void>> handler)
Set the string value of a key
|
RedisClient |
RedisClient.setBinary(String key,
String value,
Handler<AsyncResult<Void>> handler)
Set the binary string value of a key - without encoding as utf-8
|
RedisClient |
RedisClient.setbit(String key,
long offset,
int bit,
Handler<AsyncResult<Long>> handler)
Sets or clears the bit at offset in the string value stored at key
|
RedisClient |
RedisClient.setex(String key,
long seconds,
String value,
Handler<AsyncResult<String>> handler)
Set the value and expiration of a key
|
RedisClient |
RedisClient.setnx(String key,
String value,
Handler<AsyncResult<Long>> handler)
Set the value of a key, only if the key does not exist
|
RedisClient |
RedisClient.setrange(String key,
int offset,
String value,
Handler<AsyncResult<Long>> handler)
Overwrite part of a string at key starting at the specified offset
|
RedisClient |
RedisClient.setWithOptions(String key,
String value,
SetOptions options,
Handler<AsyncResult<Void>> handler)
Set the string value of a key
|
RedisClient |
RedisClient.sinter(List<String> keys,
Handler<AsyncResult<JsonArray>> handler)
Intersect multiple sets
|
RedisClient |
RedisClient.sinterstore(String destkey,
List<String> keys,
Handler<AsyncResult<Long>> handler)
Intersect multiple sets and store the resulting set in a key
|
RedisClient |
RedisClient.sismember(String key,
String member,
Handler<AsyncResult<Long>> handler)
Determine if a given value is a member of a set
|
RedisClient |
RedisClient.slaveof(String host,
int port,
Handler<AsyncResult<String>> handler)
Make the server a slave of another instance
|
RedisClient |
RedisClient.slaveofNoone(Handler<AsyncResult<String>> handler)
Make this server a master
|
RedisClient |
RedisClient.slowlogGet(int limit,
Handler<AsyncResult<JsonArray>> handler)
Read the Redis slow queries log
|
RedisClient |
RedisClient.slowlogLen(Handler<AsyncResult<Long>> handler)
Get the length of the Redis slow queries log
|
RedisClient |
RedisClient.slowlogReset(Handler<AsyncResult<Void>> handler)
Reset the Redis slow queries log
|
RedisClient |
RedisClient.smembers(String key,
Handler<AsyncResult<JsonArray>> handler)
Get all the members in a set
|
RedisClient |
RedisClient.smove(String key,
String destkey,
String member,
Handler<AsyncResult<Long>> handler)
Move a member from one set to another
|
RedisClient |
RedisClient.sort(String key,
SortOptions options,
Handler<AsyncResult<JsonArray>> handler)
Sort the elements in a list, set or sorted set
|
RedisClient |
RedisClient.spop(String key,
Handler<AsyncResult<String>> handler)
Remove and return a random member from a set
|
RedisClient |
RedisClient.spopMany(String key,
int count,
Handler<AsyncResult<String>> handler)
Remove and return random members from a set
|
RedisClient |
RedisClient.srandmember(String key,
int count,
Handler<AsyncResult<JsonArray>> handler)
Get one or multiple random members from a set
|
RedisClient |
RedisClient.srem(String key,
String member,
Handler<AsyncResult<Long>> handler)
Remove one member from a set
|
RedisClient |
RedisClient.sremMany(String key,
List<String> members,
Handler<AsyncResult<Long>> handler)
Remove one or more members from a set
|
RedisClient |
RedisClient.sscan(String key,
String cursor,
ScanOptions options,
Handler<AsyncResult<Void>> handler)
Incrementally iterate Set elements
|
RedisClient |
RedisClient.strlen(String key,
Handler<AsyncResult<Long>> handler)
Get the length of the value stored in a key
|
RedisClient |
RedisClient.subscribe(List<String> channels,
Handler<AsyncResult<Void>> handler)
Listen for messages published to the given channels
|
RedisClient |
RedisClient.sunion(List<String> keys,
Handler<AsyncResult<JsonArray>> handler)
Add multiple sets
|
RedisClient |
RedisClient.sunionstore(String destkey,
List<String> keys,
Handler<AsyncResult<Long>> handler)
Add multiple sets and store the resulting set in a key
|
RedisClient |
RedisClient.sync(Handler<AsyncResult<Void>> handler)
Internal command used for replication
|
RedisClient |
RedisClient.time(Handler<AsyncResult<JsonArray>> handler)
Return the current server time
|
RedisClient |
RedisClient.ttl(String key,
Handler<AsyncResult<Long>> handler)
Get the time to live for a key
|
RedisClient |
RedisClient.type(String key,
Handler<AsyncResult<String>> handler)
Determine the type stored at key
|
RedisClient |
RedisClient.unsubscribe(List<String> channels,
Handler<AsyncResult<Void>> handler)
Stop listening for messages posted to the given channels
|
RedisClient |
RedisClient.unwatch(Handler<AsyncResult<String>> handler)
Forget about all watched keys
|
RedisClient |
RedisClient.watch(List<String> keys,
Handler<AsyncResult<String>> handler)
Watch the given keys to determine execution of the MULTI/EXEC block
|
RedisClient |
RedisClient.zadd(String key,
double score,
String member,
Handler<AsyncResult<Long>> handler)
Add one or more members to a sorted set, or update its score if it already exists
|
RedisClient |
RedisClient.zaddMany(String key,
Map<String,Double> members,
Handler<AsyncResult<Long>> handler)
Add one or more members to a sorted set, or update its score if it already exists
|
RedisClient |
RedisClient.zcard(String key,
Handler<AsyncResult<Long>> handler)
Get the number of members in a sorted set
|
RedisClient |
RedisClient.zcount(String key,
double min,
double max,
Handler<AsyncResult<Long>> handler)
Count the members in a sorted set with scores within the given values
|
RedisClient |
RedisClient.zincrby(String key,
double increment,
String member,
Handler<AsyncResult<String>> handler)
Increment the score of a member in a sorted set
|
RedisClient |
RedisClient.zinterstore(String destkey,
List<String> sets,
AggregateOptions options,
Handler<AsyncResult<Long>> handler)
Intersect multiple sorted sets and store the resulting sorted set in a new key
|
RedisClient |
RedisClient.zinterstoreWeighed(String destkey,
Map<String,Double> sets,
AggregateOptions options,
Handler<AsyncResult<Long>> handler)
Intersect multiple sorted sets and store the resulting sorted set in a new key using weights for scoring
|
RedisClient |
RedisClient.zlexcount(String key,
String min,
String max,
Handler<AsyncResult<Long>> handler)
Count the number of members in a sorted set between a given lexicographical range
|
RedisClient |
RedisClient.zrange(String key,
long start,
long stop,
Handler<AsyncResult<JsonArray>> handler)
Return a range of members in a sorted set, by index
|
RedisClient |
RedisClient.zrangebylex(String key,
String min,
String max,
LimitOptions options,
Handler<AsyncResult<JsonArray>> handler)
Return a range of members in a sorted set, by lexicographical range
|
RedisClient |
RedisClient.zrangebyscore(String key,
String min,
String max,
RangeLimitOptions options,
Handler<AsyncResult<JsonArray>> handler)
Return a range of members in a sorted set, by score
|
RedisClient |
RedisClient.zrangeWithOptions(String key,
long start,
long stop,
RangeOptions options,
Handler<AsyncResult<JsonArray>> handler)
Return a range of members in a sorted set, by index
|
RedisClient |
RedisClient.zrank(String key,
String member,
Handler<AsyncResult<Long>> handler)
Determine the index of a member in a sorted set
|
RedisClient |
RedisClient.zrem(String key,
String member,
Handler<AsyncResult<Long>> handler)
Remove one member from a sorted set
|
RedisClient |
RedisClient.zremMany(String key,
List<String> members,
Handler<AsyncResult<Long>> handler)
Remove one or more members from a sorted set
|
RedisClient |
RedisClient.zremrangebylex(String key,
String min,
String max,
Handler<AsyncResult<Long>> handler)
Remove all members in a sorted set between the given lexicographical range
|
RedisClient |
RedisClient.zremrangebyrank(String key,
long start,
long stop,
Handler<AsyncResult<Long>> handler)
Remove all members in a sorted set within the given indexes
|
RedisClient |
RedisClient.zremrangebyscore(String key,
String min,
String max,
Handler<AsyncResult<Long>> handler)
Remove all members in a sorted set within the given scores
|
RedisClient |
RedisClient.zrevrange(String key,
long start,
long stop,
RangeOptions options,
Handler<AsyncResult<JsonArray>> handler)
Return a range of members in a sorted set, by index, with scores ordered from high to low
|
RedisClient |
RedisClient.zrevrangebylex(String key,
String max,
String min,
LimitOptions options,
Handler<AsyncResult<JsonArray>> handler)
Return a range of members in a sorted set, by score, between the given lexicographical range with scores ordered from high to low
|
RedisClient |
RedisClient.zrevrangebyscore(String key,
String max,
String min,
RangeLimitOptions options,
Handler<AsyncResult<JsonArray>> handler)
Return a range of members in a sorted set, by score, with scores ordered from high to low
|
RedisClient |
RedisClient.zrevrank(String key,
String member,
Handler<AsyncResult<Long>> handler)
Determine the index of a member in a sorted set, with scores ordered from high to low
|
RedisClient |
RedisClient.zscan(String key,
String cursor,
ScanOptions options,
Handler<AsyncResult<Void>> handler)
Incrementally iterate sorted sets elements and associated scores
|
RedisClient |
RedisClient.zscore(String key,
String member,
Handler<AsyncResult<String>> handler)
Get the score associated with the given member in a sorted set
|
RedisClient |
RedisClient.zunionstore(String destkey,
List<String> sets,
AggregateOptions options,
Handler<AsyncResult<Long>> handler)
Add multiple sorted sets and store the resulting sorted set in a new key
|
RedisClient |
RedisClient.zunionstoreWeighed(String key,
Map<String,Double> sets,
AggregateOptions options,
Handler<AsyncResult<Long>> handler)
Add multiple sorted sets using weights, and store the resulting sorted set in a new key
|
Modifier and Type | Method and Description |
---|---|
static <T> Handler<AsyncResult<T>> |
RxHelper.toFuture(rx.functions.Action1<T> onNext)
Adapt an item callback as a
Handler<AsyncResult<T>> . |
static <T> Handler<AsyncResult<T>> |
RxHelper.toFuture(rx.functions.Action1<T> onNext,
rx.functions.Action1<Throwable> onError)
Adapt an item callback and an error callback as a
Handler<AsyncResult<T>> . |
static <T> Handler<AsyncResult<T>> |
RxHelper.toFuture(rx.functions.Action1<T> onNext,
rx.functions.Action1<Throwable> onError,
rx.functions.Action0 onComplete)
Adapt an item callback and an error callback as a
Handler<AsyncResult<T>> . |
static <T> Handler<AsyncResult<T>> |
RxHelper.toFuture(rx.Observer<T> observer)
Adapt a
Subscriber as a Handler<AsyncResult<T>>; . |
Handler<AsyncResult<T>> |
ObservableFuture.toHandler() |
Modifier and Type | Method and Description |
---|---|
void |
Vertx.close(Handler<AsyncResult<Void>> completionHandler)
Like
Vertx but the completionHandler will be called when the close is complete |
static void |
Vertx.clusteredVertx(VertxOptions options,
Handler<AsyncResult<Vertx>> resultHandler)
Creates a clustered instance using the specified options.
|
void |
Vertx.deployVerticle(String name,
DeploymentOptions options,
Handler<AsyncResult<String>> completionHandler)
Like
Vertx but DeploymentOptions are provided to configure the
deployment. |
void |
Vertx.deployVerticle(String name,
Handler<AsyncResult<String>> completionHandler)
Like
Vertx but the completionHandler will be notified when the deployment is complete. |
<T> void |
Vertx.executeBlocking(Handler<Future<T>> blockingCodeHandler,
boolean ordered,
Handler<AsyncResult<T>> resultHandler)
Safely execute some blocking code.
|
<T> void |
Vertx.executeBlocking(Handler<Future<T>> blockingCodeHandler,
Handler<AsyncResult<T>> resultHandler)
Like
Vertx called with ordered = true. |
void |
Future.setHandler(Handler<AsyncResult<T>> handler)
Set a handler for the result.
|
void |
Vertx.undeploy(String deploymentID,
Handler<AsyncResult<Void>> completionHandler)
Like
Vertx but the completionHandler will be notified when the undeployment is complete. |
Modifier and Type | Method and Description |
---|---|
DatagramSocket |
DatagramSocket.blockMulticastGroup(String multicastAddress,
String sourceToBlock,
Handler<AsyncResult<DatagramSocket>> handler)
Block the given address for the given multicast address and notifies the once
the operation completes.
|
DatagramSocket |
DatagramSocket.blockMulticastGroup(String multicastAddress,
String networkInterface,
String sourceToBlock,
Handler<AsyncResult<DatagramSocket>> handler)
Block the given address for the given multicast address on the given network interface and notifies
the once the operation completes.
|
void |
DatagramSocket.close(Handler<AsyncResult<Void>> handler)
Closes the
DatagramSocket implementation asynchronous
and notifies the handler once done. |
DatagramSocket |
DatagramSocket.listen(int port,
String host,
Handler<AsyncResult<DatagramSocket>> handler)
Start listening on the given port and host.
|
DatagramSocket |
DatagramSocket.listenMulticastGroup(String multicastAddress,
Handler<AsyncResult<DatagramSocket>> handler)
Joins a multicast group and listens for packets send to it.
|
DatagramSocket |
DatagramSocket.listenMulticastGroup(String multicastAddress,
String networkInterface,
String source,
Handler<AsyncResult<DatagramSocket>> handler)
Joins a multicast group and listens for packets send to it on the given network interface.
|
DatagramSocket |
DatagramSocket.send(Buffer packet,
int port,
String host,
Handler<AsyncResult<DatagramSocket>> handler)
Write the given
Buffer to the SocketAddress . |
DatagramSocket |
DatagramSocket.send(String str,
int port,
String host,
Handler<AsyncResult<DatagramSocket>> handler)
Write the given
String to the SocketAddress using UTF8 encoding. |
DatagramSocket |
DatagramSocket.send(String str,
String enc,
int port,
String host,
Handler<AsyncResult<DatagramSocket>> handler)
Write the given
String to the SocketAddress using the given encoding. |
DatagramSocket |
DatagramSocket.unlistenMulticastGroup(String multicastAddress,
Handler<AsyncResult<DatagramSocket>> handler)
Leaves a multicast group and stops listening for packets send to it.
|
DatagramSocket |
DatagramSocket.unlistenMulticastGroup(String multicastAddress,
String networkInterface,
String source,
Handler<AsyncResult<DatagramSocket>> handler)
Leaves a multicast group and stops listening for packets send to it on the given network interface.
|
Modifier and Type | Method and Description |
---|---|
DnsClient |
DnsClient.lookup(String name,
Handler<AsyncResult<String>> handler)
Try to lookup the A (ipv4) or AAAA (ipv6) record for the given name.
|
DnsClient |
DnsClient.lookup4(String name,
Handler<AsyncResult<String>> handler)
Try to lookup the A (ipv4) record for the given name.
|
DnsClient |
DnsClient.lookup6(String name,
Handler<AsyncResult<String>> handler)
Try to lookup the AAAA (ipv6) record for the given name.
|
DnsClient |
DnsClient.resolveA(String name,
Handler<AsyncResult<List<String>>> handler)
Try to resolve all A (ipv4) records for the given name.
|
DnsClient |
DnsClient.resolveAAAA(String name,
Handler<AsyncResult<List<String>>> handler)
Try to resolve all AAAA (ipv6) records for the given name.
|
DnsClient |
DnsClient.resolveCNAME(String name,
Handler<AsyncResult<List<String>>> handler)
Try to resolve the CNAME record for the given name.
|
DnsClient |
DnsClient.resolveMX(String name,
Handler<AsyncResult<List<MxRecord>>> handler)
Try to resolve the MX records for the given name.
|
DnsClient |
DnsClient.resolveNS(String name,
Handler<AsyncResult<List<String>>> handler)
Try to resolve the NS records for the given name.
|
DnsClient |
DnsClient.resolvePTR(String name,
Handler<AsyncResult<String>> handler)
Try to resolve the PTR record for the given name.
|
DnsClient |
DnsClient.resolveSRV(String name,
Handler<AsyncResult<List<SrvRecord>>> handler)
Try to resolve the SRV records for the given name.
|
DnsClient |
DnsClient.resolveTXT(String name,
Handler<AsyncResult<List<String>>> handler)
Try to resolve the TXT records for the given name.
|
DnsClient |
DnsClient.reverseLookup(String ipaddress,
Handler<AsyncResult<String>> handler)
Try to do a reverse lookup of an IP address.
|
Modifier and Type | Method and Description |
---|---|
void |
EventBus.close(Handler<AsyncResult<Void>> completionHandler)
Close the event bus and release any resources held
|
void |
MessageConsumer.completionHandler(Handler<AsyncResult<Void>> completionHandler)
Optional method which can be called to indicate when the registration has been propagated across the cluster.
|
<R> void |
Message.reply(Object message,
DeliveryOptions options,
Handler<AsyncResult<Message<R>>> replyHandler)
The same as
reply(R message, DeliveryOptions) but you can specify handler for the reply - i.e. |
<R> void |
Message.reply(Object message,
Handler<AsyncResult<Message<R>>> replyHandler)
The same as
reply(R message) but you can specify handler for the reply - i.e. |
<T> EventBus |
EventBus.send(String address,
Object message,
DeliveryOptions options,
Handler<AsyncResult<Message<T>>> replyHandler)
Like
EventBus.send(java.lang.String, java.lang.Object) but specifying a replyHandler that will be called if the recipient
subsequently replies to the message. |
<T> EventBus |
EventBus.send(String address,
Object message,
Handler<AsyncResult<Message<T>>> replyHandler)
Like
EventBus.send(java.lang.String, java.lang.Object) but specifying a replyHandler that will be called if the recipient
subsequently replies to the message. |
void |
MessageConsumer.unregister(Handler<AsyncResult<Void>> completionHandler)
Unregisters the handler which created this registration
|
Modifier and Type | Method and Description |
---|---|
FileSystem |
FileSystem.chmod(String path,
String perms,
Handler<AsyncResult<Void>> handler)
Change the permissions on the file represented by
path to perms , asynchronously. |
FileSystem |
FileSystem.chmodRecursive(String path,
String perms,
String dirPerms,
Handler<AsyncResult<Void>> handler)
Change the permissions on the file represented by
path to perms , asynchronously. |
FileSystem |
FileSystem.chown(String path,
String user,
String group,
Handler<AsyncResult<Void>> handler)
Change the ownership on the file represented by
path to user and {code group}, asynchronously. |
void |
AsyncFile.close(Handler<AsyncResult<Void>> handler)
Close the file.
|
FileSystem |
FileSystem.copy(String from,
String to,
Handler<AsyncResult<Void>> handler)
Copy a file from the path
from to path to , asynchronously. |
FileSystem |
FileSystem.copyRecursive(String from,
String to,
boolean recursive,
Handler<AsyncResult<Void>> handler)
Copy a file from the path
from to path to , asynchronously. |
FileSystem |
FileSystem.createFile(String path,
Handler<AsyncResult<Void>> handler)
Creates an empty file with the specified
path , asynchronously. |
FileSystem |
FileSystem.createFile(String path,
String perms,
Handler<AsyncResult<Void>> handler)
Creates an empty file with the specified
path and permissions perms , asynchronously. |
FileSystem |
FileSystem.delete(String path,
Handler<AsyncResult<Void>> handler)
Deletes the file represented by the specified
path , asynchronously. |
FileSystem |
FileSystem.deleteRecursive(String path,
boolean recursive,
Handler<AsyncResult<Void>> handler)
Deletes the file represented by the specified
path , asynchronously. |
FileSystem |
FileSystem.exists(String path,
Handler<AsyncResult<Boolean>> handler)
Determines whether the file as specified by the path
path exists, asynchronously. |
AsyncFile |
AsyncFile.flush(Handler<AsyncResult<Void>> handler)
Same as
AsyncFile.flush() but the handler will be called when the flush is complete or if an error occurs |
FileSystem |
FileSystem.fsProps(String path,
Handler<AsyncResult<FileSystemProps>> handler)
Returns properties of the file-system being used by the specified
path , asynchronously. |
FileSystem |
FileSystem.link(String link,
String existing,
Handler<AsyncResult<Void>> handler)
Create a hard link on the file system from
link to existing , asynchronously. |
FileSystem |
FileSystem.lprops(String path,
Handler<AsyncResult<FileProps>> handler)
Obtain properties for the link represented by
path , asynchronously. |
FileSystem |
FileSystem.mkdir(String path,
Handler<AsyncResult<Void>> handler)
Create the directory represented by
path , asynchronously. |
FileSystem |
FileSystem.mkdir(String path,
String perms,
Handler<AsyncResult<Void>> handler)
Create the directory represented by
path , asynchronously. |
FileSystem |
FileSystem.mkdirs(String path,
Handler<AsyncResult<Void>> handler)
Create the directory represented by
path and any non existent parents, asynchronously. |
FileSystem |
FileSystem.mkdirs(String path,
String perms,
Handler<AsyncResult<Void>> handler)
Create the directory represented by
path and any non existent parents, asynchronously. |
FileSystem |
FileSystem.move(String from,
String to,
Handler<AsyncResult<Void>> handler)
Move a file from the path
from to path to , asynchronously. |
FileSystem |
FileSystem.open(String path,
OpenOptions options,
Handler<AsyncResult<AsyncFile>> handler)
Open the file represented by
path , asynchronously. |
FileSystem |
FileSystem.props(String path,
Handler<AsyncResult<FileProps>> handler)
Obtain properties for the file represented by
path , asynchronously. |
AsyncFile |
AsyncFile.read(Buffer buffer,
int offset,
long position,
int length,
Handler<AsyncResult<Buffer>> handler)
Reads
length bytes of data from the file at position position in the file, asynchronously. |
FileSystem |
FileSystem.readDir(String path,
Handler<AsyncResult<List<String>>> handler)
Read the contents of the directory specified by
path , asynchronously. |
FileSystem |
FileSystem.readDir(String path,
String filter,
Handler<AsyncResult<List<String>>> handler)
Read the contents of the directory specified by
path , asynchronously. |
FileSystem |
FileSystem.readFile(String path,
Handler<AsyncResult<Buffer>> handler)
Reads the entire file as represented by the path
path as a , asynchronously. |
FileSystem |
FileSystem.readSymlink(String link,
Handler<AsyncResult<String>> handler)
Returns the path representing the file that the symbolic link specified by
link points to, asynchronously. |
FileSystem |
FileSystem.symlink(String link,
String existing,
Handler<AsyncResult<Void>> handler)
Create a symbolic link on the file system from
link to existing , asynchronously. |
FileSystem |
FileSystem.truncate(String path,
long len,
Handler<AsyncResult<Void>> handler)
Truncate the file represented by
path to length len in bytes, asynchronously. |
FileSystem |
FileSystem.unlink(String link,
Handler<AsyncResult<Void>> handler)
Unlinks the link on the file system represented by the path
link , asynchronously. |
AsyncFile |
AsyncFile.write(Buffer buffer,
long position,
Handler<AsyncResult<Void>> handler)
Write a
Buffer to the file at position position in the file, asynchronously. |
FileSystem |
FileSystem.writeFile(String path,
Buffer data,
Handler<AsyncResult<Void>> handler)
Creates the file, and writes the specified
Buffer data to the file represented by the path path ,
asynchronously. |
Modifier and Type | Method and Description |
---|---|
void |
HttpServer.close(Handler<AsyncResult<Void>> completionHandler)
Like
HttpServer but supplying a handler that will be called when the server is actually closed (or has failed). |
HttpServer |
HttpServer.listen(Handler<AsyncResult<HttpServer>> listenHandler)
Like
HttpServer but supplying a handler that will be called when the server is actually listening (or has failed). |
HttpServer |
HttpServer.listen(int port,
Handler<AsyncResult<HttpServer>> listenHandler)
Like
HttpServer.listen() but supplying a handler that will be called when the server is actually listening (or has failed). |
HttpServer |
HttpServer.listen(int port,
String host,
Handler<AsyncResult<HttpServer>> listenHandler)
Like
HttpServer.listen() but supplying a handler that will be called when the server is actually
listening (or has failed). |
HttpServerResponse |
HttpServerResponse.sendFile(String filename,
Handler<AsyncResult<Void>> resultHandler)
Like
HttpServerResponse.sendFile(java.lang.String) but providing a handler which will be notified once the file has been completely
written to the wire. |
Modifier and Type | Method and Description |
---|---|
void |
NetServer.close(Handler<AsyncResult<Void>> completionHandler)
Like
NetServer but supplying a handler that will be notified when close is complete. |
NetClient |
NetClient.connect(int port,
String host,
Handler<AsyncResult<NetSocket>> connectHandler)
Open a connection to a server at the specific
port and host . |
NetServer |
NetServer.listen(Handler<AsyncResult<NetServer>> listenHandler)
Like
NetServer.listen() but providing a handler that will be notified when the server is listening, or fails. |
NetServer |
NetServer.listen(int port,
Handler<AsyncResult<NetServer>> listenHandler)
Like
NetServer.listen() but providing a handler that will be notified when the server is listening, or fails. |
NetServer |
NetServer.listen(int port,
String host,
Handler<AsyncResult<NetServer>> listenHandler)
Like
NetServer.listen() but providing a handler that will be notified when the server is listening, or fails. |
NetSocket |
NetSocket.sendFile(String filename,
Handler<AsyncResult<Void>> resultHandler)
Same as
NetSocket.sendFile(java.lang.String) but also takes a handler that will be called when the send has completed or
a failure has occurred |
Modifier and Type | Method and Description |
---|---|
void |
Counter.addAndGet(long value,
Handler<AsyncResult<Long>> resultHandler)
Add the value to the counter atomically and return the new count
|
void |
AsyncMap.clear(Handler<AsyncResult<Void>> resultHandler)
Clear all entries in the map
|
void |
Counter.compareAndSet(long expected,
long value,
Handler<AsyncResult<Boolean>> resultHandler)
Set the counter to the specified value only if the current value is the expectec value.
|
void |
Counter.decrementAndGet(Handler<AsyncResult<Long>> resultHandler)
Decrement the counter atomically and return the new count
|
void |
Counter.get(Handler<AsyncResult<Long>> resultHandler)
Get the current value of the counter
|
void |
AsyncMap.get(K k,
Handler<AsyncResult<V>> resultHandler)
Get a value from the map, asynchronously.
|
void |
Counter.getAndAdd(long value,
Handler<AsyncResult<Long>> resultHandler)
Add the value to the counter atomically and return the value before the add
|
void |
Counter.getAndIncrement(Handler<AsyncResult<Long>> resultHandler)
Increment the counter atomically and return the value before the increment.
|
<K,V> void |
SharedData.getClusterWideMap(String name,
Handler<AsyncResult<AsyncMap<K,V>>> resultHandler)
Get the cluster wide map with the specified name.
|
void |
SharedData.getCounter(String name,
Handler<AsyncResult<Counter>> resultHandler)
Get a cluster wide counter.
|
void |
SharedData.getLock(String name,
Handler<AsyncResult<Lock>> resultHandler)
Get a cluster wide lock with the specified name.
|
void |
SharedData.getLockWithTimeout(String name,
long timeout,
Handler<AsyncResult<Lock>> resultHandler)
Like
SharedData but specifying a timeout. |
void |
Counter.incrementAndGet(Handler<AsyncResult<Long>> resultHandler)
Increment the counter atomically and return the new count
|
void |
AsyncMap.put(K k,
V v,
Handler<AsyncResult<Void>> completionHandler)
Put a value in the map, asynchronously.
|
void |
AsyncMap.put(K k,
V v,
long timeout,
Handler<AsyncResult<Void>> completionHandler)
Like
AsyncMap but specifying a timeout. |
void |
AsyncMap.putIfAbsent(K k,
V v,
Handler<AsyncResult<V>> completionHandler)
Put the entry only if there is no entry with the key already present.
|
void |
AsyncMap.putIfAbsent(K k,
V v,
long timeout,
Handler<AsyncResult<V>> completionHandler)
Link
AsyncMap but specifying a timeout. |
void |
AsyncMap.remove(K k,
Handler<AsyncResult<V>> resultHandler)
Remove a value from the map, asynchronously.
|
void |
AsyncMap.removeIfPresent(K k,
V v,
Handler<AsyncResult<Boolean>> resultHandler)
Remove a value from the map, only if entry already exists with same value.
|
void |
AsyncMap.replace(K k,
V v,
Handler<AsyncResult<V>> resultHandler)
Replace the entry only if it is currently mapped to some value
|
void |
AsyncMap.replaceIfPresent(K k,
V oldValue,
V newValue,
Handler<AsyncResult<Boolean>> resultHandler)
Replace the entry only if it is currently mapped to a specific value
|
void |
AsyncMap.size(Handler<AsyncResult<Integer>> resultHandler)
Provide the number of entries in the map
|
Modifier and Type | Method and Description |
---|---|
void |
AuthProvider.authenticate(JsonObject authInfo,
Handler<AsyncResult<User>> resultHandler)
Authenticate a user.
|
User |
User.isAuthorised(String authority,
Handler<AsyncResult<Boolean>> resultHandler)
Is the user authorised to
|
Modifier and Type | Method and Description |
---|---|
void |
AuthProvider.authenticate(JsonObject authInfo,
Handler<AsyncResult<User>> resultHandler)
Authenticate a user.
|
User |
User.hasPermission(String permission,
Handler<AsyncResult<Boolean>> resultHandler)
Does the user have the specified permission?
|
User |
User.hasPermissions(Set<String> permissions,
Handler<AsyncResult<Boolean>> resultHandler)
Does the user have all the specified permissions?
|
User |
User.hasRole(String role,
Handler<AsyncResult<Boolean>> resultHandler)
Does the user have the specified role?
|
User |
User.hasRoles(Set<String> roles,
Handler<AsyncResult<Boolean>> resultHandler)
Does the user have all the specified roles?
|
Modifier and Type | Method and Description |
---|---|
JDBCClient |
JDBCClient.getConnection(Handler<AsyncResult<io.vertx.rxjava.ext.sql.SQLConnection>> handler)
Returns a connection that can be used to perform SQL operations on.
|
Modifier and Type | Method and Description |
---|---|
MailClient |
MailClient.sendMail(MailMessage email,
Handler<AsyncResult<MailResult>> resultHandler)
send a single mail via MailClient
|
MailService |
MailService.sendMail(MailMessage email,
Handler<AsyncResult<MailResult>> resultHandler) |
Modifier and Type | Method and Description |
---|---|
MongoClient |
MongoClient.count(String collection,
JsonObject query,
Handler<AsyncResult<Long>> resultHandler)
Count matching documents in a collection.
|
MongoClient |
MongoClient.createCollection(String collectionName,
Handler<AsyncResult<Void>> resultHandler)
Create a new collection
|
MongoClient |
MongoClient.dropCollection(String collection,
Handler<AsyncResult<Void>> resultHandler)
Drop a collection
|
MongoClient |
MongoClient.find(String collection,
JsonObject query,
Handler<AsyncResult<List<JsonObject>>> resultHandler)
Find matching documents in the specified collection
|
MongoClient |
MongoClient.findOne(String collection,
JsonObject query,
JsonObject fields,
Handler<AsyncResult<JsonObject>> resultHandler)
Find a single matching document in the specified collection
|
MongoClient |
MongoClient.findWithOptions(String collection,
JsonObject query,
FindOptions options,
Handler<AsyncResult<List<JsonObject>>> resultHandler)
Find matching documents in the specified collection, specifying options
|
MongoClient |
MongoClient.getCollections(Handler<AsyncResult<List<String>>> resultHandler)
Get a list of all collections in the database.
|
MongoClient |
MongoClient.insert(String collection,
JsonObject document,
Handler<AsyncResult<String>> resultHandler)
Insert a document in the specified collection
|
MongoClient |
MongoClient.insertWithOptions(String collection,
JsonObject document,
WriteOption writeOption,
Handler<AsyncResult<String>> resultHandler)
Insert a document in the specified collection with the specified write option
|
MongoClient |
MongoClient.remove(String collection,
JsonObject query,
Handler<AsyncResult<Void>> resultHandler)
Remove matching documents from a collection
|
MongoClient |
MongoClient.removeOne(String collection,
JsonObject query,
Handler<AsyncResult<Void>> resultHandler)
Remove a single matching document from a collection
|
MongoClient |
MongoClient.removeOneWithOptions(String collection,
JsonObject query,
WriteOption writeOption,
Handler<AsyncResult<Void>> resultHandler)
Remove a single matching document from a collection with the specified write option
|
MongoClient |
MongoClient.removeWithOptions(String collection,
JsonObject query,
WriteOption writeOption,
Handler<AsyncResult<Void>> resultHandler)
Remove matching documents from a collection with the specified write option
|
MongoClient |
MongoClient.replace(String collection,
JsonObject query,
JsonObject replace,
Handler<AsyncResult<Void>> resultHandler)
Replace matching documents in the specified collection
|
MongoClient |
MongoClient.replaceWithOptions(String collection,
JsonObject query,
JsonObject replace,
UpdateOptions options,
Handler<AsyncResult<Void>> resultHandler)
Replace matching documents in the specified collection, specifying options
|
MongoClient |
MongoClient.runCommand(String commandName,
JsonObject command,
Handler<AsyncResult<JsonObject>> resultHandler)
Run an arbitrary MongoDB command.
|
MongoClient |
MongoClient.save(String collection,
JsonObject document,
Handler<AsyncResult<String>> resultHandler)
Save a document in the specified collection
|
MongoClient |
MongoClient.saveWithOptions(String collection,
JsonObject document,
WriteOption writeOption,
Handler<AsyncResult<String>> resultHandler)
Save a document in the specified collection with the specified write option
|
MongoClient |
MongoClient.update(String collection,
JsonObject query,
JsonObject update,
Handler<AsyncResult<Void>> resultHandler)
Update matching documents in the specified collection
|
MongoClient |
MongoClient.updateWithOptions(String collection,
JsonObject query,
JsonObject update,
UpdateOptions options,
Handler<AsyncResult<Void>> resultHandler)
Update matching documents in the specified collection, specifying options
|
Modifier and Type | Method and Description |
---|---|
void |
TestCompletion.handler(Handler<AsyncResult<Void>> completionHandler)
Completion handler for the end of the test, the result is successful when all test cases pass otherwise
it is failed.
|
Modifier and Type | Method and Description |
---|---|
void |
SessionStore.clear(Handler<AsyncResult<Boolean>> resultHandler)
Remove all sessions from the store
|
void |
SessionStore.delete(String id,
Handler<AsyncResult<Boolean>> resultHandler)
Delete the session with the specified ID
|
void |
SessionStore.get(String id,
Handler<AsyncResult<Session>> resultHandler)
Get the session with the specified ID
|
void |
SessionStore.put(Session session,
Handler<AsyncResult<Boolean>> resultHandler)
Add a session with the specified ID
|
void |
SessionStore.size(Handler<AsyncResult<Integer>> resultHandler)
Get the number of sessions in the store
|
Modifier and Type | Method and Description |
---|---|
void |
TemplateEngine.render(RoutingContext context,
String templateFileName,
Handler<AsyncResult<Buffer>> handler)
Render
|
Modifier and Type | Method and Description |
---|---|
RedisClient |
RedisClient.append(String key,
String value,
Handler<AsyncResult<Long>> handler)
Append a value to a key
|
RedisClient |
RedisClient.auth(String password,
Handler<AsyncResult<String>> handler)
Authenticate to the server
|
RedisClient |
RedisClient.bgrewriteaof(Handler<AsyncResult<String>> handler)
Asynchronously rewrite the append-only file
|
RedisClient |
RedisClient.bgsave(Handler<AsyncResult<String>> handler)
Asynchronously save the dataset to disk
|
RedisClient |
RedisClient.bitcount(String key,
Handler<AsyncResult<Long>> handler)
Count set bits in a string
|
RedisClient |
RedisClient.bitcountRange(String key,
long start,
long end,
Handler<AsyncResult<Long>> handler)
Count set bits in a string
|
RedisClient |
RedisClient.bitop(BitOperation operation,
String destkey,
List<String> keys,
Handler<AsyncResult<Long>> handler)
Perform bitwise operations between strings
|
RedisClient |
RedisClient.bitpos(String key,
int bit,
Handler<AsyncResult<Long>> handler)
Find first bit set or clear in a string
|
RedisClient |
RedisClient.bitposFrom(String key,
int bit,
int start,
Handler<AsyncResult<Long>> handler)
Find first bit set or clear in a string
See also bitposRange() method, which takes start, and stop offset.
|
RedisClient |
RedisClient.bitposRange(String key,
int bit,
int start,
int stop,
Handler<AsyncResult<Long>> handler)
Find first bit set or clear in a string
Note: when both start, and stop offsets are specified,
behaviour is slightly different than if only start is specified
|
RedisClient |
RedisClient.blpop(String key,
int seconds,
Handler<AsyncResult<JsonArray>> handler)
Remove and get the first element in a list, or block until one is available
|
RedisClient |
RedisClient.blpopMany(List<String> keys,
int seconds,
Handler<AsyncResult<JsonArray>> handler)
Remove and get the first element in any of the lists, or block until one is available
|
RedisClient |
RedisClient.brpop(String key,
int seconds,
Handler<AsyncResult<JsonArray>> handler)
Remove and get the last element in a list, or block until one is available
|
RedisClient |
RedisClient.brpoplpush(String key,
String destkey,
int seconds,
Handler<AsyncResult<Void>> handler)
Pop a value from a list, push it to another list and return it; or block until one is available
|
RedisClient |
RedisClient.brpopMany(List<String> keys,
int seconds,
Handler<AsyncResult<JsonArray>> handler)
Remove and get the last element in any of the lists, or block until one is available
|
RedisClient |
RedisClient.clientGetname(Handler<AsyncResult<String>> handler)
Get the current connection name
|
RedisClient |
RedisClient.clientKill(KillFilter filter,
Handler<AsyncResult<Long>> handler)
Kill the connection of a client
|
RedisClient |
RedisClient.clientList(Handler<AsyncResult<String>> handler)
Get the list of client connections
|
RedisClient |
RedisClient.clientPause(long millis,
Handler<AsyncResult<String>> handler)
Stop processing commands from clients for some time
|
RedisClient |
RedisClient.clientSetname(String name,
Handler<AsyncResult<String>> handler)
Set the current connection name
|
void |
RedisClient.close(Handler<AsyncResult<Void>> handler)
Close the client - when it is fully closed the handler will be called.
|
RedisClient |
RedisClient.clusterSlots(Handler<AsyncResult<JsonArray>> handler)
Get array of Cluster slot to node mappings
|
RedisClient |
RedisClient.command(Handler<AsyncResult<JsonArray>> handler)
Get array of Redis command details
|
RedisClient |
RedisClient.commandCount(Handler<AsyncResult<Long>> handler)
Get total number of Redis commands
|
RedisClient |
RedisClient.commandGetkeys(Handler<AsyncResult<JsonArray>> handler)
Extract keys given a full Redis command
|
RedisClient |
RedisClient.commandInfo(List<String> commands,
Handler<AsyncResult<JsonArray>> handler)
Get array of specific Redis command details
|
RedisClient |
RedisClient.configGet(String parameter,
Handler<AsyncResult<JsonArray>> handler)
Get the value of a configuration parameter
|
RedisClient |
RedisClient.configResetstat(Handler<AsyncResult<String>> handler)
Reset the stats returned by INFO
|
RedisClient |
RedisClient.configRewrite(Handler<AsyncResult<String>> handler)
Rewrite the configuration file with the in memory configuration
|
RedisClient |
RedisClient.configSet(String parameter,
String value,
Handler<AsyncResult<String>> handler)
Set a configuration parameter to the given value
|
RedisClient |
RedisClient.dbsize(Handler<AsyncResult<Long>> handler)
Return the number of keys in the selected database
|
RedisClient |
RedisClient.debugObject(String key,
Handler<AsyncResult<String>> handler)
Get debugging information about a key
|
RedisClient |
RedisClient.debugSegfault(Handler<AsyncResult<String>> handler)
Make the server crash
|
RedisClient |
RedisClient.decr(String key,
Handler<AsyncResult<Long>> handler)
Decrement the integer value of a key by one
|
RedisClient |
RedisClient.decrby(String key,
long decrement,
Handler<AsyncResult<Long>> handler)
Decrement the integer value of a key by the given number
|
RedisClient |
RedisClient.del(List<String> keys,
Handler<AsyncResult<Long>> handler)
Delete a key
|
RedisClient |
RedisClient.discard(Handler<AsyncResult<String>> handler)
Discard all commands issued after MULTI
|
RedisClient |
RedisClient.dump(String key,
Handler<AsyncResult<String>> handler)
Return a serialized version of the value stored at the specified key.
|
RedisClient |
RedisClient.echo(String message,
Handler<AsyncResult<String>> handler)
Echo the given string
|
RedisClient |
RedisClient.eval(String script,
List<String> keys,
List<String> args,
Handler<AsyncResult<Void>> handler)
Execute a Lua script server side
|
RedisClient |
RedisClient.evalsha(String sha1,
List<String> keys,
List<String> values,
Handler<AsyncResult<Void>> handler)
Execute a Lua script server side
|
RedisClient |
RedisClient.exec(Handler<AsyncResult<Void>> handler)
Execute all commands issued after MULTI
|
RedisClient |
RedisClient.exists(String key,
Handler<AsyncResult<Long>> handler)
Determine if a key exists
|
RedisClient |
RedisClient.expire(String key,
int seconds,
Handler<AsyncResult<Long>> handler)
Set a key's time to live in seconds
|
RedisClient |
RedisClient.expireat(String key,
long seconds,
Handler<AsyncResult<Long>> handler)
Set the expiration for a key as a UNIX timestamp
|
RedisClient |
RedisClient.flushall(Handler<AsyncResult<String>> handler)
Remove all keys from all databases
|
RedisClient |
RedisClient.flushdb(Handler<AsyncResult<String>> handler)
Remove all keys from the current database
|
RedisClient |
RedisClient.get(String key,
Handler<AsyncResult<String>> handler)
Get the value of a key
|
RedisClient |
RedisClient.getBinary(String key,
Handler<AsyncResult<String>> handler)
Get the value of a key - without decoding as utf-8
|
RedisClient |
RedisClient.getbit(String key,
long offset,
Handler<AsyncResult<Long>> handler)
Returns the bit value at offset in the string value stored at key
|
RedisClient |
RedisClient.getrange(String key,
long start,
long end,
Handler<AsyncResult<String>> handler)
Get a substring of the string stored at a key
|
RedisClient |
RedisClient.getset(String key,
String value,
Handler<AsyncResult<String>> handler)
Set the string value of a key and return its old value
|
RedisClient |
RedisClient.hdel(String key,
String field,
Handler<AsyncResult<Long>> handler)
Delete one or more hash fields
|
RedisClient |
RedisClient.hdelMany(String key,
List<String> fields,
Handler<AsyncResult<Long>> handler)
Delete one or more hash fields
|
RedisClient |
RedisClient.hexists(String key,
String field,
Handler<AsyncResult<Long>> handler)
Determine if a hash field exists
|
RedisClient |
RedisClient.hget(String key,
String field,
Handler<AsyncResult<String>> handler)
Get the value of a hash field
|
RedisClient |
RedisClient.hgetall(String key,
Handler<AsyncResult<JsonObject>> handler)
Get all the fields and values in a hash
|
RedisClient |
RedisClient.hincrby(String key,
String field,
long increment,
Handler<AsyncResult<Long>> handler)
Increment the integer value of a hash field by the given number
|
RedisClient |
RedisClient.hincrbyfloat(String key,
String field,
double increment,
Handler<AsyncResult<String>> handler)
Increment the float value of a hash field by the given amount
|
RedisClient |
RedisClient.hkeys(String key,
Handler<AsyncResult<JsonArray>> handler)
Get all the fields in a hash
|
RedisClient |
RedisClient.hlen(String key,
Handler<AsyncResult<Long>> handler)
Get the number of fields in a hash
|
RedisClient |
RedisClient.hmget(String key,
List<String> fields,
Handler<AsyncResult<JsonArray>> handler)
Get the values of all the given hash fields
|
RedisClient |
RedisClient.hmset(String key,
Map<String,String> values,
Handler<AsyncResult<String>> handler)
Set multiple hash fields to multiple values
|
RedisClient |
RedisClient.hscan(String key,
String cursor,
ScanOptions options,
Handler<AsyncResult<JsonArray>> handler)
Incrementally iterate hash fields and associated values
|
RedisClient |
RedisClient.hset(String key,
String field,
String value,
Handler<AsyncResult<Long>> handler)
Set the string value of a hash field
|
RedisClient |
RedisClient.hsetnx(String key,
String field,
String value,
Handler<AsyncResult<Long>> handler)
Set the value of a hash field, only if the field does not exist
|
RedisClient |
RedisClient.hvals(String key,
Handler<AsyncResult<JsonArray>> handler)
Get all the values in a hash
|
RedisClient |
RedisClient.incr(String key,
Handler<AsyncResult<Long>> handler)
Increment the integer value of a key by one
|
RedisClient |
RedisClient.incrby(String key,
long increment,
Handler<AsyncResult<Long>> handler)
Increment the integer value of a key by the given amount
|
RedisClient |
RedisClient.incrbyfloat(String key,
double increment,
Handler<AsyncResult<String>> handler)
Increment the float value of a key by the given amount
|
RedisClient |
RedisClient.info(Handler<AsyncResult<JsonObject>> handler)
Get information and statistics about the server
|
RedisClient |
RedisClient.infoSection(String section,
Handler<AsyncResult<JsonObject>> handler)
Get information and statistics about the server
|
RedisClient |
RedisClient.keys(String pattern,
Handler<AsyncResult<JsonArray>> handler)
Find all keys matching the given pattern
|
RedisClient |
RedisClient.lastsave(Handler<AsyncResult<Long>> handler)
Get the UNIX time stamp of the last successful save to disk
|
RedisClient |
RedisClient.lindex(String key,
int index,
Handler<AsyncResult<String>> handler)
Get an element from a list by its index
|
RedisClient |
RedisClient.linsert(String key,
InsertOptions option,
String pivot,
String value,
Handler<AsyncResult<Long>> handler)
Insert an element before or after another element in a list
|
RedisClient |
RedisClient.llen(String key,
Handler<AsyncResult<Long>> handler)
Get the length of a list
|
RedisClient |
RedisClient.lpop(String key,
Handler<AsyncResult<String>> handler)
Remove and get the first element in a list
|
RedisClient |
RedisClient.lpush(String key,
String value,
Handler<AsyncResult<Long>> handler)
Prepend one value to a list
|
RedisClient |
RedisClient.lpushMany(String key,
List<String> values,
Handler<AsyncResult<Long>> handler)
Prepend one or multiple values to a list
|
RedisClient |
RedisClient.lpushx(String key,
String value,
Handler<AsyncResult<Long>> handler)
Prepend a value to a list, only if the list exists
|
RedisClient |
RedisClient.lrange(String key,
long from,
long to,
Handler<AsyncResult<JsonArray>> handler)
Get a range of elements from a list
|
RedisClient |
RedisClient.lrem(String key,
long count,
String value,
Handler<AsyncResult<Long>> handler)
Remove elements from a list
|
RedisClient |
RedisClient.lset(String key,
long index,
String value,
Handler<AsyncResult<String>> handler)
Set the value of an element in a list by its index
|
RedisClient |
RedisClient.ltrim(String key,
long from,
long to,
Handler<AsyncResult<String>> handler)
Trim a list to the specified range
|
RedisClient |
RedisClient.mget(String key,
Handler<AsyncResult<JsonArray>> handler)
Get the value of the given key
|
RedisClient |
RedisClient.mgetMany(List<String> keys,
Handler<AsyncResult<JsonArray>> handler)
Get the values of all the given keys
|
RedisClient |
RedisClient.migrate(String host,
int port,
String key,
int destdb,
long timeout,
MigrateOptions options,
Handler<AsyncResult<String>> handler)
Atomically transfer a key from a Redis instance to another one.
|
RedisClient |
RedisClient.monitor(Handler<AsyncResult<Void>> handler)
Listen for all requests received by the server in real time
|
RedisClient |
RedisClient.move(String key,
int destdb,
Handler<AsyncResult<Long>> handler)
Move a key to another database
|
RedisClient |
RedisClient.mset(Map<String,String> keyvals,
Handler<AsyncResult<String>> handler)
Set multiple keys to multiple values
|
RedisClient |
RedisClient.msetnx(Map<String,String> keyvals,
Handler<AsyncResult<Long>> handler)
Set multiple keys to multiple values, only if none of the keys exist
|
RedisClient |
RedisClient.multi(Handler<AsyncResult<String>> handler)
Mark the start of a transaction block
|
RedisClient |
RedisClient.object(String key,
ObjectCmd cmd,
Handler<AsyncResult<Void>> handler)
Inspect the internals of Redis objects
|
RedisClient |
RedisClient.persist(String key,
Handler<AsyncResult<Long>> handler)
Remove the expiration from a key
|
RedisClient |
RedisClient.pexpire(String key,
long millis,
Handler<AsyncResult<Long>> handler)
Set a key's time to live in milliseconds
|
RedisClient |
RedisClient.pexpireat(String key,
long millis,
Handler<AsyncResult<Long>> handler)
Set the expiration for a key as a UNIX timestamp specified in milliseconds
|
RedisClient |
RedisClient.pfadd(String key,
String element,
Handler<AsyncResult<Long>> handler)
Adds the specified element to the specified HyperLogLog.
|
RedisClient |
RedisClient.pfaddMany(String key,
List<String> elements,
Handler<AsyncResult<Long>> handler)
Adds the specified elements to the specified HyperLogLog.
|
RedisClient |
RedisClient.pfcount(String key,
Handler<AsyncResult<Long>> handler)
Return the approximated cardinality of the set observed by the HyperLogLog at key.
|
RedisClient |
RedisClient.pfcountMany(List<String> keys,
Handler<AsyncResult<Long>> handler)
Return the approximated cardinality of the set(s) observed by the HyperLogLog at key(s).
|
RedisClient |
RedisClient.pfmerge(String destkey,
List<String> keys,
Handler<AsyncResult<String>> handler)
Merge N different HyperLogLogs into a single one.
|
RedisClient |
RedisClient.ping(Handler<AsyncResult<String>> handler)
Ping the server
|
RedisClient |
RedisClient.psetex(String key,
long millis,
String value,
Handler<AsyncResult<Void>> handler)
Set the value and expiration in milliseconds of a key
|
RedisClient |
RedisClient.psubscribe(String pattern,
Handler<AsyncResult<Void>> handler)
Listen for messages published to channels matching the given pattern
|
RedisClient |
RedisClient.psubscribeMany(List<String> patterns,
Handler<AsyncResult<Void>> handler)
Listen for messages published to channels matching the given patterns
|
RedisClient |
RedisClient.pttl(String key,
Handler<AsyncResult<Long>> handler)
Get the time to live for a key in milliseconds
|
RedisClient |
RedisClient.publish(String channel,
String message,
Handler<AsyncResult<Long>> handler)
Post a message to a channel
|
RedisClient |
RedisClient.pubsubChannels(String pattern,
Handler<AsyncResult<JsonArray>> handler)
Lists the currently active channels - only those matching the pattern
|
RedisClient |
RedisClient.pubsubNumpat(Handler<AsyncResult<Long>> handler)
Returns the number of subscriptions to patterns (that are performed using the PSUBSCRIBE command)
|
RedisClient |
RedisClient.pubsubNumsub(List<String> channels,
Handler<AsyncResult<JsonArray>> handler)
Returns the number of subscribers (not counting clients subscribed to patterns) for the specified channels
|
RedisClient |
RedisClient.punsubscribe(List<String> patterns,
Handler<AsyncResult<Void>> handler)
Stop listening for messages posted to channels matching the given patterns
|
RedisClient |
RedisClient.randomkey(Handler<AsyncResult<String>> handler)
Return a random key from the keyspace
|
RedisClient |
RedisClient.rename(String key,
String newkey,
Handler<AsyncResult<String>> handler)
Rename a key
|
RedisClient |
RedisClient.renamenx(String key,
String newkey,
Handler<AsyncResult<Long>> handler)
Rename a key, only if the new key does not exist
|
RedisClient |
RedisClient.restore(String key,
long millis,
String serialized,
Handler<AsyncResult<String>> handler)
Create a key using the provided serialized value, previously obtained using DUMP.
|
RedisClient |
RedisClient.role(Handler<AsyncResult<JsonArray>> handler)
Return the role of the instance in the context of replication
|
RedisClient |
RedisClient.rpop(String key,
Handler<AsyncResult<String>> handler)
Remove and get the last element in a list
|
RedisClient |
RedisClient.rpoplpush(String key,
String destkey,
Handler<AsyncResult<String>> handler)
Remove the last element in a list, append it to another list and return it
|
RedisClient |
RedisClient.rpush(String key,
String value,
Handler<AsyncResult<Long>> handler)
Append one or multiple values to a list
|
RedisClient |
RedisClient.rpushMany(String key,
List<String> values,
Handler<AsyncResult<Long>> handler)
Append one or multiple values to a list
|
RedisClient |
RedisClient.rpushx(String key,
String value,
Handler<AsyncResult<Long>> handler)
Append a value to a list, only if the list exists
|
RedisClient |
RedisClient.sadd(String key,
String member,
Handler<AsyncResult<Long>> handler)
Add a member to a set
|
RedisClient |
RedisClient.saddMany(String key,
List<String> members,
Handler<AsyncResult<Long>> handler)
Add one or more members to a set
|
RedisClient |
RedisClient.save(Handler<AsyncResult<String>> handler)
Synchronously save the dataset to disk
|
RedisClient |
RedisClient.scan(String cursor,
ScanOptions options,
Handler<AsyncResult<Void>> handler)
Incrementally iterate the keys space
|
RedisClient |
RedisClient.scard(String key,
Handler<AsyncResult<Long>> handler)
Get the number of members in a set
|
RedisClient |
RedisClient.scriptExists(String script,
Handler<AsyncResult<JsonArray>> handler)
Check existence of script in the script cache.
|
RedisClient |
RedisClient.scriptExistsMany(List<String> scripts,
Handler<AsyncResult<JsonArray>> handler)
Check existence of scripts in the script cache.
|
RedisClient |
RedisClient.scriptFlush(Handler<AsyncResult<String>> handler)
Remove all the scripts from the script cache.
|
RedisClient |
RedisClient.scriptKill(Handler<AsyncResult<String>> handler)
Kill the script currently in execution.
|
RedisClient |
RedisClient.scriptLoad(String script,
Handler<AsyncResult<String>> handler)
Load the specified Lua script into the script cache.
|
RedisClient |
RedisClient.sdiff(String key,
List<String> cmpkeys,
Handler<AsyncResult<JsonArray>> handler)
Subtract multiple sets
|
RedisClient |
RedisClient.sdiffstore(String destkey,
String key,
List<String> cmpkeys,
Handler<AsyncResult<Long>> handler)
Subtract multiple sets and store the resulting set in a key
|
RedisClient |
RedisClient.select(int dbindex,
Handler<AsyncResult<String>> handler)
Change the selected database for the current connection
|
RedisClient |
RedisClient.set(String key,
String value,
Handler<AsyncResult<Void>> handler)
Set the string value of a key
|
RedisClient |
RedisClient.setBinary(String key,
String value,
Handler<AsyncResult<Void>> handler)
Set the binary string value of a key - without encoding as utf-8
|
RedisClient |
RedisClient.setbit(String key,
long offset,
int bit,
Handler<AsyncResult<Long>> handler)
Sets or clears the bit at offset in the string value stored at key
|
RedisClient |
RedisClient.setex(String key,
long seconds,
String value,
Handler<AsyncResult<String>> handler)
Set the value and expiration of a key
|
RedisClient |
RedisClient.setnx(String key,
String value,
Handler<AsyncResult<Long>> handler)
Set the value of a key, only if the key does not exist
|
RedisClient |
RedisClient.setrange(String key,
int offset,
String value,
Handler<AsyncResult<Long>> handler)
Overwrite part of a string at key starting at the specified offset
|
RedisClient |
RedisClient.setWithOptions(String key,
String value,
SetOptions options,
Handler<AsyncResult<Void>> handler)
Set the string value of a key
|
RedisClient |
RedisClient.sinter(List<String> keys,
Handler<AsyncResult<JsonArray>> handler)
Intersect multiple sets
|
RedisClient |
RedisClient.sinterstore(String destkey,
List<String> keys,
Handler<AsyncResult<Long>> handler)
Intersect multiple sets and store the resulting set in a key
|
RedisClient |
RedisClient.sismember(String key,
String member,
Handler<AsyncResult<Long>> handler)
Determine if a given value is a member of a set
|
RedisClient |
RedisClient.slaveof(String host,
int port,
Handler<AsyncResult<String>> handler)
Make the server a slave of another instance
|
RedisClient |
RedisClient.slaveofNoone(Handler<AsyncResult<String>> handler)
Make this server a master
|
RedisClient |
RedisClient.slowlogGet(int limit,
Handler<AsyncResult<JsonArray>> handler)
Read the Redis slow queries log
|
RedisClient |
RedisClient.slowlogLen(Handler<AsyncResult<Long>> handler)
Get the length of the Redis slow queries log
|
RedisClient |
RedisClient.slowlogReset(Handler<AsyncResult<Void>> handler)
Reset the Redis slow queries log
|
RedisClient |
RedisClient.smembers(String key,
Handler<AsyncResult<JsonArray>> handler)
Get all the members in a set
|
RedisClient |
RedisClient.smove(String key,
String destkey,
String member,
Handler<AsyncResult<Long>> handler)
Move a member from one set to another
|
RedisClient |
RedisClient.sort(String key,
SortOptions options,
Handler<AsyncResult<JsonArray>> handler)
Sort the elements in a list, set or sorted set
|
RedisClient |
RedisClient.spop(String key,
Handler<AsyncResult<String>> handler)
Remove and return a random member from a set
|
RedisClient |
RedisClient.spopMany(String key,
int count,
Handler<AsyncResult<String>> handler)
Remove and return random members from a set
|
RedisClient |
RedisClient.srandmember(String key,
int count,
Handler<AsyncResult<JsonArray>> handler)
Get one or multiple random members from a set
|
RedisClient |
RedisClient.srem(String key,
String member,
Handler<AsyncResult<Long>> handler)
Remove one member from a set
|
RedisClient |
RedisClient.sremMany(String key,
List<String> members,
Handler<AsyncResult<Long>> handler)
Remove one or more members from a set
|
RedisClient |
RedisClient.sscan(String key,
String cursor,
ScanOptions options,
Handler<AsyncResult<Void>> handler)
Incrementally iterate Set elements
|
RedisClient |
RedisClient.strlen(String key,
Handler<AsyncResult<Long>> handler)
Get the length of the value stored in a key
|
RedisClient |
RedisClient.subscribe(List<String> channels,
Handler<AsyncResult<Void>> handler)
Listen for messages published to the given channels
|
RedisClient |
RedisClient.sunion(List<String> keys,
Handler<AsyncResult<JsonArray>> handler)
Add multiple sets
|
RedisClient |
RedisClient.sunionstore(String destkey,
List<String> keys,
Handler<AsyncResult<Long>> handler)
Add multiple sets and store the resulting set in a key
|
RedisClient |
RedisClient.sync(Handler<AsyncResult<Void>> handler)
Internal command used for replication
|
RedisClient |
RedisClient.time(Handler<AsyncResult<JsonArray>> handler)
Return the current server time
|
RedisClient |
RedisClient.ttl(String key,
Handler<AsyncResult<Long>> handler)
Get the time to live for a key
|
RedisClient |
RedisClient.type(String key,
Handler<AsyncResult<String>> handler)
Determine the type stored at key
|
RedisClient |
RedisClient.unsubscribe(List<String> channels,
Handler<AsyncResult<Void>> handler)
Stop listening for messages posted to the given channels
|
RedisClient |
RedisClient.unwatch(Handler<AsyncResult<String>> handler)
Forget about all watched keys
|
RedisClient |
RedisClient.watch(List<String> keys,
Handler<AsyncResult<String>> handler)
Watch the given keys to determine execution of the MULTI/EXEC block
|
RedisClient |
RedisClient.zadd(String key,
double score,
String member,
Handler<AsyncResult<Long>> handler)
Add one or more members to a sorted set, or update its score if it already exists
|
RedisClient |
RedisClient.zaddMany(String key,
Map<String,Double> members,
Handler<AsyncResult<Long>> handler)
Add one or more members to a sorted set, or update its score if it already exists
|
RedisClient |
RedisClient.zcard(String key,
Handler<AsyncResult<Long>> handler)
Get the number of members in a sorted set
|
RedisClient |
RedisClient.zcount(String key,
double min,
double max,
Handler<AsyncResult<Long>> handler)
Count the members in a sorted set with scores within the given values
|
RedisClient |
RedisClient.zincrby(String key,
double increment,
String member,
Handler<AsyncResult<String>> handler)
Increment the score of a member in a sorted set
|
RedisClient |
RedisClient.zinterstore(String destkey,
List<String> sets,
AggregateOptions options,
Handler<AsyncResult<Long>> handler)
Intersect multiple sorted sets and store the resulting sorted set in a new key
|
RedisClient |
RedisClient.zinterstoreWeighed(String destkey,
Map<String,Double> sets,
AggregateOptions options,
Handler<AsyncResult<Long>> handler)
Intersect multiple sorted sets and store the resulting sorted set in a new key using weights for scoring
|
RedisClient |
RedisClient.zlexcount(String key,
String min,
String max,
Handler<AsyncResult<Long>> handler)
Count the number of members in a sorted set between a given lexicographical range
|
RedisClient |
RedisClient.zrange(String key,
long start,
long stop,
Handler<AsyncResult<JsonArray>> handler)
Return a range of members in a sorted set, by index
|
RedisClient |
RedisClient.zrangebylex(String key,
String min,
String max,
LimitOptions options,
Handler<AsyncResult<JsonArray>> handler)
Return a range of members in a sorted set, by lexicographical range
|
RedisClient |
RedisClient.zrangebyscore(String key,
String min,
String max,
RangeLimitOptions options,
Handler<AsyncResult<JsonArray>> handler)
Return a range of members in a sorted set, by score
|
RedisClient |
RedisClient.zrangeWithOptions(String key,
long start,
long stop,
RangeOptions options,
Handler<AsyncResult<JsonArray>> handler)
Return a range of members in a sorted set, by index
|
RedisClient |
RedisClient.zrank(String key,
String member,
Handler<AsyncResult<Long>> handler)
Determine the index of a member in a sorted set
|
RedisClient |
RedisClient.zrem(String key,
String member,
Handler<AsyncResult<Long>> handler)
Remove one member from a sorted set
|
RedisClient |
RedisClient.zremMany(String key,
List<String> members,
Handler<AsyncResult<Long>> handler)
Remove one or more members from a sorted set
|
RedisClient |
RedisClient.zremrangebylex(String key,
String min,
String max,
Handler<AsyncResult<Long>> handler)
Remove all members in a sorted set between the given lexicographical range
|
RedisClient |
RedisClient.zremrangebyrank(String key,
long start,
long stop,
Handler<AsyncResult<Long>> handler)
Remove all members in a sorted set within the given indexes
|
RedisClient |
RedisClient.zremrangebyscore(String key,
String min,
String max,
Handler<AsyncResult<Long>> handler)
Remove all members in a sorted set within the given scores
|
RedisClient |
RedisClient.zrevrange(String key,
long start,
long stop,
RangeOptions options,
Handler<AsyncResult<JsonArray>> handler)
Return a range of members in a sorted set, by index, with scores ordered from high to low
|
RedisClient |
RedisClient.zrevrangebylex(String key,
String max,
String min,
LimitOptions options,
Handler<AsyncResult<JsonArray>> handler)
Return a range of members in a sorted set, by score, between the given lexicographical range with scores ordered from high to low
|
RedisClient |
RedisClient.zrevrangebyscore(String key,
String max,
String min,
RangeLimitOptions options,
Handler<AsyncResult<JsonArray>> handler)
Return a range of members in a sorted set, by score, with scores ordered from high to low
|
RedisClient |
RedisClient.zrevrank(String key,
String member,
Handler<AsyncResult<Long>> handler)
Determine the index of a member in a sorted set, with scores ordered from high to low
|
RedisClient |
RedisClient.zscan(String key,
String cursor,
ScanOptions options,
Handler<AsyncResult<Void>> handler)
Incrementally iterate sorted sets elements and associated scores
|
RedisClient |
RedisClient.zscore(String key,
String member,
Handler<AsyncResult<String>> handler)
Get the score associated with the given member in a sorted set
|
RedisClient |
RedisClient.zunionstore(String destkey,
List<String> sets,
AggregateOptions options,
Handler<AsyncResult<Long>> handler)
Add multiple sorted sets and store the resulting sorted set in a new key
|
RedisClient |
RedisClient.zunionstoreWeighed(String key,
Map<String,Double> sets,
AggregateOptions options,
Handler<AsyncResult<Long>> handler)
Add multiple sorted sets using weights, and store the resulting sorted set in a new key
|
Modifier and Type | Method and Description |
---|---|
<K,V> void |
HazelcastClusterManager.getAsyncMap(String name,
Handler<AsyncResult<AsyncMap<K,V>>> resultHandler) |
<K,V> void |
HazelcastClusterManager.getAsyncMultiMap(String name,
Handler<AsyncResult<AsyncMultiMap<K,V>>> resultHandler)
Every eventbus handler has an ID.
|
void |
HazelcastClusterManager.getCounter(String name,
Handler<AsyncResult<Counter>> resultHandler) |
void |
HazelcastClusterManager.getLockWithTimeout(String name,
long timeout,
Handler<AsyncResult<Lock>> resultHandler) |
void |
HazelcastClusterManager.join(Handler<AsyncResult<Void>> resultHandler) |
void |
HazelcastClusterManager.leave(Handler<AsyncResult<Void>> resultHandler) |
Copyright © 2015. All Rights Reserved.