Package org.apache.solr.cloud.overseer
Class ReplicaMutator
- java.lang.Object
-
- org.apache.solr.cloud.overseer.ReplicaMutator
-
public class ReplicaMutator extends Object
-
-
Field Summary
Fields Modifier and Type Field Description protected SolrCloudManagercloudManagerprotected DistribStateManagerstateManagerprotected SolrZkClientzkClient
-
Constructor Summary
Constructors Constructor Description ReplicaMutator(SolrCloudManager cloudManager)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description ZkWriteCommandaddReplicaProperty(ClusterState clusterState, ZkNodeProps message)ZkWriteCommanddeleteReplicaProperty(ClusterState clusterState, ZkNodeProps message)protected ReplicasetLeader(Replica replica)protected ReplicasetProperty(Replica replica, String key, String value)ZkWriteCommandsetState(ClusterState clusterState, ZkNodeProps message)Handles state updatesprotected ReplicasetState(Replica replica, String state)protected ReplicaunsetLeader(Replica replica)protected ReplicaunsetProperty(Replica replica, String key)protected ZkWriteCommandupdateState(ClusterState prevState, ZkNodeProps message)
-
-
-
Field Detail
-
cloudManager
protected final SolrCloudManager cloudManager
-
stateManager
protected final DistribStateManager stateManager
-
zkClient
protected SolrZkClient zkClient
-
-
Constructor Detail
-
ReplicaMutator
public ReplicaMutator(SolrCloudManager cloudManager)
-
-
Method Detail
-
addReplicaProperty
public ZkWriteCommand addReplicaProperty(ClusterState clusterState, ZkNodeProps message)
-
deleteReplicaProperty
public ZkWriteCommand deleteReplicaProperty(ClusterState clusterState, ZkNodeProps message)
-
setState
public ZkWriteCommand setState(ClusterState clusterState, ZkNodeProps message)
Handles state updates
-
updateState
protected ZkWriteCommand updateState(ClusterState prevState, ZkNodeProps message)
-
-