public class IgniteClusterManager extends Object implements ClusterManager
| Modifier and Type | Field and Description |
|---|---|
static String |
VERTX_CACHE_TEMPLATE_NAME |
| Constructor and Description |
|---|
IgniteClusterManager()
Default constructor.
|
IgniteClusterManager(org.apache.ignite.Ignite ignite)
Creates cluster manager instance with given
Ignite instance. |
IgniteClusterManager(org.apache.ignite.configuration.IgniteConfiguration cfg)
Creates cluster manager instance with given Ignite configuration.
|
IgniteClusterManager(URL configFile)
Creates cluster manager instance with given Spring XML configuration file.
|
| Modifier and Type | Method and Description |
|---|---|
<K,V> void |
getAsyncMap(String name,
Handler<AsyncResult<AsyncMap<K,V>>> handler)
Return an async map for the given name
|
<K,V> void |
getAsyncMultiMap(String name,
Handler<AsyncResult<AsyncMultiMap<K,V>>> handler)
Return an async multi-map for the given name
|
void |
getCounter(String name,
Handler<AsyncResult<Counter>> handler) |
org.apache.ignite.Ignite |
getIgniteInstance()
Returns instance of
Ignite. |
void |
getLockWithTimeout(String name,
long timeout,
Handler<AsyncResult<Lock>> handler) |
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>> handler)
Join the cluster
|
void |
leave(Handler<AsyncResult<Void>> handler)
Leave the cluster
|
void |
nodeListener(NodeListener nodeListener)
Set a listener that will be called when a node joins or leaves the cluster.
|
void |
setVertx(Vertx vertx) |
public static final String VERTX_CACHE_TEMPLATE_NAME
public IgniteClusterManager()
public IgniteClusterManager(org.apache.ignite.configuration.IgniteConfiguration cfg)
cfg - IgniteConfiguration instance.public IgniteClusterManager(URL configFile)
configFile - URL path to Spring XML configuration file.public IgniteClusterManager(org.apache.ignite.Ignite ignite)
Ignite instance.ignite - Ignite instance.public org.apache.ignite.Ignite getIgniteInstance()
Ignite.Ignite instance.public void setVertx(Vertx vertx)
setVertx in interface ClusterManagerpublic void nodeListener(NodeListener nodeListener)
ClusterManagernodeListener in interface ClusterManagerpublic <K,V> void getAsyncMultiMap(String name, Handler<AsyncResult<AsyncMultiMap<K,V>>> handler)
ClusterManagergetAsyncMultiMap in interface ClusterManagerpublic <K,V> void getAsyncMap(String name, Handler<AsyncResult<AsyncMap<K,V>>> handler)
ClusterManagergetAsyncMap in interface ClusterManagerpublic <K,V> Map<K,V> getSyncMap(String name)
ClusterManagergetSyncMap in interface ClusterManagerpublic void getLockWithTimeout(String name, long timeout, Handler<AsyncResult<Lock>> handler)
getLockWithTimeout in interface ClusterManagerpublic void getCounter(String name, Handler<AsyncResult<Counter>> handler)
getCounter in interface ClusterManagerpublic String getNodeID()
ClusterManagergetNodeID in interface ClusterManagerpublic List<String> getNodes()
ClusterManagergetNodes in interface ClusterManagerpublic void join(Handler<AsyncResult<Void>> handler)
ClusterManagerjoin in interface ClusterManagerpublic void leave(Handler<AsyncResult<Void>> handler)
ClusterManagerleave in interface ClusterManagerpublic boolean isActive()
ClusterManagerisActive in interface ClusterManagerCopyright © 2021 Eclipse. All rights reserved.