public class ReplicaMutator extends Object
Modifier and Type | Field and Description |
---|---|
protected ZkStateReader |
zkStateReader |
Constructor and Description |
---|
ReplicaMutator(ZkStateReader reader) |
Modifier and Type | Method and Description |
---|---|
ZkWriteCommand |
addReplicaProperty(ClusterState clusterState,
ZkNodeProps message) |
ZkWriteCommand |
deleteReplicaProperty(ClusterState clusterState,
ZkNodeProps message) |
protected Replica |
setLeader(Replica replica) |
protected Replica |
setProperty(Replica replica,
String key,
String value) |
ZkWriteCommand |
setState(ClusterState clusterState,
ZkNodeProps message) |
protected Replica |
setState(Replica replica,
String state) |
protected Replica |
unsetLeader(Replica replica) |
protected Replica |
unsetProperty(Replica replica,
String key) |
protected ZkWriteCommand |
updateState(ClusterState prevState,
ZkNodeProps message) |
protected ZkWriteCommand |
updateStateNew(ClusterState clusterState,
ZkNodeProps message)
Handles non-legacy state updates
|
protected final ZkStateReader zkStateReader
public ReplicaMutator(ZkStateReader reader)
public ZkWriteCommand addReplicaProperty(ClusterState clusterState, ZkNodeProps message)
public ZkWriteCommand deleteReplicaProperty(ClusterState clusterState, ZkNodeProps message)
public ZkWriteCommand setState(ClusterState clusterState, ZkNodeProps message)
protected ZkWriteCommand updateState(ClusterState prevState, ZkNodeProps message)
protected ZkWriteCommand updateStateNew(ClusterState clusterState, ZkNodeProps message)
Copyright © 2000-2017 Apache Software Foundation. All Rights Reserved.