MCPcopy Create free account

hub / github.com/sgroschupf/zkclient / functions

Functions343 in github.com/sgroschupf/zkclient

↓ 55 callersMethodget
()
src/main/java/org/I0Itec/zkclient/Holder.java:30
↓ 41 callersMethodcreatePersistent
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 callersMethodstart
()
src/main/java/org/I0Itec/zkclient/Gateway.java:29
↓ 20 callersMethodgetEventLock
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 callersMethodclose
()
src/main/java/org/I0Itec/zkclient/IZkConnection.java:34
↓ 18 callersMethodcreate
(String path, byte[] data, CreateMode mode)
src/main/java/org/I0Itec/zkclient/IZkConnection.java:36
↓ 15 callersMethoddelete
(String path)
src/main/java/org/I0Itec/zkclient/IZkConnection.java:40
↓ 15 callersMethodretryUntilConnected
@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 callersMethodwaitUntil
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 callersMethodset
(T value)
src/main/java/org/I0Itec/zkclient/Holder.java:34
↓ 13 callersMethodinterrupt
()
src/main/java/org/I0Itec/zkclient/GatewayThread.java:98
↓ 12 callersMethodexists
(final String path, final boolean watch)
src/main/java/org/I0Itec/zkclient/IZkConnection.java:44
↓ 12 callersMethodshutdown
()
src/main/java/org/I0Itec/zkclient/ZkServer.java:153
↓ 11 callersMethodcreate
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 callersMethodreadData
(String path, Stat stat, boolean watch)
src/main/java/org/I0Itec/zkclient/IZkConnection.java:48
↓ 10 callersMethodstop
()
src/main/java/org/I0Itec/zkclient/Gateway.java:38
↓ 9 callersMethodgetChildren
(final String path, final boolean watch)
src/main/java/org/I0Itec/zkclient/IZkConnection.java:46
↓ 9 callersMethodgetInstance
()
src/test/java/org/I0Itec/zkclient/testutil/ZkTestSystem.java:78
↓ 9 callersMethodgetZkClient
()
src/test/java/org/I0Itec/zkclient/testutil/ZkTestSystem.java:101
↓ 9 callersMethodnumberOfListeners
()
src/main/java/org/I0Itec/zkclient/ZkClient.java:1305
↓ 8 callersMethodclose
Close the client. @throws ZkInterruptedException
src/main/java/org/I0Itec/zkclient/ZkClient.java:1265
↓ 8 callersMethodexists
(String path, boolean watch)
src/main/java/org/I0Itec/zkclient/InMemoryConnection.java:240
↓ 8 callersMethodleadingZeros
(long number, int numberOfLeadingZeros)
src/main/java/org/I0Itec/zkclient/util/ZkPathUtil.java:24
↓ 7 callersMethodexists
(final String path, final boolean watch)
src/main/java/org/I0Itec/zkclient/ZkClient.java:699
↓ 7 callersMethodgetVersion
()
src/main/java/org/I0Itec/zkclient/InMemoryConnection.java:82
↓ 7 callersMethodpoll
()
src/main/java/org/I0Itec/zkclient/DistributedQueue.java:62
↓ 6 callersMethodaddAuthInfo
(String scheme, byte[] auth)
src/main/java/org/I0Itec/zkclient/IZkConnection.java:62
↓ 6 callersMethodassertTimed
(T expectedVal, Callable<T> condition)
src/test/java/org/I0Itec/zkclient/ZkStateChangeTest.java:111
↓ 6 callersMethodcheckACL
@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 callersMethodcheckWatch
(Set<String> watches, String path, EventType eventType)
src/main/java/org/I0Itec/zkclient/InMemoryConnection.java:349
↓ 6 callersMethodgetContent
()
src/main/java/org/I0Itec/zkclient/ContentWatcher.java:87
↓ 6 callersMethodgetZkServer
()
src/test/java/org/I0Itec/zkclient/testutil/ZkTestSystem.java:93
↓ 6 callersMethodoffer
(T element)
src/main/java/org/I0Itec/zkclient/DistributedQueue.java:53
↓ 6 callersMethodstartZkServer
(TemporaryFolder temporaryFolder, int port)
src/test/java/org/I0Itec/zkclient/TestUtil.java:96
↓ 6 callersMethodwriteData
(String path, byte[] data, int expectedVersion)
src/main/java/org/I0Itec/zkclient/IZkConnection.java:50
↓ 5 callersMethodconvertToRuntimeException
(Throwable e)
src/main/java/org/I0Itec/zkclient/ExceptionUtil.java:22
↓ 5 callersMethodgetPort
()
src/main/java/org/I0Itec/zkclient/ZkServer.java:74
↓ 5 callersMethodreadData
(String path)
src/main/java/org/I0Itec/zkclient/ZkClient.java:1075
↓ 5 callersMethodsend
(ZkEvent event)
src/main/java/org/I0Itec/zkclient/ZkEventThread.java:87
↓ 5 callersMethodsubscribeDataChanges
(String path, IZkDataListener listener)
src/main/java/org/I0Itec/zkclient/ZkClient.java:185
↓ 5 callersMethodtoString
(ZkClient zkClient)
src/main/java/org/I0Itec/zkclient/util/ZkPathUtil.java:28
↓ 4 callersMethodacquireEventLock
()
src/main/java/org/I0Itec/zkclient/ZkClient.java:959
↓ 4 callersMethodbootstrap
()
src/test/java/org/I0Itec/zkclient/SaslAuthenticatedTest.java:99
↓ 4 callersMethodcountChildren
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 callersMethoddeleteRecursive
(String path)
src/main/java/org/I0Itec/zkclient/ZkClient.java:778
↓ 4 callersMethodgetChildren
(String path)
src/main/java/org/I0Itec/zkclient/ZkClient.java:672
↓ 4 callersMethodgetData
()
src/main/java/org/I0Itec/zkclient/InMemoryConnection.java:78
↓ 4 callersMethodgetName
()
src/main/java/org/I0Itec/zkclient/DistributedQueue.java:34
↓ 4 callersMethodpeek
()
src/main/java/org/I0Itec/zkclient/DistributedQueue.java:118
↓ 4 callersMethodstart
()
src/main/java/org/I0Itec/zkclient/ContentWatcher.java:46
↓ 4 callersMethodstop
()
src/main/java/org/I0Itec/zkclient/ContentWatcher.java:61
↓ 4 callersMethodwaitUntilConnected
()
src/main/java/org/I0Itec/zkclient/ZkClient.java:918
↓ 3 callersMethodbootstrapWithAuthFailure
()
src/test/java/org/I0Itec/zkclient/SaslAuthenticatedTest.java:108
↓ 3 callersMethodcleanupZk
()
src/test/java/org/I0Itec/zkclient/testutil/ZkTestSystem.java:66
↓ 3 callersMethodcreate
(KeeperException e)
src/main/java/org/I0Itec/zkclient/exception/ZkException.java:40
↓ 3 callersMethodgetAcl
(final String path)
src/main/java/org/I0Itec/zkclient/IZkConnection.java:66
↓ 3 callersMethodgetData
()
src/main/java/org/I0Itec/zkclient/DistributedQueue.java:38
↓ 3 callersMethodgetParentPath
(String path)
src/main/java/org/I0Itec/zkclient/InMemoryConnection.java:200
↓ 3 callersMethodgetZNodeEventCondition
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 callersMethodhasListeners
(String path)
src/main/java/org/I0Itec/zkclient/ZkClient.java:766
↓ 3 callersMethodinstallWatch
(Set<String> watches, String path)
src/main/java/org/I0Itec/zkclient/InMemoryConnection.java:253
↓ 3 callersMethodisEmpty
()
src/main/java/org/I0Itec/zkclient/DistributedQueue.java:92
↓ 3 callersMethodprocess
(WatchedEvent event)
src/main/java/org/I0Itec/zkclient/ZkClient.java:613
↓ 3 callersMethodsubscribeChildChanges
(String path, IZkChildListener listener)
src/main/java/org/I0Itec/zkclient/ZkClient.java:164
↓ 3 callersMethodunsubscribeDataChanges
(String path, IZkDataListener dataListener)
src/main/java/org/I0Itec/zkclient/ZkClient.java:199
↓ 3 callersMethodwaitForKeeperState
(KeeperState keeperState, long time, TimeUnit timeUnit)
src/main/java/org/I0Itec/zkclient/ZkClient.java:930
↓ 2 callersMethodcloseQuietly
(Closeable closable)
src/main/java/org/I0Itec/zkclient/GatewayThread.java:154
↓ 2 callersMethodconnect
(Watcher watcher)
src/main/java/org/I0Itec/zkclient/IZkConnection.java:32
↓ 2 callersMethodcreate
(String path, byte[] data, List<ACL> acl, CreateMode mode)
src/main/java/org/I0Itec/zkclient/InMemoryConnection.java:166
↓ 2 callersMethodexpireSession
()
src/test/java/org/I0Itec/zkclient/ZkStateChangeTest.java:134
↓ 2 callersMethodfireChildChangedEvents
(final String path, Set<IZkChildListener> childListeners)
src/main/java/org/I0Itec/zkclient/ZkClient.java:832
↓ 2 callersMethodfireDataChangedEvents
(final String path, Set<IZkDataListener> listeners)
src/main/java/org/I0Itec/zkclient/ZkClient.java:813
↓ 2 callersMethodgetAcl
()
src/main/java/org/I0Itec/zkclient/InMemoryConnection.java:86
↓ 2 callersMethodgetDataChangedCondition
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 callersMethodgetFirstElement
()
src/main/java/org/I0Itec/zkclient/DistributedQueue.java:96
↓ 2 callersMethodgetLocalHostNames
()
src/main/java/org/I0Itec/zkclient/NetworkUtil.java:33
↓ 2 callersMethodgetServers
()
src/main/java/org/I0Itec/zkclient/IZkConnection.java:58
↓ 2 callersMethodgetShutdownTrigger
()
src/main/java/org/I0Itec/zkclient/ZkClient.java:1301
↓ 2 callersMethodgetSpaces
(final int level)
src/main/java/org/I0Itec/zkclient/util/ZkPathUtil.java:58
↓ 2 callersMethodgetStateChangedCondition
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 callersMethodgetZkServerAddress
()
src/test/java/org/I0Itec/zkclient/testutil/ZkTestSystem.java:97
↓ 2 callersMethodhandleChildChange
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 callersMethodmulti
(Iterable<Op> ops)
src/main/java/org/I0Itec/zkclient/IZkConnection.java:60
↓ 2 callersMethodsend
(WatchedEvent event)
src/main/java/org/I0Itec/zkclient/InMemoryConnection.java:121
↓ 2 callersMethodserialize
(Object data)
src/main/java/org/I0Itec/zkclient/ZkClient.java:1063
↓ 2 callersMethodsetAcl
(final String path, List<ACL> acl, int version)
src/main/java/org/I0Itec/zkclient/IZkConnection.java:64
↓ 2 callersMethodsetContent
(T data)
src/main/java/org/I0Itec/zkclient/ContentWatcher.java:65
↓ 2 callersMethodsetShutdownTrigger
(boolean triggerState)
src/main/java/org/I0Itec/zkclient/ZkClient.java:1297
↓ 2 callersMethodstartServer
(int port, String dataPath, String logPath)
src/test/java/org/I0Itec/zkclient/TestUtil.java:110
↓ 2 callersMethodsubscribeStateChanges
(final IZkStateListener listener)
src/main/java/org/I0Itec/zkclient/ZkClient.java:211
↓ 2 callersMethodwaitForRetry
()
src/main/java/org/I0Itec/zkclient/ZkClient.java:1014
↓ 2 callersMethodwaitUntilExists
(String path, TimeUnit timeUnit, long time)
src/main/java/org/I0Itec/zkclient/ZkClient.java:856
↓ 1 callersMethodaddChildrenToStringBuilder
(ZkClient zkClient, PathFilter pathFilter, final int level, final StringBuilder builder, final String startPat
src/main/java/org/I0Itec/zkclient/util/ZkPathUtil.java:40
↓ 1 callersMethodawaitUp
()
src/main/java/org/I0Itec/zkclient/GatewayThread.java:177
↓ 1 callersMethodcall
()
src/test/java/org/I0Itec/zkclient/ZkStateChangeTest.java:62
↓ 1 callersMethodcall
()
src/main/java/org/I0Itec/zkclient/ZkClient.java:334
↓ 1 callersMethodconnect
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 callersMethodcreateDefaultNameSpace
Creates a set of default folder structure within a zookeeper . @param zkClient The zkclient.
src/main/java/org/I0Itec/zkclient/IDefaultNameSpace.java:26
↓ 1 callersMethodcreateJaasFile
()
src/test/java/org/I0Itec/zkclient/SaslAuthenticatedTest.java:60
↓ 1 callersMethodcreatePersistentSequential
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