public class ClusterStateManager extends Object
When a node joins to the cluster, its initial state is set.
When a cluster state change is requested, a cluster-wide transaction is started and state is changed all over the cluster atomically.
Modifier and Type | Method and Description |
---|---|
void |
commitClusterState(ClusterStateChange stateChange,
Address initiator,
UUID txnId,
boolean isTransient) |
Version |
getClusterVersion() |
ClusterState |
getState() |
void |
lockClusterState(ClusterStateChange stateChange,
Address initiator,
UUID txnId,
long leaseTime,
int memberListVersion,
int partitionStateVersion)
Validates the requested cluster state change and sets a
ClusterStateLock . |
boolean |
rollbackClusterState(UUID txnId) |
void |
setClusterVersion(Version newVersion) |
String |
stateToString() |
String |
toString() |
public ClusterState getState()
public Version getClusterVersion()
public void setClusterVersion(Version newVersion)
public void lockClusterState(ClusterStateChange stateChange, Address initiator, UUID txnId, long leaseTime, int memberListVersion, int partitionStateVersion)
ClusterStateLock
.public boolean rollbackClusterState(UUID txnId)
public void commitClusterState(ClusterStateChange stateChange, Address initiator, UUID txnId, boolean isTransient)
public String stateToString()
Copyright © 2019 Hazelcast, Inc.. All rights reserved.