A B C D E G H I L N O P R S T U W Z _

A

ALL - Static variable in interface org.I0Itec.zkclient.util.ZkPathUtil.PathFilter
 
awaitUp() - Method in class org.I0Itec.zkclient.GatewayThread
 

B

BytesPushThroughSerializer - Class in org.I0Itec.zkclient.serialize
A ZkSerializer which simply passes byte arrays to zk and back.
BytesPushThroughSerializer() - Constructor for class org.I0Itec.zkclient.serialize.BytesPushThroughSerializer
 

C

close() - Method in class org.I0Itec.zkclient.InMemoryConnection
 
close() - Method in class org.I0Itec.zkclient.ZkClient
Close the client.
close() - Method in class org.I0Itec.zkclient.ZkConnection
 
closeQuietly(Closeable) - Method in class org.I0Itec.zkclient.GatewayThread
 
connect(Watcher) - Method in class org.I0Itec.zkclient.InMemoryConnection
 
connect(long, Watcher) - Method in class org.I0Itec.zkclient.ZkClient
Connect to ZooKeeper.
connect(Watcher) - Method in class org.I0Itec.zkclient.ZkConnection
 
ContentWatcher<T> - Class in org.I0Itec.zkclient
 
ContentWatcher(ZkClient, String) - Constructor for class org.I0Itec.zkclient.ContentWatcher
 
convertToRuntimeException(Exception) - Static method in class org.I0Itec.zkclient.ExceptionUtil
 
countChildren(String) - Method in class org.I0Itec.zkclient.ZkClient
Counts number of children for the given path.
create(KeeperException) - Static method in exception org.I0Itec.zkclient.exception.ZkException
 
create(String, byte[], CreateMode) - Method in class org.I0Itec.zkclient.InMemoryConnection
 
create(String, Object, CreateMode) - Method in class org.I0Itec.zkclient.ZkClient
Create a node.
create(String, byte[], CreateMode) - Method in class org.I0Itec.zkclient.ZkConnection
 
createDefaultNameSpace(ZkClient) - Method in interface org.I0Itec.zkclient.IDefaultNameSpace
Creates a set of default folder structure within a zookeeper .
createEphemeral(String) - Method in class org.I0Itec.zkclient.ZkClient
Create an ephemeral node.
createEphemeral(String, Object) - Method in class org.I0Itec.zkclient.ZkClient
Create an ephemeral node.
createEphemeralSequential(String, Object) - Method in class org.I0Itec.zkclient.ZkClient
Create an ephemeral, sequential node.
createPersistent(String) - Method in class org.I0Itec.zkclient.ZkClient
Create a persistent node.
createPersistent(String, boolean) - Method in class org.I0Itec.zkclient.ZkClient
Create a persistent node.
createPersistent(String, Object) - Method in class org.I0Itec.zkclient.ZkClient
Create a persistent node.
createPersistentSequential(String, Object) - Method in class org.I0Itec.zkclient.ZkClient
Create a persistent, sequental node.

D

DataUpdater<T> - Interface in org.I0Itec.zkclient
Updates the data of a znode.
DEFAULT_PORT - Static variable in class org.I0Itec.zkclient.ZkServer
 
DEFAULT_TICK_TIME - Static variable in class org.I0Itec.zkclient.ZkServer
 
delete(String) - Method in class org.I0Itec.zkclient.InMemoryConnection
 
delete(String) - Method in class org.I0Itec.zkclient.ZkClient
 
delete(String) - Method in class org.I0Itec.zkclient.ZkConnection
 
deleteRecursive(String) - Method in class org.I0Itec.zkclient.ZkClient
 
deserialize(byte[]) - Method in class org.I0Itec.zkclient.serialize.BytesPushThroughSerializer
 
deserialize(byte[]) - Method in class org.I0Itec.zkclient.serialize.SerializableSerializer
 
deserialize(byte[]) - Method in interface org.I0Itec.zkclient.serialize.ZkSerializer
 
DistributedQueue<T extends java.io.Serializable> - Class in org.I0Itec.zkclient
 
DistributedQueue(ZkClient, String) - Constructor for class org.I0Itec.zkclient.DistributedQueue
 

E

ExceptionUtil - Class in org.I0Itec.zkclient
 
ExceptionUtil() - Constructor for class org.I0Itec.zkclient.ExceptionUtil
 
