Package org.apache.storm.utils
Class CuratorUtils
java.lang.Object
org.apache.storm.utils.CuratorUtils
-
Field Summary
-
Constructor Summary
-
Method Summary
Modifier and TypeMethodDescriptionstatic 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) 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) 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) 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) 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) protected static void
setupBuilder
(org.apache.storm.shade.org.apache.curator.framework.CuratorFrameworkFactory.Builder builder, String zkStr, Map<String, Object> conf, ZookeeperAuthInfo auth) static void
testSetupBuilder
(org.apache.storm.shade.org.apache.curator.framework.CuratorFrameworkFactory.Builder builder, String zkStr, Map<String, Object> conf, ZookeeperAuthInfo auth)
-
Field Details
-
LOG
public static final org.slf4j.Logger LOG
-
-
Constructor Details
-
CuratorUtils
public CuratorUtils()
-
-
Method Details
-
newCurator
-
newCurator
-
newCurator
-
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
-
newCuratorStarted
-