Package org.gridgain.ignite.migrationtools.adapter.internal.ignite2.proxies

Class IgniteClusterDelegate

java.lang.Object

org.gridgain.ignite.migrationtools.adapter.internal.ignite2.proxies.ClusterGroupDelegate

org.gridgain.ignite.migrationtools.adapter.internal.ignite2.proxies.IgniteClusterDelegate

All Implemented Interfaces:

org.apache.ignite.cluster.ClusterGroup, org.apache.ignite.IgniteCluster, org.apache.ignite.lang.IgniteAsyncSupport

public class IgniteClusterDelegate
extends ClusterGroupDelegate
implements org.apache.ignite.IgniteCluster

Static delegate that exposes an IgniteClusterProxy as IgniteCluster. Extends ClusterGroupDelegate to reuse the ClusterGroup method implementations.

Field Summary

Fields inherited from interface org.apache.ignite.IgniteCluster

MAX_TAG_LENGTH

Method Summary

Modifier and Type	Method	Description
boolean	active()
void	active(boolean active)
void	baselineAutoAdjustEnabled(boolean enabled)
org.apache.ignite.internal.processors.cluster.baseline.autoadjust.BaselineAutoAdjustStatus	baselineAutoAdjustStatus()
long	baselineAutoAdjustTimeout()
void	baselineAutoAdjustTimeout(long timeout)
void	checkpoint()
void	clearStatistics(Collection<String> caches)
org.apache.ignite.lang.IgniteFuture<?>	clientReconnectFuture()
Collection<org.apache.ignite.cluster.BaselineNode>	currentBaselineTopology()
boolean	disableWal(String cacheName)
void	enableStatistics(Collection<String> caches, boolean enabled)
boolean	enableWal(String cacheName)
org.apache.ignite.cluster.ClusterGroup	forLocal()
<R> org.apache.ignite.lang.IgniteFuture<R>	future()
UUID	id()
void	id(UUID id)
boolean	isAsync()
boolean	isBaselineAutoAdjustEnabled()
boolean	isWalEnabled(String cacheName)
org.apache.ignite.cluster.ClusterNode	localNode()
<K, V> ConcurrentMap<K,V>	nodeLocalMap()
boolean	pingNode(UUID nodeId)
void	resetMetrics()
void	restartNodes()
void	restartNodes(Collection<UUID> ids)
void	setBaselineTopology(long topVer)
void	setBaselineTopology(Collection<? extends org.apache.ignite.cluster.BaselineNode> baselineTop)
void	setTxTimeoutOnPartitionMapExchange(long timeout)
org.apache.ignite.ShutdownPolicy	shutdownPolicy()
void	shutdownPolicy(org.apache.ignite.ShutdownPolicy policy)
Collection<org.apache.ignite.cluster.ClusterStartNodeResult>	startNodes(File file, boolean restart, int timeout, int maxConn)
Collection<org.apache.ignite.cluster.ClusterStartNodeResult>	startNodes(Collection<Map<String,Object>> hosts, Map<String,Object> dflts, boolean restart, int timeout, int maxConn)
org.apache.ignite.lang.IgniteFuture<Collection<org.apache.ignite.cluster.ClusterStartNodeResult>>	startNodesAsync(File file, boolean restart, int timeout, int maxConn)
org.apache.ignite.lang.IgniteFuture<Collection<org.apache.ignite.cluster.ClusterStartNodeResult>>	startNodesAsync(Collection<Map<String,Object>> hosts, Map<String,Object> dflts, boolean restart, int timeout, int maxConn)
org.apache.ignite.cluster.ClusterState	state()
void	state(org.apache.ignite.cluster.ClusterState state)
void	stopNodes()
void	stopNodes(Collection<UUID> ids)
String	tag()
void	tag(String tag)
Collection<org.apache.ignite.cluster.ClusterNode>	topology(long topVer)
long	topologyVersion()
org.apache.ignite.IgniteCluster	withAsync()

Methods inherited from class org.gridgain.ignite.migrationtools.adapter.internal.ignite2.proxies.ClusterGroupDelegate

forAttribute, forCacheNodes, forClientNodes, forClients, forDaemons, forDataNodes, forHost, forHost, forNode, forNodeId, forNodeIds, forNodes, forOldest, forOthers, forOthers, forPredicate, forRandom, forRemotes, forServers, forYoungest, hostNames, ignite, metrics, node, node, nodes, predicate

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface org.apache.ignite.cluster.ClusterGroup

