org.trafodion.dcs.zookeeper

Class ZkClient

java.lang.Object

org.trafodion.dcs.zookeeper.ZkClient

All Implemented Interfaces:

org.apache.zookeeper.Watcher

public class ZkClient
extends Object
implements org.apache.zookeeper.Watcher

Nested Class Summary

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

org.apache.zookeeper.Watcher.Event

Constructor Summary

Constructors

Constructor and Description
ZkClient()
ZkClient(int sessionTimeout, int maxRetries, int retryIntervalMillis)
ZkClient(String zkhost, int zkport)

Method Summary

Methods

Modifier and Type	Method and Description
void	close()
void	connect()
String	create(String path, byte[] data, List<org.apache.zookeeper.data.ACL> acl, org.apache.zookeeper.CreateMode createMode) NONSEQUENTIAL create is idempotent operation.
void	create(String path, String value, boolean ephemeral)
void	delete(String path, int version) delete is an idempotent operation.
org.apache.zookeeper.data.Stat	exists(String path, boolean watch) exists is an idempotent operation.
org.apache.zookeeper.data.Stat	exists(String path, org.apache.zookeeper.Watcher watcher) exists is an idempotent operation.
String	get(String path, org.apache.zookeeper.Watcher watcher)
List<String>	getChildren(String path, org.apache.zookeeper.Watcher watcher) getChildren is an idempotent operation.
byte[]	getData(String path, boolean watch, org.apache.zookeeper.data.Stat stat) getData is an idemnpotent operation.
byte[]	getData(String path, org.apache.zookeeper.Watcher watcher, org.apache.zookeeper.data.Stat stat) getData is an idempotent operation.
long	getSessionId()
byte[]	getSessionPasswd()
org.apache.zookeeper.ZooKeeper.States	getState()
org.apache.zookeeper.ZooKeeper	getZk()
String	getZkQuorum()
org.apache.zookeeper.ZooKeeper	getZooKeeper()
static void	main(String[] args)
List<org.apache.zookeeper.OpResult>	multi(Iterable<org.apache.zookeeper.Op> ops) Run multiple operations in a transactional manner.
void	process(org.apache.zookeeper.WatchedEvent event)
byte[]	removeMetaData(byte[] data)
void	resetZk()
org.apache.zookeeper.data.Stat	setData(String path, byte[] data, int version) setData is NOT an idempotent operation.
void	sync(String path, org.apache.zookeeper.AsyncCallback.VoidCallback cb, Object ctx)

Methods inherited from class java.lang.Object

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

Constructor Detail

ZkClient

public ZkClient()

ZkClient

public ZkClient(int sessionTimeout,
        int maxRetries,
        int retryIntervalMillis)

ZkClient

public ZkClient(String zkhost,
        int zkport)

Method Detail

getZkQuorum

public String getZkQuorum()

connect

public void connect()
             throws IOException,
                    InterruptedException

Throws:

IOException

InterruptedException

resetZk

public void resetZk()
             throws IOException,
                    InterruptedException

Throws:

IOException

InterruptedException

close

public void close()
           throws InterruptedException

Throws:

InterruptedException

getZk

public org.apache.zookeeper.ZooKeeper getZk()

process

public void process(org.apache.zookeeper.WatchedEvent event)

Specified by:

process in interface org.apache.zookeeper.Watcher

create

public void create(String path,
          String value,
          boolean ephemeral)
            throws org.apache.zookeeper.KeeperException,
                   InterruptedException

Throws:

org.apache.zookeeper.KeeperException

InterruptedException

get

public String get(String path,
         org.apache.zookeeper.Watcher watcher)
           throws org.apache.zookeeper.KeeperException,
                  InterruptedException

Throws:

org.apache.zookeeper.KeeperException

InterruptedException

delete

public void delete(String path,
          int version)
            throws InterruptedException,
                   org.apache.zookeeper.KeeperException

delete is an idempotent operation. Retry before throwing exception. This function will not throw NoNodeException if the path does not exist.

Throws:

InterruptedException

org.apache.zookeeper.KeeperException

exists

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

exists is an idempotent operation. Retry before throwing exception

Returns:

A Stat instance

Throws:

org.apache.zookeeper.KeeperException

InterruptedException

exists

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

exists is an idempotent operation. Retry before throwing exception

Returns:

A Stat instance

Throws:

org.apache.zookeeper.KeeperException

InterruptedException

getChildren

public List<String> getChildren(String path,
                       org.apache.zookeeper.Watcher watcher)
                         throws org.apache.zookeeper.KeeperException,
                                InterruptedException

getChildren is an idempotent operation. Retry before throwing exception

Returns:

List of children znodes

Throws:

org.apache.zookeeper.KeeperException

InterruptedException

getData

public byte[] getData(String path,
             org.apache.zookeeper.Watcher watcher,
             org.apache.zookeeper.data.Stat stat)
               throws org.apache.zookeeper.KeeperException,
                      InterruptedException

getData is an idempotent operation. Retry before throwing exception

Returns:

Data

Throws:

org.apache.zookeeper.KeeperException

InterruptedException

getData

public byte[] getData(String path,
             boolean watch,
             org.apache.zookeeper.data.Stat stat)
               throws org.apache.zookeeper.KeeperException,
                      InterruptedException

getData is an idemnpotent operation. Retry before throwing exception

Returns:

Data

Throws:

org.apache.zookeeper.KeeperException

InterruptedException

setData

public org.apache.zookeeper.data.Stat setData(String path,
                                     byte[] data,
                                     int version)
                                       throws org.apache.zookeeper.KeeperException,
                                              InterruptedException

setData is NOT an idempotent operation. Retry may cause BadVersion Exception Adding an identifier field into the data to check whether badversion is caused by the result of previous correctly setData

Returns:

Stat instance

Throws:

org.apache.zookeeper.KeeperException

InterruptedException

create

public String create(String path,
            byte[] data,
            List<org.apache.zookeeper.data.ACL> acl,
            org.apache.zookeeper.CreateMode createMode)
              throws org.apache.zookeeper.KeeperException,
                     InterruptedException

NONSEQUENTIAL create is idempotent operation. Retry before throwing exceptions. But this function will not throw the NodeExist exception back to the application.

But SEQUENTIAL is NOT idempotent operation. It is necessary to add identifier to the path to verify, whether the previous one is successful or not.

Returns:

Path

Throws:

org.apache.zookeeper.KeeperException

InterruptedException

multi

public List<org.apache.zookeeper.OpResult> multi(Iterable<org.apache.zookeeper.Op> ops)
                                          throws org.apache.zookeeper.KeeperException,
                                                 InterruptedException

Run multiple operations in a transactional manner. Retry before throwing exception

Throws:

org.apache.zookeeper.KeeperException

InterruptedException

removeMetaData

public byte[] removeMetaData(byte[] data)

getSessionId

public long getSessionId()

getState

public org.apache.zookeeper.ZooKeeper.States getState()

getZooKeeper

public org.apache.zookeeper.ZooKeeper getZooKeeper()

getSessionPasswd

public byte[] getSessionPasswd()

sync

public void sync(String path,
        org.apache.zookeeper.AsyncCallback.VoidCallback cb,
        Object ctx)

main

public static void main(String[] args)
                 throws Exception

Throws:

Exception