public class ZkClient extends Object implements ConfigurationProvider
Constructor and Description |
---|
ZkClient(org.apache.curator.framework.CuratorFramework client) |
ZkClient(String serverSet) |
Modifier and Type | Method and Description |
---|---|
void |
electLeader(String path) |
void |
electLeader(String ELECTION_PATH,
org.apache.curator.framework.recipes.leader.LeaderSelectorListener listener) |
String |
get(String path) |
String |
get(String path,
boolean compress) |
List<String> |
getChildren(String path) |
org.apache.curator.framework.CuratorFramework |
getClient() |
String |
getConnectionString() |
List<String> |
list(String path) |
void |
rebuild() |
void |
register(String path,
InetSocketAddress address) |
void |
register(String NODE_LIST_PATH,
InetSocketAddress address,
byte[] data) |
void |
register(String NODE_LIST_PATH,
String ip,
int port,
byte[] data) |
void |
registerUpdater(ConfigurationUpdater updater) |
void |
set(String path,
String data) |
void |
set(String path,
String data,
boolean compress) |
void |
start() |
void |
startNodeCache(org.apache.curator.framework.recipes.cache.NodeCache cache) |
void |
stop() |
void |
stopNodeCache(org.apache.curator.framework.recipes.cache.NodeCache cache) |
public ZkClient(org.apache.curator.framework.CuratorFramework client)
public ZkClient(String serverSet)
public void rebuild()
public void register(String NODE_LIST_PATH, InetSocketAddress address, @Nullable byte[] data)
public void register(String path, InetSocketAddress address)
register
in interface ConfigurationProvider
public void electLeader(String ELECTION_PATH, org.apache.curator.framework.recipes.leader.LeaderSelectorListener listener)
public void electLeader(String path)
electLeader
in interface ConfigurationProvider
public void startNodeCache(org.apache.curator.framework.recipes.cache.NodeCache cache)
public void start()
public void stopNodeCache(org.apache.curator.framework.recipes.cache.NodeCache cache)
public void set(String path, String data)
set
in interface ConfigurationProvider
public String get(String path)
get
in interface ConfigurationProvider
public List<String> list(String path)
list
in interface ConfigurationProvider
public List<String> getChildren(String path)
getChildren
in interface ConfigurationProvider
public org.apache.curator.framework.CuratorFramework getClient()
public String getConnectionString()
public void registerUpdater(ConfigurationUpdater updater)
registerUpdater
in interface ConfigurationProvider
Copyright © 2016. All Rights Reserved.