public class IgniteClusterManager extends Object implements ClusterManager
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 extCfg)
Creates cluster manager instance with given Ignite configuration.
|
IgniteClusterManager(IgniteOptions extOptions)
Creates cluster manager instance with given IgniteOptions.
|
IgniteClusterManager(JsonObject jsonConfig)
Creates cluster manager instance with given JSON configuration.
|
IgniteClusterManager(URL configFile)
Creates cluster manager instance with given Spring XML configuration file.
|
Modifier and Type | Method and Description |
---|---|
void |
addRegistration(String address,
RegistrationInfo registrationInfo,
Promise<Void> promise)
Share a new messaging handler registration with other nodes in the cluster.
|
<K,V> void |
getAsyncMap(String name,
Promise<AsyncMap<K,V>> promise)
Return an
AsyncMap for the given name . |
void |
getCounter(String name,
Promise<Counter> promise)
Return a
Counter for the given name . |
org.apache.ignite.Ignite |
getIgniteInstance()
Returns instance of
Ignite . |
void |
getLockWithTimeout(String name,
long timeout,
Promise<Lock> promise)
|
String |
getNodeId()
Return the unique node identifier for this node.
|
NodeInfo |
getNodeInfo()
Get details about this clustered node.
|
void |
getNodeInfo(String id,
Promise<NodeInfo> promise)
Get details about a specific node in the cluster.
|
List<String> |
getNodes()
Return a list of node identifiers corresponding to the nodes in the cluster.
|
void |
getRegistrations(String address,
Promise<List<RegistrationInfo>> promise)
Get the messaging handler currently registered in the cluster.
|
<K,V> Map<K,V> |
getSyncMap(String name)
Return a synchronous map for the given
name . |
void |
init(Vertx vertx,
NodeSelector nodeSelector)
Invoked before this cluster node tries to join the cluster.
|
boolean |
isActive()
Is the cluster manager active?
|
void |
join(Promise<Void> promise)
Join the cluster.
|
void |
leave(Promise<Void> promise)
Leave the cluster.
|
void |
nodeListener(NodeListener nodeListener)
Set a listener that will be called when a node joins or leaves the cluster.
|
void |
removeRegistration(String address,
RegistrationInfo registrationInfo,
Promise<Void> promise)
Signal removal of a messaging handler registration to other nodes in the cluster.
|
void |
setNodeInfo(NodeInfo nodeInfo,
Promise<Void> promise)
Store the details about this clustered node.
|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
clusterHost, clusterPublicHost, init
public IgniteClusterManager()
public IgniteClusterManager(org.apache.ignite.configuration.IgniteConfiguration extCfg)
extCfg
- IgniteConfiguration
instance.public IgniteClusterManager(URL configFile)
configFile
- URL
path to Spring XML configuration file.public IgniteClusterManager(JsonObject jsonConfig)
jsonConfig
- JsonObject
JSON configuration.public IgniteClusterManager(IgniteOptions extOptions)
extOptions
- IgniteOptions
options object.public IgniteClusterManager(org.apache.ignite.Ignite ignite)
Ignite
instance.ignite
- Ignite
instance.public org.apache.ignite.Ignite getIgniteInstance()
Ignite
.Ignite
instance.public void init(Vertx vertx, NodeSelector nodeSelector)
ClusterManager
Implementations must signal the provided nodeSelector
when messaging handler registrations are added or removed
by sending a RegistrationUpdateEvent
with NodeSelector.registrationsUpdated(RegistrationUpdateEvent)
.
init
in interface ClusterManager
vertx
- the Vert.x instancenodeSelector
- the NodeSelector
that must receive RegistrationUpdateEvent
.public void nodeListener(NodeListener nodeListener)
ClusterManager
nodeListener
in interface ClusterManager
public <K,V> void getAsyncMap(String name, Promise<AsyncMap<K,V>> promise)
ClusterManager
AsyncMap
for the given name
.getAsyncMap
in interface ClusterManager
public <K,V> Map<K,V> getSyncMap(String name)
ClusterManager
name
.getSyncMap
in interface ClusterManager
public void getLockWithTimeout(String name, long timeout, Promise<Lock> promise)
ClusterManager
getLockWithTimeout
in interface ClusterManager
public void getCounter(String name, Promise<Counter> promise)
ClusterManager
Counter
for the given name
.getCounter
in interface ClusterManager
public String getNodeId()
ClusterManager
getNodeId
in interface ClusterManager
public void setNodeInfo(NodeInfo nodeInfo, Promise<Void> promise)
ClusterManager
setNodeInfo
in interface ClusterManager
public NodeInfo getNodeInfo()
ClusterManager
getNodeInfo
in interface ClusterManager
public void getNodeInfo(String id, Promise<NodeInfo> promise)
ClusterManager
getNodeInfo
in interface ClusterManager
id
- the clustered node idpublic List<String> getNodes()
ClusterManager
getNodes
in interface ClusterManager
public void join(Promise<Void> promise)
ClusterManager
join
in interface ClusterManager
public void leave(Promise<Void> promise)
ClusterManager
leave
in interface ClusterManager
public boolean isActive()
ClusterManager
isActive
in interface ClusterManager
public void addRegistration(String address, RegistrationInfo registrationInfo, Promise<Void> promise)
ClusterManager
addRegistration
in interface ClusterManager
public void removeRegistration(String address, RegistrationInfo registrationInfo, Promise<Void> promise)
ClusterManager
removeRegistration
in interface ClusterManager
public void getRegistrations(String address, Promise<List<RegistrationInfo>> promise)
ClusterManager
getRegistrations
in interface ClusterManager
Copyright © 2023 Eclipse. All rights reserved.