org.apache.ignite.internal.processors.cluster

Interface IGridClusterStateProcessor

All Superinterfaces:

GridComponent, GridProcessor

All Known Implementing Classes:

GridClusterStateProcessor

public interface IGridClusterStateProcessor
extends GridProcessor

Nested Class Summary

Nested classes/interfaces inherited from interface org.apache.ignite.internal.GridComponent

GridComponent.DiscoveryDataExchangeType

Method Summary

Modifier and Type	Method and Description
void	cacheProcessorStarted()
IgniteInternalFuture<?>	changeGlobalState(boolean activate, Collection<? extends BaselineNode> baselineNodes, boolean forceChangeBaselineTopology)
DiscoveryDataClusterState	clusterState()
boolean	evictionsAllowed()
void	onBaselineTopologyChanged(BaselineTopology blt, BaselineTopologyHistoryItem prevBltHistItem)
void	onExchangeFinishedOnCoordinator(IgniteInternalFuture exchangeFuture, boolean hasMovingPartitions)
@Nullable IgniteInternalFuture<Boolean>	onLocalJoin(DiscoCache discoCache)
@Nullable ChangeGlobalStateFinishMessage	onNodeLeft(ClusterNode node)
void	onStateChangeError(Map<UUID,Exception> errs, StateChangeRequest req)
void	onStateChangeExchangeDone(StateChangeRequest req)
boolean	onStateChangeMessage(AffinityTopologyVersion topVer, ChangeGlobalStateMessage msg, DiscoCache discoCache)
void	onStateFinishMessage(ChangeGlobalStateFinishMessage msg)
DiscoveryDataClusterState	pendingState(ChangeGlobalStateMessage stateMsg)
boolean	publicApiActiveState(boolean waitForTransition)
IgniteFuture<Boolean>	publicApiActiveStateAsync(boolean waitForTransition)

Methods inherited from interface org.apache.ignite.internal.GridComponent

collectGridNodeData, collectJoiningNodeData, discoveryDataType, onDisconnected, onGridDataReceived, onJoiningNodeDataReceived, onKernalStart, onKernalStop, onReconnected, printMemoryStats, start, stop, validateNode, validateNode

Method Detail

publicApiActiveState

boolean publicApiActiveState(boolean waitForTransition)

Returns:

Cluster state to be used on public API.

publicApiActiveStateAsync

IgniteFuture<Boolean> publicApiActiveStateAsync(boolean waitForTransition)

Returns:

Cluster state to be used on public API.

onLocalJoin

@Nullable
@Nullable IgniteInternalFuture<Boolean> onLocalJoin(DiscoCache discoCache)

Parameters:

discoCache - Discovery data cache.

Returns:

If transition is in progress returns future which is completed when transition finishes.

onNodeLeft

@Nullable
@Nullable ChangeGlobalStateFinishMessage onNodeLeft(ClusterNode node)

Parameters:

node - Failed node.

Returns:

Message if cluster state changed.

onStateFinishMessage

void onStateFinishMessage(ChangeGlobalStateFinishMessage msg)

Parameters:

msg - Message.

onStateChangeMessage

boolean onStateChangeMessage(AffinityTopologyVersion topVer,
                             ChangeGlobalStateMessage msg,
                             DiscoCache discoCache)

Parameters:

topVer - Current topology version.

msg - Message.

discoCache - Current nodes.

Returns:

True if need start state change process.

clusterState

DiscoveryDataClusterState clusterState()

Returns:

Current cluster state, should be called only from discovery thread.

pendingState

DiscoveryDataClusterState pendingState(ChangeGlobalStateMessage stateMsg)

Returns:

Pending cluster state which will be used when state transition is finished.

cacheProcessorStarted

void cacheProcessorStarted()

changeGlobalState

IgniteInternalFuture<?> changeGlobalState(boolean activate,
                                          Collection<? extends BaselineNode> baselineNodes,
                                          boolean forceChangeBaselineTopology)

Parameters:

activate - New cluster state.

Returns:

State change future.

onStateChangeError

void onStateChangeError(Map<UUID,Exception> errs,
                        StateChangeRequest req)

Parameters:

errs - Errors.

req - State change request.

onStateChangeExchangeDone

void onStateChangeExchangeDone(StateChangeRequest req)

Parameters:

req - State change request.

onBaselineTopologyChanged

void onBaselineTopologyChanged(BaselineTopology blt,
                               BaselineTopologyHistoryItem prevBltHistItem)
                        throws IgniteCheckedException

Parameters:

blt - New baseline topology.

prevBltHistItem - Previous baseline history item.

Throws:

IgniteCheckedException

onExchangeFinishedOnCoordinator

void onExchangeFinishedOnCoordinator(IgniteInternalFuture exchangeFuture,
                                     boolean hasMovingPartitions)

Parameters:

exchangeFuture - Exchange future.

hasMovingPartitions - True if there are moving partitions.

evictionsAllowed

boolean evictionsAllowed()

Returns:

True if partition evictions are allowed in current state.