exists(String, boolean) - Method in class org.I0Itec.zkclient.InMemoryConnection
 
exists(String, boolean) - Method in class org.I0Itec.zkclient.ZkClient
 
exists(String) - Method in class org.I0Itec.zkclient.ZkClient
 
exists(String, boolean) - Method in class org.I0Itec.zkclient.ZkConnection
 

G

Gateway - Class in org.I0Itec.zkclient
 
Gateway(int, int) - Constructor for class org.I0Itec.zkclient.Gateway
 
GatewayThread - Class in org.I0Itec.zkclient
 
GatewayThread(int, int) - Constructor for class org.I0Itec.zkclient.GatewayThread
 
get() - Method in class org.I0Itec.zkclient.Holder
 
getChildren(String, boolean) - Method in class org.I0Itec.zkclient.InMemoryConnection
 
getChildren(String) - Method in class org.I0Itec.zkclient.ZkClient
 
getChildren(String, boolean) - Method in class org.I0Itec.zkclient.ZkClient
 
getChildren(String, boolean) - Method in class org.I0Itec.zkclient.ZkConnection
 
getContent() - Method in class org.I0Itec.zkclient.ContentWatcher
 
getCreateTime(String) - Method in class org.I0Itec.zkclient.InMemoryConnection
 
getCreateTime(String) - Method in class org.I0Itec.zkclient.ZkConnection
 
getCreationTime(String) - Method in class org.I0Itec.zkclient.ZkClient
 
getDataChangedCondition() - Method in class org.I0Itec.zkclient.ZkLock
This condition will be signaled if a zookeeper event was processed and the event contains a data/child change.
getDataListener(String) - Method in class org.I0Itec.zkclient.ZkClient
 
getEventLock() - Method in class org.I0Itec.zkclient.ZkClient
Returns a mutex all zookeeper events are synchronized aginst.
getLocalhostName() - Static method in class org.I0Itec.zkclient.NetworkUtil
 
getLocalHostNames() - Static method in class org.I0Itec.zkclient.NetworkUtil
 
getPort() - Method in class org.I0Itec.zkclient.ZkServer
 
getServers() - Method in class org.I0Itec.zkclient.InMemoryConnection
 
getServers() - Method in class org.I0Itec.zkclient.ZkConnection
 
getShutdownTrigger() - Method in class org.I0Itec.zkclient.ZkClient
 
getStateChangedCondition() - Method in class org.I0Itec.zkclient.ZkLock
This condition will be signaled if a zookeeper event was processed and the event contains a state change (connected, disconnected, session expired, etc ...).
getZkClient() - Method in class org.I0Itec.zkclient.ZkServer
 
getZNodeEventCondition() - Method in class org.I0Itec.zkclient.ZkLock
This condition will be signaled if any znode related zookeeper event was received.
getZookeeper() - Method in class org.I0Itec.zkclient.ZkConnection
 
getZookeeperState() - Method in class org.I0Itec.zkclient.InMemoryConnection
 
getZookeeperState() - Method in class org.I0Itec.zkclient.ZkConnection
 

H

handleChildChange(String, List<String>) - Method in interface org.I0Itec.zkclient.IZkChildListener
Called when the children of the given path changed.
handleDataChange(String, Object) - Method in class org.I0Itec.zkclient.ContentWatcher
 
handleDataChange(String, Object) - Method in interface org.I0Itec.zkclient.IZkDataListener
 
handleDataDeleted(String) - Method in class org.I0Itec.zkclient.ContentWatcher
 
handleDataDeleted(String) - Method in interface org.I0Itec.zkclient.IZkDataListener
 
handleNewSession() - Method in interface org.I0Itec.zkclient.IZkStateListener
Called after the zookeeper session has expired and a new session has been created.
handleStateChanged(Watcher.Event.KeeperState) - Method in interface org.I0Itec.zkclient.IZkStateListener
Called when the zookeeper connection state has changed.
Holder<T> - Class in org.I0Itec.zkclient
 
Holder() - Constructor for class org.I0Itec.zkclient.Holder
 
Holder(T) - Constructor for class org.I0Itec.zkclient.Holder
 
hostNameInArray(String[], String) - Static method in class org.I0Itec.zkclient.NetworkUtil
 
hostNamesInList(String, String[]) - Static method in class org.I0Itec.zkclient.NetworkUtil
 

I

IDefaultNameSpace - Interface in org.I0Itec.zkclient
 
