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
↓ 1 callers
Method
delete
(String path)
src/main/java/org/I0Itec/zkclient/InMemoryConnection.java:208
↓ 1 callers
Method
delete
(final String path)
src/main/java/org/I0Itec/zkclient/ZkClient.java:1042
↓ 1 callers
Method
derializable
(byte[] data)
src/main/java/org/I0Itec/zkclient/ZkClient.java:1067
↓ 1 callers
Method
deserialize
(byte[] bytes)
src/main/java/org/I0Itec/zkclient/serialize/ZkSerializer.java:31
↓ 1 callers
Method
establishConnection
()
src/test/java/org/I0Itec/zkclient/ZkConnectionTest.java:30
↓ 1 callers
Method
fireAllEvents
()
src/main/java/org/I0Itec/zkclient/ZkClient.java:663
↓ 1 callers
Method
fireNewSessionEvents
()
src/main/java/org/I0Itec/zkclient/ZkClient.java:730
↓ 1 callers
Method
fireSessionEstablishmentError
(final Throwable error)
src/main/java/org/I0Itec/zkclient/ZkClient.java:754
↓ 1 callers
Method
fireStateChangedEvent
(final KeeperState state)
src/main/java/org/I0Itec/zkclient/ZkClient.java:742
↓ 1 callers
Method
getChildren
(String path, boolean watch)
src/main/java/org/I0Itec/zkclient/InMemoryConnection.java:257
↓ 1 callers
Method
getCreateTime
(String path)
src/main/java/org/I0Itec/zkclient/IZkConnection.java:56
↓ 1 callers
Method
getCreationTime
(String path)
src/main/java/org/I0Itec/zkclient/ZkClient.java:1247
↓ 1 callers
Method
getServerPort
()
src/test/java/org/I0Itec/zkclient/testutil/ZkTestSystem.java:105
↓ 1 callers
Method
getServers
()
src/main/java/org/I0Itec/zkclient/ZkConnection.java:160
↓ 1 callers
Method
getSmallestElement
(List<String> list)
src/main/java/org/I0Itec/zkclient/DistributedQueue.java:81
↓ 1 callers
Method
handleDataChange
(String dataPath, Object data)
src/main/java/org/I0Itec/zkclient/IZkDataListener.java:27
↓ 1 callers
Method
handleDataDeleted
(String dataPath)
src/main/java/org/I0Itec/zkclient/IZkDataListener.java:29
↓ 1 callers
Method
handleNewSession
Called after the zookeeper session has expired and a new session has been created. You would have to re-create any ephemeral nodes here. @throws Exce
src/main/java/org/I0Itec/zkclient/IZkStateListener.java:39
↓ 1 callers
Method
handleSessionEstablishmentError
Called when a session cannot be re-established. This should be used to implement connection failure handling e.g. retry to connect or pass the error u
src/main/java/org/I0Itec/zkclient/IZkStateListener.java:50
↓ 1 callers
Method
handleStateChanged
Called when the zookeeper connection state has changed. @param state The new state. @throws Exception On any error.
src/main/java/org/I0Itec/zkclient/IZkStateListener.java:30
↓ 1 callers
Method
hostNamesInList
(final String serverList, final String[] hostNames)
src/main/java/org/I0Itec/zkclient/NetworkUtil.java:68
↓ 1 callers
Method
interruptAndJoin
()
src/main/java/org/I0Itec/zkclient/GatewayThread.java:172
↓ 1 callers
Method
ipToString
(final byte[] bytes)
src/main/java/org/I0Itec/zkclient/NetworkUtil.java:57
↓ 1 callers
Method
isPortFree
(int port)
src/main/java/org/I0Itec/zkclient/NetworkUtil.java:92
↓ 1 callers
Method
isZkSaslEnabled
()
src/main/java/org/I0Itec/zkclient/ZkClient.java:890
↓ 1 callers
Method
processDataOrChildChange
(WatchedEvent event)
src/main/java/org/I0Itec/zkclient/ZkClient.java:795
↓ 1 callers
Method
processStateChanged
(WatchedEvent event)
src/main/java/org/I0Itec/zkclient/ZkClient.java:712
↓ 1 callers
Method
readData
()
src/main/java/org/I0Itec/zkclient/ContentWatcher.java:52
↓ 1 callers
Method
reconnect
()
src/main/java/org/I0Itec/zkclient/ZkClient.java:1285
↓ 1 callers
Method
retainInterruptFlag
This sets the interrupt flag if the catched exception was an {@link InterruptedException}. Catching such an exception always clears the interrupt flag
src/main/java/org/I0Itec/zkclient/ExceptionUtil.java:37
↓ 1 callers
Method
run
()
src/test/java/org/I0Itec/zkclient/testutil/ZkTestSystem.java:83
↓ 1 callers
Method
run
()
src/main/java/org/I0Itec/zkclient/ZkEventThread.java:50
↓ 1 callers
Method
serialize
(Object data)
src/main/java/org/I0Itec/zkclient/serialize/ZkSerializer.java:29
↓ 1 callers
Method
setCurrentState
(KeeperState currentState)
src/main/java/org/I0Itec/zkclient/ZkClient.java:1022
↓ 1 callers
Method
setFailOnConnect
(boolean failFlag)
src/test/java/org/I0Itec/zkclient/ZkStateChangeTest.java:138
↓ 1 callers
Method
showChilds
(String path)
src/main/java/org/I0Itec/zkclient/util/ZkPathUtil.java:70
↓ 1 callers
Method
showFolders
(OutputStream output)
src/main/java/org/I0Itec/zkclient/ZkClient.java:882
↓ 1 callers
Method
start
()
src/main/java/org/I0Itec/zkclient/ZkServer.java:78
↓ 1 callers
Method
startSingleZkServer
(final int tickTime, final File dataDir, final File dataLogDir, final int port)
src/main/java/org/I0Itec/zkclient/ZkServer.java:138
↓ 1 callers
Method
startZooKeeperServer
()
src/main/java/org/I0Itec/zkclient/ZkServer.java:100
↓ 1 callers
Method
unsubscribeAll
()
src/main/java/org/I0Itec/zkclient/ZkClient.java:223
↓ 1 callers
Method
unsubscribeChildChanges
(String path, IZkChildListener childListener)
src/main/java/org/I0Itec/zkclient/ZkClient.java:176
↓ 1 callers
Method
unsubscribeStateChanges
(IZkStateListener stateListener)
src/main/java/org/I0Itec/zkclient/ZkClient.java:217
↓ 1 callers
Method
update
Updates the current data of a znode. @param currentData The current contents. @return the new data that should be written back to ZooKeepe
src/main/java/org/I0Itec/zkclient/DataUpdater.java:32
↓ 1 callers
Method
updateDataSerialized
Updates data of an existing znode. The current content of the znode is passed to the {@link DataUpdater} that is passed into this method, which return
src/main/java/org/I0Itec/zkclient/ZkClient.java:1126
↓ 1 callers
Method
watchForChilds
Installs a child watch for the given path. @param path @return the current children of the path or null if the zk node with the given path doesn't ex
src/main/java/org/I0Itec/zkclient/ZkClient.java:1174
↓ 1 callers
Method
watchForData
(final String path)
src/main/java/org/I0Itec/zkclient/ZkClient.java:1158
↓ 1 callers
Method
writeData
(String path, byte[] data, int expectedVersion)
src/main/java/org/I0Itec/zkclient/InMemoryConnection.java:320
↓ 1 callers
Method
writeData
(String path, Object object)
src/main/java/org/I0Itec/zkclient/ZkClient.java:1110
↓ 1 callers
Method
writeDataReturnStat
(String path, byte[] data, int expectedVersion)
src/main/java/org/I0Itec/zkclient/IZkConnection.java:52
↓ 1 callers
Method
writeDataReturnStat
(String path, byte[] data, int expectedVersion)
src/main/java/org/I0Itec/zkclient/InMemoryConnection.java:325
↓ 1 callers
Method
writeDataReturnStat
(final String path, Object datat, final int expectedVersion)
src/main/java/org/I0Itec/zkclient/ZkClient.java:1146
Method
AbstractConnectionTest
(IZkConnection connection)
src/test/java/org/I0Itec/zkclient/AbstractConnectionTest.java:31
Method
ContentWatcher
(ZkClient zkClient, String fileName)
src/main/java/org/I0Itec/zkclient/ContentWatcher.java:41
Method
DataAndVersion
(byte[] data, int version, List<ACL> acl)
src/main/java/org/I0Itec/zkclient/InMemoryConnection.java:68
Method
DeferredGatewayStarter
(Gateway gateway, int delay)
src/test/java/org/I0Itec/zkclient/DeferredGatewayStarter.java:23
Method
DistributedQueue
(ZkClient zkClient, String root)
src/main/java/org/I0Itec/zkclient/DistributedQueue.java:48
Method
Element
(String name, T data)
src/main/java/org/I0Itec/zkclient/DistributedQueue.java:29
Method
EventThread
(Watcher watcher)
src/main/java/org/I0Itec/zkclient/InMemoryConnection.java:106
Method
Gateway
(int port, int destinationPort)
src/main/java/org/I0Itec/zkclient/Gateway.java:24
Method
GatewayThread
(int port, int destinationPort)
src/main/java/org/I0Itec/zkclient/GatewayThread.java:46
Method
Holder
()
src/main/java/org/I0Itec/zkclient/Holder.java:22
Method
InMemoryConnection
()
src/main/java/org/I0Itec/zkclient/InMemoryConnection.java:126
Method
InMemoryConnectionTest
()
src/test/java/org/I0Itec/zkclient/InMemoryConnectionTest.java:21
Method
TcclAwareObjectIputStream
(InputStream in)
src/main/java/org/I0Itec/zkclient/serialize/TcclAwareObjectIputStream.java:29
Method
ZkAuthFailedException
()
src/main/java/org/I0Itec/zkclient/exception/ZkAuthFailedException.java:22
Method
ZkBadVersionException
()
src/main/java/org/I0Itec/zkclient/exception/ZkBadVersionException.java:24
Method
ZkClient
(String serverstring)
src/main/java/org/I0Itec/zkclient/ZkClient.java:85
Method
ZkConnection
(String zkServers)
src/main/java/org/I0Itec/zkclient/ZkConnection.java:52
Method
ZkConnectionResolveHosts
()
src/test/java/org/I0Itec/zkclient/ZkConnectionResolveHostsTest.java:12
Method
ZkConnectionTest
()
src/test/java/org/I0Itec/zkclient/ZkConnectionTest.java:26
Method
ZkEvent
(String description)
src/main/java/org/I0Itec/zkclient/ZkEventThread.java:46
Method
ZkEventThread
(String name)
src/main/java/org/I0Itec/zkclient/ZkEventThread.java:58
Method
ZkException
()
src/main/java/org/I0Itec/zkclient/exception/ZkException.java:24
Method
ZkInterruptedException
(InterruptedException e)
src/main/java/org/I0Itec/zkclient/exception/ZkInterruptedException.java:22
Method
ZkMarshallingError
()
src/main/java/org/I0Itec/zkclient/exception/ZkMarshallingError.java:22
Method
ZkNoNodeException
()
src/main/java/org/I0Itec/zkclient/exception/ZkNoNodeException.java:24
Method
ZkNodeExistsException
()
src/main/java/org/I0Itec/zkclient/exception/ZkNodeExistsException.java:24
Method
ZkServer
(String dataDir, String logDir, IDefaultNameSpace defaultNameSpace)
src/main/java/org/I0Itec/zkclient/ZkServer.java:53
Method
ZkTestSystem
()
src/test/java/org/I0Itec/zkclient/testutil/ZkTestSystem.java:39
Method
ZkTimeoutException
()
src/main/java/org/I0Itec/zkclient/exception/ZkTimeoutException.java:22
Method
addAuthInfo
(String scheme, byte[] auth)
src/test/java/org/I0Itec/zkclient/ZkStateChangeTest.java:212
Method
addAuthInfo
(String scheme, byte[] auth)
src/main/java/org/I0Itec/zkclient/InMemoryConnection.java:395
Method
addAuthInfo
(String scheme, byte[] auth)
src/main/java/org/I0Itec/zkclient/ZkConnection.java:170
Method
addAuthInfo
Add authentication information to the connection. This will be used to identify the user and check access to nodes protected by ACLs @param scheme @p
src/main/java/org/I0Itec/zkclient/ZkClient.java:1199
Method
after
()
src/test/java/org/I0Itec/zkclient/testutil/ZkTestSystem.java:60
Method
before
()
src/test/java/org/I0Itec/zkclient/testutil/ZkTestSystem.java:54
Method
call
()
src/test/java/org/I0Itec/zkclient/ContentWatcherTest.java:64
Method
call
()
src/test/java/org/I0Itec/zkclient/AbstractBaseZkClientTest.java:160
Method
call
()
src/test/java/org/I0Itec/zkclient/ServerZkClientTest.java:94
Method
close
()
src/test/java/org/I0Itec/zkclient/ZkStateChangeTest.java:142
Method
close
()
src/main/java/org/I0Itec/zkclient/InMemoryConnection.java:137
Method
close
()
src/main/java/org/I0Itec/zkclient/ZkConnection.java:79
Method
connect
(Watcher w)
src/test/java/org/I0Itec/zkclient/ZkStateChangeTest.java:119
Method
connect
(Watcher watcher)
src/main/java/org/I0Itec/zkclient/InMemoryConnection.java:151
Method
connect
(Watcher watcher)
src/main/java/org/I0Itec/zkclient/ZkConnection.java:61
Method
create
(String path, byte[] data, CreateMode mode)
src/test/java/org/I0Itec/zkclient/ZkStateChangeTest.java:147
Method
create
(String path, byte[] data, CreateMode mode)
src/main/java/org/I0Itec/zkclient/ZkConnection.java:93
Method
createEphemeral
Create an ephemeral node. @param path @throws ZkInterruptedException if operation was interrupted, or a required reconnection got interru
src/main/java/org/I0Itec/zkclient/ZkClient.java:460
Method
createEphemeralSequential
Create an ephemeral, sequential node. @param path @param data @return created path @throws ZkInterruptedException if operation was interr
src/main/java/org/I0Itec/zkclient/ZkClient.java:589
← previous
next →
101–200 of 343, ranked by callers