Class CuratorUtils

java.lang.Object
org.apache.storm.utils.CuratorUtils

public class CuratorUtils extends Object
  • Field Details

    • LOG

      public static final org.slf4j.Logger LOG
  • Constructor Details

    • CuratorUtils

      public CuratorUtils()
  • Method Details

    • newCurator

      public static org.apache.storm.shade.org.apache.curator.framework.CuratorFramework newCurator(Map<String,Object> conf, List<String> servers, Object port, String root, List<org.apache.storm.shade.org.apache.zookeeper.data.ACL> defaultAcl)
    • newCurator

      public static org.apache.storm.shade.org.apache.curator.framework.CuratorFramework newCurator(Map<String,Object> conf, List<String> servers, Object port, ZookeeperAuthInfo auth, List<org.apache.storm.shade.org.apache.zookeeper.data.ACL> defaultAcl)
    • newCurator

      public static org.apache.storm.shade.org.apache.curator.framework.CuratorFramework newCurator(Map<String,Object> conf, List<String> servers, Object port, String root, ZookeeperAuthInfo auth, List<org.apache.storm.shade.org.apache.zookeeper.data.ACL> defaultAcl)
    • setupBuilder

      protected static void setupBuilder(org.apache.storm.shade.org.apache.curator.framework.CuratorFrameworkFactory.Builder builder, String zkStr, Map<String,Object> conf, ZookeeperAuthInfo auth)
    • testSetupBuilder

      public static void testSetupBuilder(org.apache.storm.shade.org.apache.curator.framework.CuratorFrameworkFactory.Builder builder, String zkStr, Map<String,Object> conf, ZookeeperAuthInfo auth)
    • newCuratorStarted

      public static org.apache.storm.shade.org.apache.curator.framework.CuratorFramework newCuratorStarted(Map<String,Object> conf, List<String> servers, Object port, String root, ZookeeperAuthInfo auth, List<org.apache.storm.shade.org.apache.zookeeper.data.ACL> defaultAcl)
    • newCuratorStarted

      public static org.apache.storm.shade.org.apache.curator.framework.CuratorFramework newCuratorStarted(Map<String,Object> conf, List<String> servers, Object port, ZookeeperAuthInfo auth, List<org.apache.storm.shade.org.apache.zookeeper.data.ACL> defaultAcl)