InMemoryConnection - Class in org.I0Itec.zkclient
 
InMemoryConnection() - Constructor for class org.I0Itec.zkclient.InMemoryConnection
 
interrupt() - Method in class org.I0Itec.zkclient.GatewayThread
 
interruptAndJoin() - Method in class org.I0Itec.zkclient.GatewayThread
 
isEmpty() - Method in class org.I0Itec.zkclient.DistributedQueue
 
isPortFree(int) - Static method in class org.I0Itec.zkclient.NetworkUtil
 
IZkChildListener - Interface in org.I0Itec.zkclient
An IZkChildListener can be registered at a ZkClient for listening on zk child changes for a given path.
IZkDataListener - Interface in org.I0Itec.zkclient
An IZkDataListener can be registered at a ZkClient for listening on zk data changes for a given path.
IZkStateListener - Interface in org.I0Itec.zkclient
 

L

LOG - Static variable in class org.I0Itec.zkclient.GatewayThread
 

N

NetworkUtil - Class in org.I0Itec.zkclient
 
NetworkUtil() - Constructor for class org.I0Itec.zkclient.NetworkUtil
 
numberOfListeners() - Method in class org.I0Itec.zkclient.ZkClient
 

O

offer(T) - Method in class org.I0Itec.zkclient.DistributedQueue
 
org.I0Itec.zkclient - package org.I0Itec.zkclient
 
org.I0Itec.zkclient.exception - package org.I0Itec.zkclient.exception
 
org.I0Itec.zkclient.serialize - package org.I0Itec.zkclient.serialize
 
org.I0Itec.zkclient.util - package org.I0Itec.zkclient.util
 
OVERWRITE_HOSTNAME_SYSTEM_PROPERTY - Static variable in class org.I0Itec.zkclient.NetworkUtil
 

P

peek() - Method in class org.I0Itec.zkclient.DistributedQueue
 
poll() - Method in class org.I0Itec.zkclient.DistributedQueue
 
process(WatchedEvent) - Method in class org.I0Itec.zkclient.ZkClient
 

R

readData(String, Stat, boolean) - Method in class org.I0Itec.zkclient.InMemoryConnection
 
readData(String) - Method in class org.I0Itec.zkclient.ZkClient
 
readData(String, boolean) - Method in class org.I0Itec.zkclient.ZkClient
 
readData(String, Stat) - Method in class org.I0Itec.zkclient.ZkClient
 
readData(String, Stat, boolean) - Method in class org.I0Itec.zkclient.ZkClient
 
readData(String, Stat, boolean) - Method in class org.I0Itec.zkclient.ZkConnection
 
retainInterruptFlag(Throwable) - Static method in class org.I0Itec.zkclient.ExceptionUtil
This sets the interrupt flag if the catched exception was an InterruptedException.
rethrowInterruptedException(Exception) - Static method in class org.I0Itec.zkclient.ExceptionUtil
 
retryUntilConnected(Callable<T>) - Method in class org.I0Itec.zkclient.ZkClient
 
run() - Method in class org.I0Itec.zkclient.GatewayThread
 

S

SerializableSerializer - Class in org.I0Itec.zkclient.serialize
 
SerializableSerializer() - Constructor for class org.I0Itec.zkclient.serialize.SerializableSerializer
 
serialize(Object) - Method in class org.I0Itec.zkclient.serialize.BytesPushThroughSerializer
 
serialize(Object) - Method in class org.I0Itec.zkclient.serialize.SerializableSerializer
 
serialize(Object) - Method in interface org.I0Itec.zkclient.serialize.ZkSerializer
 
set(T) - Method in class org.I0Itec.zkclient.Holder
 
setContent(T) - Method in class org.I0Itec.zkclient.ContentWatcher
 
setCurrentState(Watcher.Event.KeeperState) - Method in class org.I0Itec.zkclient.ZkClient
 
setShutdownTrigger(boolean) - Method in class org.I0Itec.zkclient.ZkClient
 
setZkSerializer(ZkSerializer) - Method in class org.I0Itec.zkclient.ZkClient
 
showChilds(String) - Method in interface org.I0Itec.zkclient.util.ZkPathUtil.PathFilter
 
showFolders(OutputStream) - Method in class org.I0Itec.zkclient.ZkClient
 
shutdown() - Method in class org.I0Itec.zkclient.ZkServer
 