forAttribute, forCacheNodes, forClientNodes, forClients, forDaemons, forDataNodes, forHost, forHost, forNode, forNodeId, forNodeIds, forNodes, forOldest, forOthers, forOthers, forPredicate, forRandom, forRemotes, forServers, forYoungest, hostNames, ignite, metrics, node, node, nodes, predicate

Method Details

localNode

public org.apache.ignite.cluster.ClusterNode localNode()

Specified by:

localNode in interface org.apache.ignite.IgniteCluster

forLocal

public org.apache.ignite.cluster.ClusterGroup forLocal()

Specified by:

forLocal in interface org.apache.ignite.IgniteCluster

nodeLocalMap

public <K,
V> ConcurrentMap<K,V> nodeLocalMap()

Specified by:

nodeLocalMap in interface org.apache.ignite.IgniteCluster

pingNode

public boolean pingNode(UUID nodeId)

Specified by:

pingNode in interface org.apache.ignite.IgniteCluster

topologyVersion

public long topologyVersion()

Specified by:

topologyVersion in interface org.apache.ignite.IgniteCluster

topology

public Collection<org.apache.ignite.cluster.ClusterNode> topology(long topVer)
                                                           throws UnsupportedOperationException

Specified by:

topology in interface org.apache.ignite.IgniteCluster

Throws:

UnsupportedOperationException

startNodes

public Collection<org.apache.ignite.cluster.ClusterStartNodeResult> startNodes(File file,
 boolean restart,
 int timeout,
 int maxConn)
                                                                        throws org.apache.ignite.IgniteException

Specified by:

startNodes in interface org.apache.ignite.IgniteCluster

Throws:

org.apache.ignite.IgniteException

startNodes

public Collection<org.apache.ignite.cluster.ClusterStartNodeResult> startNodes(Collection<Map<String,Object>> hosts,
 Map<String,Object> dflts,
 boolean restart,
 int timeout,
 int maxConn)
                                                                        throws org.apache.ignite.IgniteException

Specified by:

startNodes in interface org.apache.ignite.IgniteCluster

Throws:

org.apache.ignite.IgniteException

startNodesAsync

public org.apache.ignite.lang.IgniteFuture<Collection<org.apache.ignite.cluster.ClusterStartNodeResult>> startNodesAsync(File file,
 boolean restart,
 int timeout,
 int maxConn)
                                                                                                                  throws org.apache.ignite.IgniteException

Specified by:

startNodesAsync in interface org.apache.ignite.IgniteCluster

Throws:

org.apache.ignite.IgniteException

startNodesAsync

public org.apache.ignite.lang.IgniteFuture<Collection<org.apache.ignite.cluster.ClusterStartNodeResult>> startNodesAsync(Collection<Map<String,Object>> hosts,
 Map<String,Object> dflts,
 boolean restart,
 int timeout,
 int maxConn)
                                                                                                                  throws org.apache.ignite.IgniteException

Specified by:

startNodesAsync in interface org.apache.ignite.IgniteCluster

Throws:

org.apache.ignite.IgniteException

stopNodes

public void stopNodes()
               throws org.apache.ignite.IgniteException

Specified by:

stopNodes in interface org.apache.ignite.IgniteCluster

Throws:

org.apache.ignite.IgniteException

stopNodes

public void stopNodes(Collection<UUID> ids)
               throws org.apache.ignite.IgniteException

Specified by:

stopNodes in interface org.apache.ignite.IgniteCluster

Throws:

org.apache.ignite.IgniteException

restartNodes

public void restartNodes()
                  throws org.apache.ignite.IgniteException

Specified by:

restartNodes in interface org.apache.ignite.IgniteCluster

Throws:

org.apache.ignite.IgniteException

restartNodes

public void restartNodes(Collection<UUID> ids)
                  throws org.apache.ignite.IgniteException

Specified by:

restartNodes in interface org.apache.ignite.IgniteCluster

Throws:

org.apache.ignite.IgniteException

resetMetrics

public void resetMetrics()

Specified by:

resetMetrics in interface org.apache.ignite.IgniteCluster

enableStatistics

public void enableStatistics(Collection<String> caches,
 boolean enabled)

Specified by:

enableStatistics in interface org.apache.ignite.IgniteCluster

clearStatistics

public void clearStatistics(Collection<String> caches)

Specified by:

clearStatistics in interface org.apache.ignite.IgniteCluster

setTxTimeoutOnPartitionMapExchange

public void setTxTimeoutOnPartitionMapExchange(long timeout)

Specified by:

setTxTimeoutOnPartitionMapExchange in interface org.apache.ignite.IgniteCluster

clientReconnectFuture

public org.apache.ignite.lang.IgniteFuture<?> clientReconnectFuture()

Specified by:

clientReconnectFuture in interface org.apache.ignite.IgniteCluster

