org.apache.ignite.internal.processors.cluster

Class DiscoveryDataClusterState

java.lang.Object

org.apache.ignite.internal.processors.cluster.DiscoveryDataClusterState

All Implemented Interfaces:

Serializable

public class DiscoveryDataClusterState
extends Object
implements Serializable

A pojo-object representing current cluster global state. The state includes cluster active flag and cluster baseline topology.

This object also captures a transitional cluster state, when one or more fields are changing. In this case, a transitionReqId field is set to a non-null value and previousBaselineTopology captures previous cluster state. A joining node catching the cluster in an intermediate state will observe transitionReqId field to be non-null, however the previousBaselineTopology will not be sent to the joining node. TODO https://issues.apache.org/jira/browse/IGNITE-7640 This class must be immutable, transitionRes must be set by calling finish().

See Also:

Serialized Form

Method Summary

Modifier and Type	Method and Description
boolean	active()
boolean	baselineChanged()
BaselineTopology	baselineTopology()
DiscoveryDataClusterState	finish(boolean success) Creates a non-transitional cluster state.
boolean	hasBaselineTopology()
BaselineTopology	previousBaselineTopology()
void	setTransitionResult(UUID reqId, boolean active) Discovery cluster state is changed asynchronously by discovery message, this methods changes local status for public API calls.
String	toString()
boolean	transition()
Exception	transitionError()
void	transitionError(Exception ex)
Set<UUID>	transitionNodes()
UUID	transitionRequestId()
Boolean	transitionResult()
AffinityTopologyVersion	transitionTopologyVersion()

Methods inherited from class java.lang.Object

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

Method Detail

transitionResult

@Nullable
public Boolean transitionResult()

Returns:

Local flag for state transition result (global state is updated asynchronously by custom message).

setTransitionResult

public void setTransitionResult(UUID reqId,
                                boolean active)

Discovery cluster state is changed asynchronously by discovery message, this methods changes local status for public API calls.

Parameters:

reqId - Request ID.

active - New cluster state.

transitionRequestId

public UUID transitionRequestId()

Returns:

State change request ID.

transition

public boolean transition()

Returns:

True if any cluster state change is in progress (e.g. active state change, baseline change).

transitionTopologyVersion

public AffinityTopologyVersion transitionTopologyVersion()

Returns:

State change exchange version.

active

public boolean active()

Returns:

Current cluster state (or new state in case when transition is in progress).

baselineTopology

@Nullable
public BaselineTopology baselineTopology()

Returns:

Baseline topology.

previousBaselineTopology

@Nullable
public BaselineTopology previousBaselineTopology()

Returns:

Previous Baseline topology.

baselineChanged

public boolean baselineChanged()

Returns:

True If baseLine changed, False if not.

hasBaselineTopology

public boolean hasBaselineTopology()

Returns:

True if baseline topology is set in the cluster. False otherwise.

transitionNodes

public Set<UUID> transitionNodes()

Returns:

Nodes participating in state change exchange.

transitionError

@Nullable
public Exception transitionError()

Returns:

Transition error.

transitionError

public void transitionError(Exception ex)

Parameters:

ex - Exception

finish

public DiscoveryDataClusterState finish(boolean success)

Creates a non-transitional cluster state. This method effectively cleans all fields identifying the state as transitional and creates a new state with the state transition result.

Parameters:

success - Transition success status.

Returns:

Cluster state that finished transition.

toString

public String toString()

Overrides:

toString in class Object