public interface ClusterManager
Vertx.executeBlocking(io.vertx.core.Handler<io.vertx.core.Promise<T>>, boolean, io.vertx.core.Handler<io.vertx.core.AsyncResult<T>>)
should be used to run the operation on a worker.Modifier and Type | Method and Description |
---|---|
<K,V> void |
getAsyncMap(String name,
Handler<AsyncResult<AsyncMap<K,V>>> resultHandler)
Return an async map for the given name
|
<K,V> void |
getAsyncMultiMap(String name,
Handler<AsyncResult<AsyncMultiMap<K,V>>> resultHandler)
Return an async multi-map for the given name
|
void |
getCounter(String name,
Handler<AsyncResult<Counter>> resultHandler) |
void |
getLockWithTimeout(String name,
long timeout,
Handler<AsyncResult<Lock>> resultHandler) |
String |
getNodeID()
Return the unique node ID for this node
|
List<String> |
getNodes()
Return a list of node IDs corresponding to the nodes in the cluster
|
<K,V> Map<K,V> |
getSyncMap(String name)
Return a synchronous map for the given name
|
boolean |
isActive()
Is the cluster manager active?
|
void |
join(Handler<AsyncResult<Void>> resultHandler)
Join the cluster
|
void |
leave(Handler<AsyncResult<Void>> resultHandler)
Leave the cluster
|
void |
nodeListener(NodeListener listener)
Set a listener that will be called when a node joins or leaves the cluster.
|
void |
setVertx(Vertx vertx) |
void setVertx(Vertx vertx)
<K,V> void getAsyncMultiMap(String name, Handler<AsyncResult<AsyncMultiMap<K,V>>> resultHandler)
<K,V> void getAsyncMap(String name, Handler<AsyncResult<AsyncMap<K,V>>> resultHandler)
void getLockWithTimeout(String name, long timeout, Handler<AsyncResult<Lock>> resultHandler)
void getCounter(String name, Handler<AsyncResult<Counter>> resultHandler)
String getNodeID()
List<String> getNodes()
void nodeListener(NodeListener listener)
listener
- void join(Handler<AsyncResult<Void>> resultHandler)
void leave(Handler<AsyncResult<Void>> resultHandler)
boolean isActive()
Copyright © 2023 Eclipse. All rights reserved.