active

public boolean active()

Specified by:

active in interface org.apache.ignite.IgniteCluster

active

public void active(boolean active)

Specified by:

active in interface org.apache.ignite.IgniteCluster

state

public org.apache.ignite.cluster.ClusterState state()

Specified by:

state in interface org.apache.ignite.IgniteCluster

state

public void state(org.apache.ignite.cluster.ClusterState state)
           throws org.apache.ignite.IgniteException

Specified by:

state in interface org.apache.ignite.IgniteCluster

Throws:

org.apache.ignite.IgniteException

currentBaselineTopology

public Collection<org.apache.ignite.cluster.BaselineNode> currentBaselineTopology()

Specified by:

currentBaselineTopology in interface org.apache.ignite.IgniteCluster

setBaselineTopology

public void setBaselineTopology(Collection<? extends org.apache.ignite.cluster.BaselineNode> baselineTop)

Specified by:

setBaselineTopology in interface org.apache.ignite.IgniteCluster

setBaselineTopology

public void setBaselineTopology(long topVer)

Specified by:

setBaselineTopology in interface org.apache.ignite.IgniteCluster

withAsync

public org.apache.ignite.IgniteCluster withAsync()

Specified by:

withAsync in interface org.apache.ignite.lang.IgniteAsyncSupport

Specified by:

withAsync in interface org.apache.ignite.IgniteCluster

isAsync

public boolean isAsync()

Specified by:

isAsync in interface org.apache.ignite.lang.IgniteAsyncSupport

future

public <R> org.apache.ignite.lang.IgniteFuture<R> future()

Specified by:

future in interface org.apache.ignite.lang.IgniteAsyncSupport

disableWal

public boolean disableWal(String cacheName)
                   throws org.apache.ignite.IgniteException

Specified by:

disableWal in interface org.apache.ignite.IgniteCluster

Throws:

org.apache.ignite.IgniteException

enableWal

public boolean enableWal(String cacheName)
                  throws org.apache.ignite.IgniteException

Specified by:

enableWal in interface org.apache.ignite.IgniteCluster

Throws:

org.apache.ignite.IgniteException

isWalEnabled

public boolean isWalEnabled(String cacheName)

Specified by:

isWalEnabled in interface org.apache.ignite.IgniteCluster

checkpoint

public void checkpoint()
                throws org.apache.ignite.IgniteException

Specified by:

checkpoint in interface org.apache.ignite.IgniteCluster

Throws:

org.apache.ignite.IgniteException

id

public UUID id()

Specified by:

id in interface org.apache.ignite.IgniteCluster

id

public void id(UUID id)

Specified by:

id in interface org.apache.ignite.IgniteCluster

tag

public String tag()

Specified by:

tag in interface org.apache.ignite.IgniteCluster

tag

public void tag(String tag)
         throws org.apache.ignite.IgniteCheckedException

Specified by:

tag in interface org.apache.ignite.IgniteCluster

Throws:

org.apache.ignite.IgniteCheckedException

isBaselineAutoAdjustEnabled

public boolean isBaselineAutoAdjustEnabled()

Specified by:

isBaselineAutoAdjustEnabled in interface org.apache.ignite.IgniteCluster

baselineAutoAdjustEnabled

public void baselineAutoAdjustEnabled(boolean enabled)
                               throws org.apache.ignite.IgniteException

Specified by:

baselineAutoAdjustEnabled in interface org.apache.ignite.IgniteCluster

Throws:

org.apache.ignite.IgniteException

baselineAutoAdjustTimeout

public long baselineAutoAdjustTimeout()

Specified by:

baselineAutoAdjustTimeout in interface org.apache.ignite.IgniteCluster

baselineAutoAdjustTimeout

public void baselineAutoAdjustTimeout(long timeout)
                               throws org.apache.ignite.IgniteException

Specified by:

baselineAutoAdjustTimeout in interface org.apache.ignite.IgniteCluster

Throws:

org.apache.ignite.IgniteException

baselineAutoAdjustStatus

public org.apache.ignite.internal.processors.cluster.baseline.autoadjust.BaselineAutoAdjustStatus baselineAutoAdjustStatus()

Specified by:

baselineAutoAdjustStatus in interface org.apache.ignite.IgniteCluster

shutdownPolicy

public org.apache.ignite.ShutdownPolicy shutdownPolicy()

Specified by:

shutdownPolicy in interface org.apache.ignite.IgniteCluster

shutdownPolicy

public void shutdownPolicy(org.apache.ignite.ShutdownPolicy policy)

Specified by:

shutdownPolicy in interface org.apache.ignite.IgniteCluster