Code
Hub
Workspaces
Following
Trending
Connect
MCP
copy
Create free account
hub
/
github.com/sgroschupf/zkclient
/ functions
Functions
343 in github.com/sgroschupf/zkclient
⨍
Functions
343
◇
Types & classes
58
↓ 55 callers
Method
get
()
src/main/java/org/I0Itec/zkclient/Holder.java:30
↓ 41 callers
Method
createPersistent
Create a persistent node. @param path @throws ZkInterruptedException if operation was interrupted, or a required reconnection got interru
src/main/java/org/I0Itec/zkclient/ZkClient.java:250
↓ 24 callers
Method
start
()
src/main/java/org/I0Itec/zkclient/Gateway.java:29
↓ 20 callers
Method
getEventLock
Returns a mutex all zookeeper events are synchronized aginst. So in case you need to do something without getting any zookeeper event interruption syn
src/main/java/org/I0Itec/zkclient/ZkClient.java:1038
↓ 19 callers
Method
close
()
src/main/java/org/I0Itec/zkclient/IZkConnection.java:34
↓ 18 callers
Method
create
(String path, byte[] data, CreateMode mode)
src/main/java/org/I0Itec/zkclient/IZkConnection.java:36
↓ 15 callers
Method
delete
(String path)
src/main/java/org/I0Itec/zkclient/IZkConnection.java:40
↓ 15 callers
Method
retryUntilConnected
@param <T> @param callable @return result of Callable @throws ZkInterruptedException if operation was interrupted, or a required reconnect
src/main/java/org/I0Itec/zkclient/ZkClient.java:981
↓ 15 callers
Method
waitUntil
This waits until the provided {@link Callable} returns an object that is equals to the given expected value or the timeout has been reached. In both c
src/test/java/org/I0Itec/zkclient/TestUtil.java:50
↓ 14 callers
Method
set
(T value)
src/main/java/org/I0Itec/zkclient/Holder.java:34
↓ 13 callers
Method
interrupt
()
src/main/java/org/I0Itec/zkclient/GatewayThread.java:98
↓ 12 callers
Method
exists
(final String path, final boolean watch)
src/main/java/org/I0Itec/zkclient/IZkConnection.java:44
↓ 12 callers
Method
shutdown
()
src/main/java/org/I0Itec/zkclient/ZkServer.java:153
↓ 11 callers
Method
create
Create a node. @param path @param data @param mode @return create node's path @throws ZkInterruptedException if operation was interrupted
src/main/java/org/I0Itec/zkclient/ZkClient.java:498
↓ 10 callers
Method
readData
(String path, Stat stat, boolean watch)
src/main/java/org/I0Itec/zkclient/IZkConnection.java:48
↓ 10 callers
Method
stop
()
src/main/java/org/I0Itec/zkclient/Gateway.java:38
↓ 9 callers
Method
getChildren
(final String path, final boolean watch)
src/main/java/org/I0Itec/zkclient/IZkConnection.java:46
↓ 9 callers
Method
getInstance
()
src/test/java/org/I0Itec/zkclient/testutil/ZkTestSystem.java:78
↓ 9 callers
Method
getZkClient
()
src/test/java/org/I0Itec/zkclient/testutil/ZkTestSystem.java:101
↓ 9 callers
Method
numberOfListeners
()
src/main/java/org/I0Itec/zkclient/ZkClient.java:1305
↓ 8 callers
Method
close
Close the client. @throws ZkInterruptedException
src/main/java/org/I0Itec/zkclient/ZkClient.java:1265
↓ 8 callers
Method
exists
(String path, boolean watch)
src/main/java/org/I0Itec/zkclient/InMemoryConnection.java:240
↓ 8 callers
Method
leadingZeros
(long number, int numberOfLeadingZeros)
src/main/java/org/I0Itec/zkclient/util/ZkPathUtil.java:24
↓ 7 callers
Method
exists
(final String path, final boolean watch)
src/main/java/org/I0Itec/zkclient/ZkClient.java:699
↓ 7 callers
Method
getVersion
()
src/main/java/org/I0Itec/zkclient/InMemoryConnection.java:82
↓ 7 callers
Method
poll
()
src/main/java/org/I0Itec/zkclient/DistributedQueue.java:62
↓ 6 callers
Method
addAuthInfo
(String scheme, byte[] auth)
src/main/java/org/I0Itec/zkclient/IZkConnection.java:62
↓ 6 callers
Method
assertTimed
(T expectedVal, Callable<T> condition)
src/test/java/org/I0Itec/zkclient/ZkStateChangeTest.java:111
↓ 6 callers
Method
checkACL
@param path - path of znode we are accessing @param perm - Privileges required for the action @throws KeeperException.NoAuthExce
src/main/java/org/I0Itec/zkclient/InMemoryConnection.java:444
↓ 6 callers
Method
checkWatch
(Set<String> watches, String path, EventType eventType)
src/main/java/org/I0Itec/zkclient/InMemoryConnection.java:349
↓ 6 callers
Method
getContent
()
src/main/java/org/I0Itec/zkclient/ContentWatcher.java:87
↓ 6 callers
Method
getZkServer
()
src/test/java/org/I0Itec/zkclient/testutil/ZkTestSystem.java:93
↓ 6 callers
Method
offer
(T element)
src/main/java/org/I0Itec/zkclient/DistributedQueue.java:53
↓ 6 callers
Method
startZkServer
(TemporaryFolder temporaryFolder, int port)
src/test/java/org/I0Itec/zkclient/TestUtil.java:96
↓ 6 callers
Method
writeData
(String path, byte[] data, int expectedVersion)
src/main/java/org/I0Itec/zkclient/IZkConnection.java:50
↓ 5 callers
Method
convertToRuntimeException
(Throwable e)
src/main/java/org/I0Itec/zkclient/ExceptionUtil.java:22
↓ 5 callers
Method
getPort
()
src/main/java/org/I0Itec/zkclient/ZkServer.java:74
↓ 5 callers
Method
readData
(String path)
src/main/java/org/I0Itec/zkclient/ZkClient.java:1075
↓ 5 callers
Method
send
(ZkEvent event)
src/main/java/org/I0Itec/zkclient/ZkEventThread.java:87
↓ 5 callers
Method
subscribeDataChanges
(String path, IZkDataListener listener)
src/main/java/org/I0Itec/zkclient/ZkClient.java:185
↓ 5 callers
Method
toString
(ZkClient zkClient)
src/main/java/org/I0Itec/zkclient/util/ZkPathUtil.java:28
↓ 4 callers
Method
acquireEventLock
()
src/main/java/org/I0Itec/zkclient/ZkClient.java:959
↓ 4 callers
Method
bootstrap
()
src/test/java/org/I0Itec/zkclient/SaslAuthenticatedTest.java:99
↓ 4 callers
Method
countChildren
Counts number of children for the given path. @param path @return number of children or 0 if path does not exist.
src/main/java/org/I0Itec/zkclient/ZkClient.java:691
↓ 4 callers
Method
deleteRecursive
(String path)
src/main/java/org/I0Itec/zkclient/ZkClient.java:778
↓ 4 callers
Method
getChildren
(String path)
src/main/java/org/I0Itec/zkclient/ZkClient.java:672
↓ 4 callers
Method
getData
()
src/main/java/org/I0Itec/zkclient/InMemoryConnection.java:78
↓ 4 callers
Method
getName
()
src/main/java/org/I0Itec/zkclient/DistributedQueue.java:34
↓ 4 callers
Method
peek
()
src/main/java/org/I0Itec/zkclient/DistributedQueue.java:118
↓ 4 callers
Method
start
()
src/main/java/org/I0Itec/zkclient/ContentWatcher.java:46
↓ 4 callers
Method
stop
()
src/main/java/org/I0Itec/zkclient/ContentWatcher.java:61
↓ 4 callers
Method
waitUntilConnected
()
src/main/java/org/I0Itec/zkclient/ZkClient.java:918
↓ 3 callers
Method
bootstrapWithAuthFailure
()
src/test/java/org/I0Itec/zkclient/SaslAuthenticatedTest.java:108
↓ 3 callers
Method
cleanupZk
()
src/test/java/org/I0Itec/zkclient/testutil/ZkTestSystem.java:66
↓ 3 callers
Method
create
(KeeperException e)
src/main/java/org/I0Itec/zkclient/exception/ZkException.java:40
↓ 3 callers
Method
getAcl
(final String path)
src/main/java/org/I0Itec/zkclient/IZkConnection.java:66
↓ 3 callers
Method
getData
()
src/main/java/org/I0Itec/zkclient/DistributedQueue.java:38
↓ 3 callers
Method
getParentPath
(String path)
src/main/java/org/I0Itec/zkclient/InMemoryConnection.java:200
↓ 3 callers
Method
getZNodeEventCondition
This condition will be signaled if any znode related zookeeper event was received. @return the condition.
src/main/java/org/I0Itec/zkclient/ZkLock.java:53
↓ 3 callers
Method
hasListeners
(String path)
src/main/java/org/I0Itec/zkclient/ZkClient.java:766
↓ 3 callers
Method
installWatch
(Set<String> watches, String path)
src/main/java/org/I0Itec/zkclient/InMemoryConnection.java:253
↓ 3 callers
Method
isEmpty
()
src/main/java/org/I0Itec/zkclient/DistributedQueue.java:92
↓ 3 callers
Method
process
(WatchedEvent event)
src/main/java/org/I0Itec/zkclient/ZkClient.java:613
↓ 3 callers
Method
subscribeChildChanges
(String path, IZkChildListener listener)
src/main/java/org/I0Itec/zkclient/ZkClient.java:164
↓ 3 callers
Method
unsubscribeDataChanges
(String path, IZkDataListener dataListener)
src/main/java/org/I0Itec/zkclient/ZkClient.java:199
↓ 3 callers
Method
waitForKeeperState
(KeeperState keeperState, long time, TimeUnit timeUnit)
src/main/java/org/I0Itec/zkclient/ZkClient.java:930
↓ 2 callers
Method
closeQuietly
(Closeable closable)
src/main/java/org/I0Itec/zkclient/GatewayThread.java:154
↓ 2 callers
Method
connect
(Watcher watcher)
src/main/java/org/I0Itec/zkclient/IZkConnection.java:32
↓ 2 callers
Method
create
(String path, byte[] data, List<ACL> acl, CreateMode mode)
src/main/java/org/I0Itec/zkclient/InMemoryConnection.java:166
↓ 2 callers
Method
expireSession
()
src/test/java/org/I0Itec/zkclient/ZkStateChangeTest.java:134
↓ 2 callers
Method
fireChildChangedEvents
(final String path, Set<IZkChildListener> childListeners)
src/main/java/org/I0Itec/zkclient/ZkClient.java:832
↓ 2 callers
Method
fireDataChangedEvents
(final String path, Set<IZkDataListener> listeners)
src/main/java/org/I0Itec/zkclient/ZkClient.java:813
↓ 2 callers
Method
getAcl
()
src/main/java/org/I0Itec/zkclient/InMemoryConnection.java:86
↓ 2 callers
Method
getDataChangedCondition
This condition will be signaled if a zookeeper event was processed and the event contains a data/child change. @return the condition.
src/main/java/org/I0Itec/zkclient/ZkLock.java:34
↓ 2 callers
Method
getFirstElement
()
src/main/java/org/I0Itec/zkclient/DistributedQueue.java:96
↓ 2 callers
Method
getLocalHostNames
()
src/main/java/org/I0Itec/zkclient/NetworkUtil.java:33
↓ 2 callers
Method
getServers
()
src/main/java/org/I0Itec/zkclient/IZkConnection.java:58
↓ 2 callers
Method
getShutdownTrigger
()
src/main/java/org/I0Itec/zkclient/ZkClient.java:1301
↓ 2 callers
Method
getSpaces
(final int level)
src/main/java/org/I0Itec/zkclient/util/ZkPathUtil.java:58
↓ 2 callers
Method
getStateChangedCondition
This condition will be signaled if a zookeeper event was processed and the event contains a state change (connected, disconnected, session expired, et
src/main/java/org/I0Itec/zkclient/ZkLock.java:44
↓ 2 callers
Method
getZkServerAddress
()
src/test/java/org/I0Itec/zkclient/testutil/ZkTestSystem.java:97
↓ 2 callers
Method
handleChildChange
Called when the children of the given path changed. @param parentPath The parent path @param currentChilds The children or null
src/main/java/org/I0Itec/zkclient/IZkChildListener.java:40
↓ 2 callers
Method
multi
(Iterable<Op> ops)
src/main/java/org/I0Itec/zkclient/IZkConnection.java:60
↓ 2 callers
Method
send
(WatchedEvent event)
src/main/java/org/I0Itec/zkclient/InMemoryConnection.java:121
↓ 2 callers
Method
serialize
(Object data)
src/main/java/org/I0Itec/zkclient/ZkClient.java:1063
↓ 2 callers
Method
setAcl
(final String path, List<ACL> acl, int version)
src/main/java/org/I0Itec/zkclient/IZkConnection.java:64
↓ 2 callers
Method
setContent
(T data)
src/main/java/org/I0Itec/zkclient/ContentWatcher.java:65
↓ 2 callers
Method
setShutdownTrigger
(boolean triggerState)
src/main/java/org/I0Itec/zkclient/ZkClient.java:1297
↓ 2 callers
Method
startServer
(int port, String dataPath, String logPath)
src/test/java/org/I0Itec/zkclient/TestUtil.java:110
↓ 2 callers
Method
subscribeStateChanges
(final IZkStateListener listener)
src/main/java/org/I0Itec/zkclient/ZkClient.java:211
↓ 2 callers
Method
waitForRetry
()
src/main/java/org/I0Itec/zkclient/ZkClient.java:1014
↓ 2 callers
Method
waitUntilExists
(String path, TimeUnit timeUnit, long time)
src/main/java/org/I0Itec/zkclient/ZkClient.java:856
↓ 1 callers
Method
addChildrenToStringBuilder
(ZkClient zkClient, PathFilter pathFilter, final int level, final StringBuilder builder, final String startPat
src/main/java/org/I0Itec/zkclient/util/ZkPathUtil.java:40
↓ 1 callers
Method
awaitUp
()
src/main/java/org/I0Itec/zkclient/GatewayThread.java:177
↓ 1 callers
Method
call
()
src/test/java/org/I0Itec/zkclient/ZkStateChangeTest.java:62
↓ 1 callers
Method
call
()
src/main/java/org/I0Itec/zkclient/ZkClient.java:334
↓ 1 callers
Method
connect
Connect to ZooKeeper. @param maxMsToWaitUntilConnected @param watcher @throws ZkInterruptedException if the connection timed out due to t
src/main/java/org/I0Itec/zkclient/ZkClient.java:1221
↓ 1 callers
Method
createDefaultNameSpace
Creates a set of default folder structure within a zookeeper . @param zkClient The zkclient.
src/main/java/org/I0Itec/zkclient/IDefaultNameSpace.java:26
↓ 1 callers
Method
createJaasFile
()
src/test/java/org/I0Itec/zkclient/SaslAuthenticatedTest.java:60
↓ 1 callers
Method
createPersistentSequential
Create a persistent, sequental node. @param path @param data @return create node's path @throws ZkInterruptedException if operation was i
src/main/java/org/I0Itec/zkclient/ZkClient.java:423
next →
1–100 of 343, ranked by callers