public class ClusterStateManager extends Object
Modifier and Type | Method and Description |
---|---|
void |
commitClusterState(ClusterStateChange stateChange,
Address initiator,
String txnId,
boolean isTransient) |
Version |
getClusterVersion() |
ClusterState |
getState() |
void |
lockClusterState(ClusterStateChange stateChange,
Address initiator,
String txnId,
long leaseTime,
int memberListVersion,
int partitionStateVersion)
Validate cluster state change requested and set a
ClusterStateLock . |
boolean |
rollbackClusterState(String 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, String txnId, long leaseTime, int memberListVersion, int partitionStateVersion)
ClusterStateLock
.stateChange
- initiator
- txnId
- leaseTime
- partitionStateVersion
- public boolean rollbackClusterState(String txnId)
public void commitClusterState(ClusterStateChange stateChange, Address initiator, String txnId, boolean isTransient)
public String stateToString()
Copyright © 2018 Hazelcast, Inc.. All Rights Reserved.