com.baidu.disconf.core.common.zookeeper.inner

Class ResilientActiveKeyValueStore

java.lang.Object

com.baidu.disconf.core.common.zookeeper.inner.ConnectionWatcher

com.baidu.disconf.core.common.zookeeper.inner.ResilientActiveKeyValueStore

All Implemented Interfaces:

org.apache.zookeeper.Watcher

public class ResilientActiveKeyValueStore
extends ConnectionWatcher

ZK读写

Version:

2014-7-7

Author:

liaoqiqi

Nested Class Summary

Nested classes/interfaces inherited from interface org.apache.zookeeper.Watcher

org.apache.zookeeper.Watcher.Event

Field Summary

Fields

Modifier and Type	Field and Description
protected static org.slf4j.Logger	LOGGER
static int	MAX_RETRIES
static int	RETRY_PERIOD_SECONDS

Fields inherited from class com.baidu.disconf.core.common.zookeeper.inner.ConnectionWatcher

zk

Constructor Summary

Constructors

Constructor and Description
ResilientActiveKeyValueStore(boolean debug)

Method Summary

Methods

Modifier and Type	Method and Description
String	createEphemeralNode(String path, String value, org.apache.zookeeper.CreateMode createMode)
void	deleteNode(String path)
boolean	exists(String path) 判断是否存在
List<String>	getRootChildren()
String	read(String path, org.apache.zookeeper.Watcher watcher, org.apache.zookeeper.data.Stat stat)
void	write(String path, String value)

Methods inherited from class com.baidu.disconf.core.common.zookeeper.inner.ConnectionWatcher

close, connect, getZk, process, reconnect, setZk

Methods inherited from class java.lang.Object

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

Field Detail

LOGGER

protected static final org.slf4j.Logger LOGGER

MAX_RETRIES

public static final int MAX_RETRIES

See Also:

Constant Field Values

RETRY_PERIOD_SECONDS

public static final int RETRY_PERIOD_SECONDS

See Also:

Constant Field Values

Constructor Detail

ResilientActiveKeyValueStore

public ResilientActiveKeyValueStore(boolean debug)

Parameters:

debug -

Method Detail

write

public void write(String path,
         String value)
           throws InterruptedException,
                  org.apache.zookeeper.KeeperException

Parameters:

path -

value -

Throws:

InterruptedException

org.apache.zookeeper.KeeperException

createEphemeralNode

public String createEphemeralNode(String path,
                         String value,
                         org.apache.zookeeper.CreateMode createMode)
                           throws InterruptedException,
                                  org.apache.zookeeper.KeeperException

Parameters:

path -

value -

Returns:

void

Throws:

InterruptedException

org.apache.zookeeper.KeeperException

exists

public boolean exists(String path)
               throws InterruptedException,
                      org.apache.zookeeper.KeeperException

判断是否存在

Parameters:

path -

Returns:

Throws:

InterruptedException

org.apache.zookeeper.KeeperException

read

public String read(String path,
          org.apache.zookeeper.Watcher watcher,
          org.apache.zookeeper.data.Stat stat)
            throws InterruptedException,
                   org.apache.zookeeper.KeeperException

Parameters:

path -

watcher -

Returns:

String

Throws:

InterruptedException

org.apache.zookeeper.KeeperException

getRootChildren

public List<String> getRootChildren()

Returns:

List

deleteNode

public void deleteNode(String path)

Parameters:

path -