Class NodeMutator

  • public class NodeMutator
    extends Object
    • Field Detail

      • zkClient

        protected zkClient
    • Constructor Detail

      • NodeMutator

        public NodeMutator​( cloudManager)
    • Method Detail

      • downNode

        public List<ZkWriteCommand> downNode​( clusterState,
      • computeCollectionUpdate

        public static Optional<ZkWriteCommand> computeCollectionUpdate​(String nodeName,
                                                                       String collectionName,
        Returns the write command needed to update the replicas of a given collection given the identity of a node being down.
        An optional with the write command or an empty one if the collection does not need any state modification. The returned write command might be for per replica state updates or for an update to state.json, depending on the configuration of the collection.