Class ExchangeDiscoveryEvents
- java.lang.Object
-
- org.apache.ignite.internal.processors.cache.ExchangeDiscoveryEvents
-
public class ExchangeDiscoveryEvents extends Object
Discovery events processed in single exchange (contain multiple events if exchanges for multiple discovery events are merged into single exchange).
-
-
Method Summary
All Methods Static Methods Instance Methods Concrete Methods Modifier and Type Method Description DiscoCachediscoveryCache()Collection<DiscoveryEvent>events()booleanhasServerJoin()booleanhasServerLeft()Collection<ClusterNode>joinedServerNodes()DiscoveryEventlastEvent()Collection<ClusterNode>leftServerNodes()booleannodeJoined(UUID nodeId)voidprocessEvents(GridDhtPartitionsExchangeFuture fut)static booleanserverJoinEvent(DiscoveryEvent evt)static booleanserverLeftEvent(DiscoveryEvent evt)AffinityTopologyVersiontopologyVersion()StringtoString()voidwarnNoAffinityNodes(GridCacheSharedContext<?,?> cctx)
-
-
-
Method Detail
-
processEvents
public void processEvents(GridDhtPartitionsExchangeFuture fut)
- Parameters:
fut- Current exchange future.
-
nodeJoined
public boolean nodeJoined(UUID nodeId)
- Parameters:
nodeId- Node ID.- Returns:
Trueif has join event for give node.
-
events
public Collection<DiscoveryEvent> events()
- Returns:
- All events.
-
serverLeftEvent
public static boolean serverLeftEvent(DiscoveryEvent evt)
- Parameters:
evt- Event.- Returns:
Trueif given event isEventType.EVT_NODE_FAILEDorEventType.EVT_NODE_LEFT.
-
serverJoinEvent
public static boolean serverJoinEvent(DiscoveryEvent evt)
- Parameters:
evt- Event.- Returns:
Trueif given event isEventType.EVT_NODE_JOINED.
-
discoveryCache
public DiscoCache discoveryCache()
- Returns:
- Discovery data cache for last event.
-
lastEvent
public DiscoveryEvent lastEvent()
- Returns:
- Last event.
-
topologyVersion
public AffinityTopologyVersion topologyVersion()
- Returns:
- Last event version.
-
hasServerJoin
public boolean hasServerJoin()
- Returns:
Trueif has event for server join.
-
hasServerLeft
public boolean hasServerLeft()
- Returns:
Trueif has event for server leave.
-
joinedServerNodes
public Collection<ClusterNode> joinedServerNodes()
-
leftServerNodes
public Collection<ClusterNode> leftServerNodes()
-
warnNoAffinityNodes
public void warnNoAffinityNodes(GridCacheSharedContext<?,?> cctx)
- Parameters:
cctx- Context.
-
-