Package org.apache.storm.utils
Class CuratorUtils
java.lang.Object
org.apache.storm.utils.CuratorUtils
- 
Field SummaryFields
- 
Constructor SummaryConstructors
- 
Method SummaryModifier and TypeMethodDescriptionstatic org.apache.storm.utils.CuratorUtils.SslConfgetSslConf(Map<String, Object> conf) static org.apache.storm.shade.org.apache.curator.framework.CuratorFrameworknewCurator(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.CuratorFrameworknewCurator(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.CuratorFrameworknewCurator(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.CuratorFrameworknewCuratorStarted(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.CuratorFrameworknewCuratorStarted(Map<String, Object> conf, List<String> servers, Object port, ZookeeperAuthInfo auth, List<org.apache.storm.shade.org.apache.zookeeper.data.ACL> defaultAcl) protected static voidsetupBuilder(org.apache.storm.shade.org.apache.curator.framework.CuratorFrameworkFactory.Builder builder, String zkStr, Map<String, Object> conf, ZookeeperAuthInfo auth) static voidtestSetupBuilder(org.apache.storm.shade.org.apache.curator.framework.CuratorFrameworkFactory.Builder builder, String zkStr, Map<String, Object> conf, ZookeeperAuthInfo auth) 
- 
Field Details- 
LOGpublic static final org.slf4j.Logger LOG
- 
CLIENT_CNXN
 
- 
- 
Constructor Details- 
CuratorUtilspublic CuratorUtils()
 
- 
- 
Method Details- 
newCurator
- 
newCurator
- 
newCurator
- 
setupBuilderprotected static void setupBuilder(org.apache.storm.shade.org.apache.curator.framework.CuratorFrameworkFactory.Builder builder, String zkStr, Map<String, Object> conf, ZookeeperAuthInfo auth) 
- 
getSslConf
- 
testSetupBuilderpublic static void testSetupBuilder(org.apache.storm.shade.org.apache.curator.framework.CuratorFrameworkFactory.Builder builder, String zkStr, Map<String, Object> conf, ZookeeperAuthInfo auth) 
- 
newCuratorStarted
- 
newCuratorStarted
 
-