start() - Method in class org.I0Itec.zkclient.ContentWatcher
 
start() - Method in class org.I0Itec.zkclient.Gateway
 
start() - Method in class org.I0Itec.zkclient.ZkServer
 
stop() - Method in class org.I0Itec.zkclient.ContentWatcher
 
stop() - Method in class org.I0Itec.zkclient.Gateway
 
subscribeChildChanges(String, IZkChildListener) - Method in class org.I0Itec.zkclient.ZkClient
 
subscribeDataChanges(String, IZkDataListener) - Method in class org.I0Itec.zkclient.ZkClient
 
subscribeStateChanges(IZkStateListener) - Method in class org.I0Itec.zkclient.ZkClient
 

T

toString(ZkClient) - Static method in class org.I0Itec.zkclient.util.ZkPathUtil
 
toString(ZkClient, String, ZkPathUtil.PathFilter) - Static method in class org.I0Itec.zkclient.util.ZkPathUtil
 

U

unsubscribeAll() - Method in class org.I0Itec.zkclient.ZkClient
 
unsubscribeChildChanges(String, IZkChildListener) - Method in class org.I0Itec.zkclient.ZkClient
 
unsubscribeDataChanges(String, IZkDataListener) - Method in class org.I0Itec.zkclient.ZkClient
 
unsubscribeStateChanges(IZkStateListener) - Method in class org.I0Itec.zkclient.ZkClient
 
update(T) - Method in interface org.I0Itec.zkclient.DataUpdater
Updates the current data of a znode.
updateDataSerialized(String, DataUpdater<T>) - Method in class org.I0Itec.zkclient.ZkClient
Updates data of an existing znode.

W

waitForKeeperState(Watcher.Event.KeeperState, long, TimeUnit) - Method in class org.I0Itec.zkclient.ZkClient
 
waitUntilConnected() - Method in class org.I0Itec.zkclient.ZkClient
 
waitUntilConnected(long, TimeUnit) - Method in class org.I0Itec.zkclient.ZkClient
 
waitUntilExists(String, TimeUnit, long) - Method in class org.I0Itec.zkclient.ZkClient
 
watchForChilds(String) - Method in class org.I0Itec.zkclient.ZkClient
Installs a child watch for the given path.
watchForData(String) - Method in class org.I0Itec.zkclient.ZkClient
 
writeData(String, byte[], int) - Method in class org.I0Itec.zkclient.InMemoryConnection
 
writeData(String, Object) - Method in class org.I0Itec.zkclient.ZkClient
 
writeData(String, Object, int) - Method in class org.I0Itec.zkclient.ZkClient
 
writeData(String, byte[]) - Method in class org.I0Itec.zkclient.ZkConnection
 
writeData(String, byte[], int) - Method in class org.I0Itec.zkclient.ZkConnection
 

Z

ZkBadVersionException - Exception in org.I0Itec.zkclient.exception
 
ZkBadVersionException() - Constructor for exception org.I0Itec.zkclient.exception.ZkBadVersionException
 
ZkBadVersionException(KeeperException) - Constructor for exception org.I0Itec.zkclient.exception.ZkBadVersionException
 
ZkBadVersionException(String, KeeperException) - Constructor for exception org.I0Itec.zkclient.exception.ZkBadVersionException
 
ZkBadVersionException(String) - Constructor for exception org.I0Itec.zkclient.exception.ZkBadVersionException
 
ZkClient - Class in org.I0Itec.zkclient
Abstracts the interaction with zookeeper and allows permanent (not just one time) watches on nodes in ZooKeeper
ZkClient(String) - Constructor for class org.I0Itec.zkclient.ZkClient
 
ZkClient(String, int) - Constructor for class org.I0Itec.zkclient.ZkClient
 
ZkClient(String, int, int) - Constructor for class org.I0Itec.zkclient.ZkClient
 
ZkClient(String, int, int, ZkSerializer) - Constructor for class org.I0Itec.zkclient.ZkClient
 
ZkClient(IZkConnection) - Constructor for class org.I0Itec.zkclient.ZkClient
 
ZkClient(IZkConnection, int) - Constructor for class org.I0Itec.zkclient.ZkClient
 
ZkClient(IZkConnection, int, ZkSerializer) - Constructor for class org.I0Itec.zkclient.ZkClient
 
ZkConnection - Class in org.I0Itec.zkclient
 
