Class ClusterStateUtil


  • public class ClusterStateUtil
    extends Object
    • Constructor Detail

      • ClusterStateUtil

        public ClusterStateUtil()
    • Method Detail

      • waitForAllActiveAndLiveReplicas

        public static boolean waitForAllActiveAndLiveReplicas​(org.apache.solr.common.cloud.ZkStateReader zkStateReader,
                                                              int timeoutInMs)
        Wait to see *all* cores live and active.
        Parameters:
        zkStateReader - to use for ClusterState
        timeoutInMs - how long to wait before giving up
        Returns:
        false if timed out
      • waitForAllActiveAndLiveReplicas

        public static boolean waitForAllActiveAndLiveReplicas​(org.apache.solr.common.cloud.ZkStateReader zkStateReader,
                                                              String collection,
                                                              int timeoutInMs)
        Wait to see *all* cores live and active.
        Parameters:
        zkStateReader - to use for ClusterState
        collection - to look at
        timeoutInMs - how long to wait before giving up
        Returns:
        false if timed out
      • waitToSeeLiveReplica

        public static boolean waitToSeeLiveReplica​(org.apache.solr.common.cloud.ZkStateReader zkStateReader,
                                                   String collection,
                                                   String coreNodeName,
                                                   String baseUrl,
                                                   int timeoutInMs)
        Wait to see an entry in the ClusterState with a specific coreNodeName and baseUrl.
        Parameters:
        zkStateReader - to use for ClusterState
        collection - to look in
        coreNodeName - to wait for
        baseUrl - to wait for
        timeoutInMs - how long to wait before giving up
        Returns:
        false if timed out
      • waitForAllReplicasNotLive

        public static boolean waitForAllReplicasNotLive​(org.apache.solr.common.cloud.ZkStateReader zkStateReader,
                                                        int timeoutInMs)
      • waitForAllReplicasNotLive

        public static boolean waitForAllReplicasNotLive​(org.apache.solr.common.cloud.ZkStateReader zkStateReader,
                                                        String collection,
                                                        int timeoutInMs)
      • getLiveAndActiveReplicaCount

        public static int getLiveAndActiveReplicaCount​(org.apache.solr.common.cloud.ZkStateReader zkStateReader,
                                                       String collection)
      • waitForLiveAndActiveReplicaCount

        public static boolean waitForLiveAndActiveReplicaCount​(org.apache.solr.common.cloud.ZkStateReader zkStateReader,
                                                               String collection,
                                                               int replicaCount,
                                                               int timeoutInMs)