Dependencies
Declarations
-
org
-
I0Itec
-
zkclient
-
ContentWatcher
-
DataUpdater
-
DistributedQueue
-
ExceptionUtil
-
Gateway
-
GatewayThread
-
Holder
-
IDefaultNameSpace
-
IZkChildListener
-
IZkConnection
-
connect(Watcher): void
-
close(): void
-
create(String, byte[], CreateMode): String
-
create(String, byte[], List<ACL>, CreateMode): String
-
delete(String): void
-
delete(String, int): void
-
exists(String, boolean): boolean
-
getChildren(String, boolean): List<String>
-
readData(String, Stat, boolean): byte[]
-
writeData(String, byte[], int): void
-
writeDataReturnStat(String, byte[], int): Stat
-
getZookeeperState(): States
-
getCreateTime(String): long
-
getServers(): String
-
multi(Iterable<Op>): List<OpResult>
-
addAuthInfo(String, byte[]): void
-
setAcl(String, List<ACL>, int): void
-
getAcl(String): Entry<List<ACL>, Stat>
-
IZkDataListener
-
IZkStateListener
-
InMemoryConnection
-
DataAndVersion
-
_lock: Lock
-
_data: Map<String, DataAndVersion>
-
_creationTime: Map<String, Long>
-
_ids: List<Id>
-
sequence: AtomicInteger
-
_dataWatches: Set<String>
-
_nodeWatches: Set<String>
-
_eventThread: EventThread
-
EventThread
-
InMemoryConnection(): void
-
close(): void
-
connect(Watcher): void
-
create(String, byte[], List<ACL>, CreateMode): String
-
create(String, byte[], CreateMode): String
-
getParentPath(String): String
-
delete(String): void
-
delete(String, int): void
-
exists(String, boolean): boolean
-
installWatch(Set<String>, String): void
-
getChildren(String, boolean): List<String>
-
getZookeeperState(): States
-
readData(String, Stat, boolean): byte[]
-
writeData(String, byte[], int): void
-
writeDataReturnStat(String, byte[], int): Stat
-
checkWatch(Set<String>, String, EventType): void
-
getCreateTime(String): long
-
getServers(): String
-
multi(Iterable<Op>): List<OpResult>
-
addAuthInfo(String, byte[]): void
-
setAcl(String, List<ACL>, int): void
-
getAcl(String): Entry<List<ACL>, Stat>
-
checkACL(String, int): void
-
NetworkUtil
-
ZkClient
-
LOG: Logger
-
JAVA_LOGIN_CONFIG_PARAM: String
-
ZK_SASL_CLIENT: String
-
ZK_LOGIN_CONTEXT_NAME_KEY: String
-
_connection: IZkConnection
-
_operationRetryTimeoutInMillis: long
-
_childListener: Map<String, Set<IZkChildListener>>
-
_dataListener: ConcurrentHashMap<String, Set<IZkDataListener>>
-
_stateListener: Set<IZkStateListener>
-
_currentState: KeeperState
-
_zkEventLock: ZkLock
-
_shutdownTriggered: boolean
-
_eventThread: ZkEventThread
-
_zookeeperEventThread: Thread
-
_zkSerializer: ZkSerializer
-
_closed: boolean
-
_isZkSaslEnabled: boolean
-
ZkClient(String): void
-
ZkClient(String, int): void
-
ZkClient(String, int, int): void
-
ZkClient(String, int, int, ZkSerializer): void
-
ZkClient(String, int, int, ZkSerializer, long): void
-
ZkClient(IZkConnection): void
-
ZkClient(IZkConnection, int): void
-
ZkClient(IZkConnection, int, ZkSerializer): void
-
ZkClient(IZkConnection, int, ZkSerializer, long): void
-
setZkSerializer(ZkSerializer): void
-
subscribeChildChanges(String, IZkChildListener): List<String>
-
unsubscribeChildChanges(String, IZkChildListener): void
-
subscribeDataChanges(String, IZkDataListener): void
-
unsubscribeDataChanges(String, IZkDataListener): void
-
subscribeStateChanges(IZkStateListener): void
-
unsubscribeStateChanges(IZkStateListener): void
-
unsubscribeAll(): void
-
createPersistent(String): void
-
createPersistent(String, boolean): void
-
createPersistent(String, boolean, List<ACL>): void
-
setAcl(String, List<ACL>): void
-
getAcl(String): Entry<List<ACL>, Stat>
-
createPersistent(String, Object): void
-
createPersistent(String, Object, List<ACL>): void
-
createPersistentSequential(String, Object): String
-
createPersistentSequential(String, Object, List<ACL>): String
-
createEphemeral(String): void
-
createEphemeral(String, List<ACL>): void
-
create(String, Object, CreateMode): String
-
create(String, Object, List<ACL>, CreateMode): String
-
createEphemeral(String, Object): void
-
createEphemeral(String, Object, List<ACL>): void
-
createEphemeralSequential(String, Object): String
-
createEphemeralSequential(String, Object, List<ACL>): String
-
process(WatchedEvent): void
-
fireAllEvents(): void
-
getChildren(String): List<String>
-
getChildren(String, boolean): List<String>
-
countChildren(String): int
-
exists(String, boolean): boolean
-
exists(String): boolean
-
processStateChanged(WatchedEvent): void
-
fireNewSessionEvents(): void
-
fireStateChangedEvent(KeeperState): void
-
fireSessionEstablishmentError(Throwable): void
-
hasListeners(String): boolean
-
deleteRecursive(String): boolean
-
processDataOrChildChange(WatchedEvent): void
-
fireDataChangedEvents(String, Set<IZkDataListener>): void
-
fireChildChangedEvents(String, Set<IZkChildListener>): void
-
waitUntilExists(String, TimeUnit, long): boolean
-
getDataListener(String): Set<IZkDataListener>
-
showFolders(OutputStream): void
-
isZkSaslEnabled(): boolean
-
waitUntilConnected(): void
-
waitUntilConnected(long, TimeUnit): boolean
-
waitForKeeperState(KeeperState, long, TimeUnit): boolean
-
acquireEventLock(): void
-
retryUntilConnected(Callable<Object>): Object
-
waitForRetry(): void
-
setCurrentState(KeeperState): void
-
getEventLock(): ZkLock
-
delete(String): boolean
-
delete(String, int): boolean
-
serialize(Object): byte[]
-
derializable(byte[]): Object
-
readData(String): Object
-
readData(String, boolean): Object
-
readData(String, Stat): Object
-
readData(String, Stat, boolean): Object
-
writeData(String, Object): void
-
updateDataSerialized(String, DataUpdater<Object>): void
-
writeData(String, Object, int): void
-
writeDataReturnStat(String, Object, int): Stat
-
watchForData(String): void
-
watchForChilds(String): List<String>
-
addAuthInfo(String, byte[]): void
-
connect(long, Watcher): void
-
getCreationTime(String): long
-
close(): void
-
reconnect(): void
-
setShutdownTrigger(boolean): void
-
getShutdownTrigger(): boolean
-
numberOfListeners(): int
-
multi(Iterable<Op>): List<OpResult>
-
ZkConnection
-
LOG: Logger
-
DEFAULT_SESSION_TIMEOUT: int
-
_zk: ZooKeeper
-
_zookeeperLock: Lock
-
_servers: String
-
_sessionTimeOut: int
-
ZkConnection(String): void
-
ZkConnection(String, int): void
-
connect(Watcher): void
-
close(): void
-
create(String, byte[], CreateMode): String
-
create(String, byte[], List<ACL>, CreateMode): String
-
delete(String): void
-
delete(String, int): void
-
exists(String, boolean): boolean
-
getChildren(String, boolean): List<String>
-
readData(String, Stat, boolean): byte[]
-
writeData(String, byte[]): void
-
writeData(String, byte[], int): void
-
writeDataReturnStat(String, byte[], int): Stat
-
getZookeeperState(): States
-
getZookeeper(): ZooKeeper
-
getCreateTime(String): long
-
getServers(): String
-
multi(Iterable<Op>): List<OpResult>
-
addAuthInfo(String, byte[]): void
-
setAcl(String, List<ACL>, int): void
-
getAcl(String): Entry<List<ACL>, Stat>
-
ZkEventThread
-
ZkLock
-
ZkServer
-
LOG: Logger
-
DEFAULT_PORT: int
-
DEFAULT_TICK_TIME: int
-
DEFAULT_MIN_SESSION_TIMEOUT: int
-
_dataDir: String
-
_logDir: String
-
_defaultNameSpace: IDefaultNameSpace
-
_zk: ZooKeeperServer
-
_nioFactory: NIOServerCnxnFactory
-
_zkClient: ZkClient
-
_port: int
-
_tickTime: int
-
_minSessionTimeout: int
-
ZkServer(String, String, IDefaultNameSpace): void
-
ZkServer(String, String, IDefaultNameSpace, int): void
-
ZkServer(String, String, IDefaultNameSpace, int, int): void
-
ZkServer(String, String, IDefaultNameSpace, int, int, int): void
-
getPort(): int
-
start(): void
-
startZooKeeperServer(): void
-
startSingleZkServer(int, File, File, int): void
-
shutdown(): void
-
getZkClient(): ZkClient
-
exception
-
serialize
-
util
Java files
Class files