ZkConnection(String) - Constructor for class org.I0Itec.zkclient.ZkConnection
 
ZkConnection(String, int) - Constructor for class org.I0Itec.zkclient.ZkConnection
 
ZkException - Exception in org.I0Itec.zkclient.exception
 
ZkException() - Constructor for exception org.I0Itec.zkclient.exception.ZkException
 
ZkException(String, Throwable) - Constructor for exception org.I0Itec.zkclient.exception.ZkException
 
ZkException(String) - Constructor for exception org.I0Itec.zkclient.exception.ZkException
 
ZkException(Throwable) - Constructor for exception org.I0Itec.zkclient.exception.ZkException
 
ZkInterruptedException - Exception in org.I0Itec.zkclient.exception
 
ZkInterruptedException(InterruptedException) - Constructor for exception org.I0Itec.zkclient.exception.ZkInterruptedException
 
ZkLock - Class in org.I0Itec.zkclient
 
ZkLock() - Constructor for class org.I0Itec.zkclient.ZkLock
 
ZkMarshallingError - Exception in org.I0Itec.zkclient.exception
 
ZkMarshallingError() - Constructor for exception org.I0Itec.zkclient.exception.ZkMarshallingError
 
ZkMarshallingError(Throwable) - Constructor for exception org.I0Itec.zkclient.exception.ZkMarshallingError
 
ZkMarshallingError(String, Throwable) - Constructor for exception org.I0Itec.zkclient.exception.ZkMarshallingError
 
ZkMarshallingError(String) - Constructor for exception org.I0Itec.zkclient.exception.ZkMarshallingError
 
ZkNodeExistsException - Exception in org.I0Itec.zkclient.exception
 
ZkNodeExistsException() - Constructor for exception org.I0Itec.zkclient.exception.ZkNodeExistsException
 
ZkNodeExistsException(KeeperException) - Constructor for exception org.I0Itec.zkclient.exception.ZkNodeExistsException
 
ZkNodeExistsException(String, KeeperException) - Constructor for exception org.I0Itec.zkclient.exception.ZkNodeExistsException
 
ZkNodeExistsException(String) - Constructor for exception org.I0Itec.zkclient.exception.ZkNodeExistsException
 
ZkNoNodeException - Exception in org.I0Itec.zkclient.exception
 
ZkNoNodeException() - Constructor for exception org.I0Itec.zkclient.exception.ZkNoNodeException
 
ZkNoNodeException(KeeperException) - Constructor for exception org.I0Itec.zkclient.exception.ZkNoNodeException
 
ZkNoNodeException(String, KeeperException) - Constructor for exception org.I0Itec.zkclient.exception.ZkNoNodeException
 
ZkNoNodeException(String) - Constructor for exception org.I0Itec.zkclient.exception.ZkNoNodeException
 
ZkPathUtil - Class in org.I0Itec.zkclient.util
 
ZkPathUtil() - Constructor for class org.I0Itec.zkclient.util.ZkPathUtil
 
ZkPathUtil.PathFilter - Interface in org.I0Itec.zkclient.util
 
ZkSerializer - Interface in org.I0Itec.zkclient.serialize
Zookeeper is able to store data in form of byte arrays.
ZkServer - Class in org.I0Itec.zkclient
 
ZkServer(String, String, IDefaultNameSpace) - Constructor for class org.I0Itec.zkclient.ZkServer
 
ZkServer(String, String, IDefaultNameSpace, int) - Constructor for class org.I0Itec.zkclient.ZkServer
 
ZkServer(String, String, IDefaultNameSpace, int, int) - Constructor for class org.I0Itec.zkclient.ZkServer
 
ZkTimeoutException - Exception in org.I0Itec.zkclient.exception
 
ZkTimeoutException() - Constructor for exception org.I0Itec.zkclient.exception.ZkTimeoutException
 
ZkTimeoutException(String, Throwable) - Constructor for exception org.I0Itec.zkclient.exception.ZkTimeoutException
 
ZkTimeoutException(String) - Constructor for exception org.I0Itec.zkclient.exception.ZkTimeoutException
 
ZkTimeoutException(Throwable) - Constructor for exception org.I0Itec.zkclient.exception.ZkTimeoutException
 

_

_connection - Variable in class org.I0Itec.zkclient.ZkClient
 

A B C D E G H I L N O P R S T U W Z _