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
Method
createZkClient
()
src/test/java/org/I0Itec/zkclient/testutil/ZkTestSystem.java:109
Method
delete
(String path)
src/test/java/org/I0Itec/zkclient/ZkStateChangeTest.java:157
Method
delete
(String path)
src/main/java/org/I0Itec/zkclient/ZkConnection.java:103
Method
deserialize
(byte[] bytes)
src/main/java/org/I0Itec/zkclient/serialize/BytesPushThroughSerializer.java:25
Method
deserialize
(byte[] bytes)
src/main/java/org/I0Itec/zkclient/serialize/SerializableSerializer.java:28
Method
exists
(final String path, final boolean watch)
src/test/java/org/I0Itec/zkclient/ZkStateChangeTest.java:167
Method
exists
(String path, boolean watch)
src/main/java/org/I0Itec/zkclient/ZkConnection.java:113
Method
getAcl
(String path)
src/test/java/org/I0Itec/zkclient/ZkStateChangeTest.java:222
Method
getAcl
(String path)
src/main/java/org/I0Itec/zkclient/InMemoryConnection.java:421
Method
getAcl
(String path)
src/main/java/org/I0Itec/zkclient/ZkConnection.java:180
Method
getAcl
Gets the acl on path @param path @return an entry instance with key = list of acls on node and value = stats. @throws ZkException if any
src/main/java/org/I0Itec/zkclient/ZkClient.java:354
Method
getChildren
(final String path, final boolean watch)
src/test/java/org/I0Itec/zkclient/ZkStateChangeTest.java:172
Method
getChildren
(final String path, final boolean watch)
src/main/java/org/I0Itec/zkclient/ZkConnection.java:118
Method
getCreateTime
(String path)
src/test/java/org/I0Itec/zkclient/ZkStateChangeTest.java:197
Method
getCreateTime
(String path)
src/main/java/org/I0Itec/zkclient/InMemoryConnection.java:356
Method
getCreateTime
(String path)
src/main/java/org/I0Itec/zkclient/ZkConnection.java:151
Method
getDataListener
(String path)
src/main/java/org/I0Itec/zkclient/ZkClient.java:878
Method
getLocalhostName
()
src/main/java/org/I0Itec/zkclient/NetworkUtil.java:111
Method
getServers
()
src/test/java/org/I0Itec/zkclient/ZkStateChangeTest.java:202
Method
getServers
()
src/main/java/org/I0Itec/zkclient/InMemoryConnection.java:365
Method
getZkClient
()
src/main/java/org/I0Itec/zkclient/ZkServer.java:179
Method
getZookeeper
()
src/main/java/org/I0Itec/zkclient/ZkConnection.java:147
Method
getZookeeperState
()
src/test/java/org/I0Itec/zkclient/ZkStateChangeTest.java:192
Method
getZookeeperState
()
src/main/java/org/I0Itec/zkclient/IZkConnection.java:54
Method
getZookeeperState
()
src/main/java/org/I0Itec/zkclient/InMemoryConnection.java:285
Method
getZookeeperState
()
src/main/java/org/I0Itec/zkclient/ZkConnection.java:142
Method
handleChildChange
(String parentPath, List<String> currentChilds)
src/test/java/org/I0Itec/zkclient/AbstractBaseZkClientTest.java:256
Method
handleChildChange
(String parentPath, List<String> currentChilds)
src/test/java/org/I0Itec/zkclient/ServerZkClientTest.java:238
Method
handleDataChange
(String dataPath, Object data)
src/test/java/org/I0Itec/zkclient/AbstractBaseZkClientTest.java:144
Method
handleDataChange
(String dataPath, Object data)
src/main/java/org/I0Itec/zkclient/ContentWatcher.java:76
Method
handleDataDeleted
(String dataPath)
src/test/java/org/I0Itec/zkclient/AbstractBaseZkClientTest.java:149
Method
handleDataDeleted
(String dataPath)
src/main/java/org/I0Itec/zkclient/ContentWatcher.java:82
Method
handleNewSession
()
src/test/java/org/I0Itec/zkclient/ZkStateChangeTest.java:240
Method
handleSessionEstablishmentError
(final Throwable error)
src/test/java/org/I0Itec/zkclient/ZkStateChangeTest.java:245
Method
handleStateChanged
(KeeperState state)
src/test/java/org/I0Itec/zkclient/ZkStateChangeTest.java:233
Method
hostNameInArray
(final String[] hostNames, final String hostName)
src/main/java/org/I0Itec/zkclient/NetworkUtil.java:83
Method
multi
(Iterable<Op> ops)
src/test/java/org/I0Itec/zkclient/ZkStateChangeTest.java:207
Method
multi
(Iterable<Op> ops)
src/main/java/org/I0Itec/zkclient/InMemoryConnection.java:370
Method
multi
(Iterable<Op> ops)
src/main/java/org/I0Itec/zkclient/ZkConnection.java:165
Method
multi
(final Iterable<Op> ops)
src/main/java/org/I0Itec/zkclient/ZkClient.java:1318
Method
readData
(String path, Stat stat, boolean watch)
src/test/java/org/I0Itec/zkclient/ZkStateChangeTest.java:177
Method
readData
(String path, Stat stat, boolean watch)
src/main/java/org/I0Itec/zkclient/InMemoryConnection.java:298
Method
readData
(String path, Stat stat, boolean watch)
src/main/java/org/I0Itec/zkclient/ZkConnection.java:123
Method
resolveClass
Load the local class equivalent of the specified stream class description. Uses the current class {@link ClassLoader} and falls back to the {@link Thr
src/main/java/org/I0Itec/zkclient/serialize/TcclAwareObjectIputStream.java:38
Method
resolveProxyClass
Returns a proxy class that implements the interfaces named in a proxy class descriptor; subclasses may implement this method to read custom data from
src/main/java/org/I0Itec/zkclient/serialize/TcclAwareObjectIputStream.java:60
Method
rethrowInterruptedException
(Throwable e)
src/main/java/org/I0Itec/zkclient/ExceptionUtil.java:43
Method
run
()
src/test/java/org/I0Itec/zkclient/ContentWatcherTest.java:80
Method
run
()
src/test/java/org/I0Itec/zkclient/AbstractBaseZkClientTest.java:117
Method
run
()
src/test/java/org/I0Itec/zkclient/DeferredGatewayStarter.java:28
Method
run
()
src/test/java/org/I0Itec/zkclient/DistributedQueueTest.java:100
Method
run
()
src/test/java/org/I0Itec/zkclient/ServerZkClientTest.java:121
Method
run
()
src/test/java/org/I0Itec/zkclient/ZkStateChangeTest.java:127
Method
run
()
src/main/java/org/I0Itec/zkclient/GatewayThread.java:52
Method
run
()
src/main/java/org/I0Itec/zkclient/ZkEventThread.java:63
Method
run
()
src/main/java/org/I0Itec/zkclient/InMemoryConnection.java:110
Method
run
()
src/main/java/org/I0Itec/zkclient/ZkClient.java:734
Method
serialize
(Object bytes)
src/main/java/org/I0Itec/zkclient/serialize/BytesPushThroughSerializer.java:30
Method
serialize
(Object serializable)
src/main/java/org/I0Itec/zkclient/serialize/SerializableSerializer.java:41
Method
setAcl
(String path, List<ACL> acl, int version)
src/test/java/org/I0Itec/zkclient/ZkStateChangeTest.java:217
Method
setAcl
(String path, List<ACL> acl, int version)
src/main/java/org/I0Itec/zkclient/InMemoryConnection.java:400
Method
setAcl
(String path, List<ACL> acl, int version)
src/main/java/org/I0Itec/zkclient/ZkConnection.java:175
Method
setAcl
Sets the acl on path @param path @param acl List of ACL permissions to assign to the path. @throws ZkException if any ZooKeepe
src/main/java/org/I0Itec/zkclient/ZkClient.java:320
Method
setUp
()
src/test/java/org/I0Itec/zkclient/ContentWatcherTest.java:36
Method
setUp
()
src/test/java/org/I0Itec/zkclient/AbstractBaseZkClientTest.java:44
Method
setUp
()
src/test/java/org/I0Itec/zkclient/MemoryZkClientTest.java:24
Method
setUp
()
src/test/java/org/I0Itec/zkclient/InMemoryAuthTest.java:31
Method
setUp
()
src/test/java/org/I0Itec/zkclient/ZkAuthTest.java:29
Method
setUp
()
src/test/java/org/I0Itec/zkclient/AbstractAuthTest.java:41
Method
setUp
()
src/test/java/org/I0Itec/zkclient/DistributedQueueTest.java:38
Method
setUp
()
src/test/java/org/I0Itec/zkclient/SaslAuthenticatedTest.java:73
Method
setUp
()
src/test/java/org/I0Itec/zkclient/ServerZkClientTest.java:49
Method
setUp
()
src/test/java/org/I0Itec/zkclient/ZkStateChangeTest.java:45
Method
setZkSerializer
(ZkSerializer zkSerializer)
src/main/java/org/I0Itec/zkclient/ZkClient.java:160
Method
showChilds
(String path)
src/test/java/org/I0Itec/zkclient/util/ZkPathUtilTest.java:48
Method
showStructure
()
src/test/java/org/I0Itec/zkclient/testutil/ZkTestSystem.java:113
Method
tearDown
()
src/test/java/org/I0Itec/zkclient/ContentWatcherTest.java:43
Method
tearDown
()
src/test/java/org/I0Itec/zkclient/AbstractBaseZkClientTest.java:50
Method
tearDown
()
src/test/java/org/I0Itec/zkclient/MemoryZkClientTest.java:30
Method
tearDown
()
src/test/java/org/I0Itec/zkclient/InMemoryAuthTest.java:37
Method
tearDown
()
src/test/java/org/I0Itec/zkclient/ZkAuthTest.java:37
Method
tearDown
()
src/test/java/org/I0Itec/zkclient/AbstractAuthTest.java:47
Method
tearDown
()
src/test/java/org/I0Itec/zkclient/DistributedQueueTest.java:44
Method
tearDown
()
src/test/java/org/I0Itec/zkclient/SaslAuthenticatedTest.java:86
Method
tearDown
()
src/test/java/org/I0Itec/zkclient/ServerZkClientTest.java:57
Method
tearDown
()
src/test/java/org/I0Itec/zkclient/ZkStateChangeTest.java:53
Method
testAuthFailure
Tests that ZkClient throws an exception in the case ZooKeeper keeps dropping the connection due to authentication failures. @throws IOException
src/test/java/org/I0Itec/zkclient/SaslAuthenticatedTest.java:131
Method
testAuthFailure_AllowFailedSasl
Tests that ZkClient spots the AuthFailed event in the case the property to allow failed SASL connections is enabled. @throws IOException
src/test/java/org/I0Itec/zkclient/SaslAuthenticatedTest.java:147
Method
testAuthFailure_DisabledSasl
Tests that ZkClient spots the AuthFailed event in the case the property to allow failed SASL connections is enabled. @throws IOException
src/test/java/org/I0Itec/zkclient/SaslAuthenticatedTest.java:166
Method
testAuthorized
()
src/test/java/org/I0Itec/zkclient/InMemoryAuthTest.java:43
Method
testAuthorized
()
src/test/java/org/I0Itec/zkclient/ZkAuthTest.java:47
Method
testBadAuth
()
src/test/java/org/I0Itec/zkclient/AbstractAuthTest.java:52
Method
testBytes
()
src/test/java/org/I0Itec/zkclient/ZkClientSerializationTest.java:34
Method
testChildListenerAfterSessionExpiredException
()
src/test/java/org/I0Itec/zkclient/ServerZkClientTest.java:223
Method
testConnection
Tests that a connection authenticates successfully. @throws IOException
src/test/java/org/I0Itec/zkclient/SaslAuthenticatedTest.java:118
Method
testConnectionTimeout
()
src/test/java/org/I0Itec/zkclient/ServerZkClientTest.java:65
Method
testCountChildren
()
src/test/java/org/I0Itec/zkclient/ServerZkClientTest.java:279
Method
testCreateWithParentDirs
()
src/test/java/org/I0Itec/zkclient/ServerZkClientTest.java:332
Method
testDataChanges1
()
src/test/java/org/I0Itec/zkclient/AbstractBaseZkClientTest.java:136
Method
testDataChanges2
()
src/test/java/org/I0Itec/zkclient/AbstractBaseZkClientTest.java:169
Method
testDelete
()
src/test/java/org/I0Itec/zkclient/AbstractBaseZkClientTest.java:74
← previous
next →
201–300 of 343, ranked by callers