com.xjeffrose.xio.core

Class ZkClient

java.lang.Object

com.xjeffrose.xio.core.ZkClient

All Implemented Interfaces:

ConfigurationProvider

public class ZkClient
extends Object
implements ConfigurationProvider

Constructor Summary

Constructors

Constructor and Description
ZkClient(org.apache.curator.framework.CuratorFramework client)
ZkClient(String serverSet)

Method Summary

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)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

ZkClient

public ZkClient(org.apache.curator.framework.CuratorFramework client)

ZkClient

public ZkClient(String serverSet)

Method Detail

rebuild

public void rebuild()

register

public void register(String NODE_LIST_PATH,
                     InetSocketAddress address,
                     @Nullable
                     byte[] data)

register

public void register(String NODE_LIST_PATH,
                     String ip,
                     int port,
                     @Nullable
                     byte[] data)

register

public void register(String path,
                     InetSocketAddress address)

Specified by:

register in interface ConfigurationProvider

electLeader

public void electLeader(String ELECTION_PATH,
                        org.apache.curator.framework.recipes.leader.LeaderSelectorListener listener)

electLeader

public void electLeader(String path)

Specified by:

electLeader in interface ConfigurationProvider

startNodeCache

public void startNodeCache(org.apache.curator.framework.recipes.cache.NodeCache cache)

start

public void start()

stopNodeCache

public void stopNodeCache(org.apache.curator.framework.recipes.cache.NodeCache cache)

stop

public void stop()
          throws Exception

Throws:

Exception

set

public void set(String path,
                String data)

Specified by:

set in interface ConfigurationProvider

get

public String get(String path)

Specified by:

get in interface ConfigurationProvider

set

public void set(String path,
                String data,
                boolean compress)

get

public String get(String path,
                  boolean compress)

list

public List<String> list(String path)

Specified by:

list in interface ConfigurationProvider

getChildren

public List<String> getChildren(String path)

Specified by:

getChildren in interface ConfigurationProvider

getClient

public org.apache.curator.framework.CuratorFramework getClient()

getConnectionString

public String getConnectionString()

registerUpdater

public void registerUpdater(ConfigurationUpdater updater)

Specified by:

registerUpdater in interface ConfigurationProvider