Interface IgniteDiscoverySpi
-
- All Superinterfaces:
DiscoverySpi,IgniteSpi
- All Known Implementing Classes:
IsolatedDiscoverySpi,TcpDiscoverySpi
public interface IgniteDiscoverySpi extends DiscoverySpi
-
-
Method Summary
All Methods Instance Methods Abstract Methods Modifier and Type Method Description booleanallNodesSupport(IgniteFeatures feature)voidclientReconnect()booleanclientReconnectSupported()booleanknownNode(UUID nodeId)voidresolveCommunicationFailure(ClusterNode node, Exception err)voidsetInternalListener(IgniteDiscoverySpiInternalListener lsnr)For TESTING only.voidsimulateNodeFailure()For TESTING only.booleansupportsCommunicationFailureResolve()-
Methods inherited from interface org.apache.ignite.spi.discovery.DiscoverySpi
consistentId, disconnect, failNode, getGridStartTime, getLocalNode, getNode, getRemoteNodes, isClientMode, pingNode, sendCustomEvent, setAuthenticator, setDataExchange, setListener, setMetricsProvider, setNodeAttributes
-
Methods inherited from interface org.apache.ignite.spi.IgniteSpi
getName, getNodeAttributes, onClientDisconnected, onClientReconnected, onContextDestroyed, onContextInitialized, spiStart, spiStop
-
-
-
-
Method Detail
-
knownNode
boolean knownNode(UUID nodeId)
- Parameters:
nodeId- Node ID.- Returns:
Trueif node joining or already joined topology.
-
clientReconnectSupported
boolean clientReconnectSupported()
- Returns:
Trueif SPI supports client reconnect.
-
clientReconnect
void clientReconnect()
-
allNodesSupport
boolean allNodesSupport(IgniteFeatures feature)
- Parameters:
feature- Feature to check.- Returns:
trueif all nodes support the given feature.
-
simulateNodeFailure
void simulateNodeFailure()
For TESTING only.
-
setInternalListener
void setInternalListener(IgniteDiscoverySpiInternalListener lsnr)
For TESTING only.- Parameters:
lsnr- Listener.
-
supportsCommunicationFailureResolve
boolean supportsCommunicationFailureResolve()
- Returns:
Trueif supports communication error resolve.
-
resolveCommunicationFailure
void resolveCommunicationFailure(ClusterNode node, Exception err)
- Parameters:
node- Problem node.err- Connection error.
-
-