MCPcopy Create free account

hub / github.com/sgroschupf/zkclient / functions

Functions343 in github.com/sgroschupf/zkclient

MethodcreateZkClient
()
src/test/java/org/I0Itec/zkclient/testutil/ZkTestSystem.java:109
Methoddelete
(String path)
src/test/java/org/I0Itec/zkclient/ZkStateChangeTest.java:157
Methoddelete
(String path)
src/main/java/org/I0Itec/zkclient/ZkConnection.java:103
Methoddeserialize
(byte[] bytes)
src/main/java/org/I0Itec/zkclient/serialize/BytesPushThroughSerializer.java:25
Methoddeserialize
(byte[] bytes)
src/main/java/org/I0Itec/zkclient/serialize/SerializableSerializer.java:28
Methodexists
(final String path, final boolean watch)
src/test/java/org/I0Itec/zkclient/ZkStateChangeTest.java:167
Methodexists
(String path, boolean watch)
src/main/java/org/I0Itec/zkclient/ZkConnection.java:113
MethodgetAcl
(String path)
src/test/java/org/I0Itec/zkclient/ZkStateChangeTest.java:222
MethodgetAcl
(String path)
src/main/java/org/I0Itec/zkclient/InMemoryConnection.java:421
MethodgetAcl
(String path)
src/main/java/org/I0Itec/zkclient/ZkConnection.java:180
MethodgetAcl
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
MethodgetChildren
(final String path, final boolean watch)
src/test/java/org/I0Itec/zkclient/ZkStateChangeTest.java:172
MethodgetChildren
(final String path, final boolean watch)
src/main/java/org/I0Itec/zkclient/ZkConnection.java:118
MethodgetCreateTime
(String path)
src/test/java/org/I0Itec/zkclient/ZkStateChangeTest.java:197
MethodgetCreateTime
(String path)
src/main/java/org/I0Itec/zkclient/InMemoryConnection.java:356
MethodgetCreateTime
(String path)
src/main/java/org/I0Itec/zkclient/ZkConnection.java:151
MethodgetDataListener
(String path)
src/main/java/org/I0Itec/zkclient/ZkClient.java:878
MethodgetLocalhostName
()
src/main/java/org/I0Itec/zkclient/NetworkUtil.java:111
MethodgetServers
()
src/test/java/org/I0Itec/zkclient/ZkStateChangeTest.java:202
MethodgetServers
()
src/main/java/org/I0Itec/zkclient/InMemoryConnection.java:365
MethodgetZkClient
()
src/main/java/org/I0Itec/zkclient/ZkServer.java:179
MethodgetZookeeper
()
src/main/java/org/I0Itec/zkclient/ZkConnection.java:147
MethodgetZookeeperState
()
src/test/java/org/I0Itec/zkclient/ZkStateChangeTest.java:192
MethodgetZookeeperState
()
src/main/java/org/I0Itec/zkclient/IZkConnection.java:54
MethodgetZookeeperState
()
src/main/java/org/I0Itec/zkclient/InMemoryConnection.java:285
MethodgetZookeeperState
()
src/main/java/org/I0Itec/zkclient/ZkConnection.java:142
MethodhandleChildChange
(String parentPath, List<String> currentChilds)
src/test/java/org/I0Itec/zkclient/AbstractBaseZkClientTest.java:256
MethodhandleChildChange
(String parentPath, List<String> currentChilds)
src/test/java/org/I0Itec/zkclient/ServerZkClientTest.java:238
MethodhandleDataChange
(String dataPath, Object data)
src/test/java/org/I0Itec/zkclient/AbstractBaseZkClientTest.java:144
MethodhandleDataChange
(String dataPath, Object data)
src/main/java/org/I0Itec/zkclient/ContentWatcher.java:76
MethodhandleDataDeleted
(String dataPath)
src/test/java/org/I0Itec/zkclient/AbstractBaseZkClientTest.java:149
MethodhandleDataDeleted
(String dataPath)
src/main/java/org/I0Itec/zkclient/ContentWatcher.java:82
MethodhandleNewSession
()
src/test/java/org/I0Itec/zkclient/ZkStateChangeTest.java:240
MethodhandleSessionEstablishmentError
(final Throwable error)
src/test/java/org/I0Itec/zkclient/ZkStateChangeTest.java:245
MethodhandleStateChanged
(KeeperState state)
src/test/java/org/I0Itec/zkclient/ZkStateChangeTest.java:233
MethodhostNameInArray
(final String[] hostNames, final String hostName)
src/main/java/org/I0Itec/zkclient/NetworkUtil.java:83
Methodmulti
(Iterable<Op> ops)
src/test/java/org/I0Itec/zkclient/ZkStateChangeTest.java:207
Methodmulti
(Iterable<Op> ops)
src/main/java/org/I0Itec/zkclient/InMemoryConnection.java:370
Methodmulti
(Iterable<Op> ops)
src/main/java/org/I0Itec/zkclient/ZkConnection.java:165
Methodmulti
(final Iterable<Op> ops)
src/main/java/org/I0Itec/zkclient/ZkClient.java:1318
MethodreadData
(String path, Stat stat, boolean watch)
src/test/java/org/I0Itec/zkclient/ZkStateChangeTest.java:177
MethodreadData
(String path, Stat stat, boolean watch)
src/main/java/org/I0Itec/zkclient/InMemoryConnection.java:298
MethodreadData
(String path, Stat stat, boolean watch)
src/main/java/org/I0Itec/zkclient/ZkConnection.java:123
MethodresolveClass
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
MethodresolveProxyClass
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
MethodrethrowInterruptedException
(Throwable e)
src/main/java/org/I0Itec/zkclient/ExceptionUtil.java:43
Methodrun
()
src/test/java/org/I0Itec/zkclient/ContentWatcherTest.java:80
Methodrun
()
src/test/java/org/I0Itec/zkclient/AbstractBaseZkClientTest.java:117
Methodrun
()
src/test/java/org/I0Itec/zkclient/DeferredGatewayStarter.java:28
Methodrun
()
src/test/java/org/I0Itec/zkclient/DistributedQueueTest.java:100
Methodrun
()
src/test/java/org/I0Itec/zkclient/ServerZkClientTest.java:121
Methodrun
()
src/test/java/org/I0Itec/zkclient/ZkStateChangeTest.java:127
Methodrun
()
src/main/java/org/I0Itec/zkclient/GatewayThread.java:52
Methodrun
()
src/main/java/org/I0Itec/zkclient/ZkEventThread.java:63
Methodrun
()
src/main/java/org/I0Itec/zkclient/InMemoryConnection.java:110
Methodrun
()
src/main/java/org/I0Itec/zkclient/ZkClient.java:734
Methodserialize
(Object bytes)
src/main/java/org/I0Itec/zkclient/serialize/BytesPushThroughSerializer.java:30
Methodserialize
(Object serializable)
src/main/java/org/I0Itec/zkclient/serialize/SerializableSerializer.java:41
MethodsetAcl
(String path, List<ACL> acl, int version)
src/test/java/org/I0Itec/zkclient/ZkStateChangeTest.java:217
MethodsetAcl
(String path, List<ACL> acl, int version)
src/main/java/org/I0Itec/zkclient/InMemoryConnection.java:400
MethodsetAcl
(String path, List<ACL> acl, int version)
src/main/java/org/I0Itec/zkclient/ZkConnection.java:175
MethodsetAcl
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
MethodsetUp
()
src/test/java/org/I0Itec/zkclient/ContentWatcherTest.java:36
MethodsetUp
()
src/test/java/org/I0Itec/zkclient/AbstractBaseZkClientTest.java:44
MethodsetUp
()
src/test/java/org/I0Itec/zkclient/MemoryZkClientTest.java:24
MethodsetUp
()
src/test/java/org/I0Itec/zkclient/InMemoryAuthTest.java:31
MethodsetUp
()
src/test/java/org/I0Itec/zkclient/ZkAuthTest.java:29
MethodsetUp
()
src/test/java/org/I0Itec/zkclient/AbstractAuthTest.java:41
MethodsetUp
()
src/test/java/org/I0Itec/zkclient/DistributedQueueTest.java:38
MethodsetUp
()
src/test/java/org/I0Itec/zkclient/SaslAuthenticatedTest.java:73
MethodsetUp
()
src/test/java/org/I0Itec/zkclient/ServerZkClientTest.java:49
MethodsetUp
()
src/test/java/org/I0Itec/zkclient/ZkStateChangeTest.java:45
MethodsetZkSerializer
(ZkSerializer zkSerializer)
src/main/java/org/I0Itec/zkclient/ZkClient.java:160
MethodshowChilds
(String path)
src/test/java/org/I0Itec/zkclient/util/ZkPathUtilTest.java:48
MethodshowStructure
()
src/test/java/org/I0Itec/zkclient/testutil/ZkTestSystem.java:113
MethodtearDown
()
src/test/java/org/I0Itec/zkclient/ContentWatcherTest.java:43
MethodtearDown
()
src/test/java/org/I0Itec/zkclient/AbstractBaseZkClientTest.java:50
MethodtearDown
()
src/test/java/org/I0Itec/zkclient/MemoryZkClientTest.java:30
MethodtearDown
()
src/test/java/org/I0Itec/zkclient/InMemoryAuthTest.java:37
MethodtearDown
()
src/test/java/org/I0Itec/zkclient/ZkAuthTest.java:37
MethodtearDown
()
src/test/java/org/I0Itec/zkclient/AbstractAuthTest.java:47
MethodtearDown
()
src/test/java/org/I0Itec/zkclient/DistributedQueueTest.java:44
MethodtearDown
()
src/test/java/org/I0Itec/zkclient/SaslAuthenticatedTest.java:86
MethodtearDown
()
src/test/java/org/I0Itec/zkclient/ServerZkClientTest.java:57
MethodtearDown
()
src/test/java/org/I0Itec/zkclient/ZkStateChangeTest.java:53
MethodtestAuthFailure
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
MethodtestAuthFailure_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
MethodtestAuthFailure_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
MethodtestAuthorized
()
src/test/java/org/I0Itec/zkclient/InMemoryAuthTest.java:43
MethodtestAuthorized
()
src/test/java/org/I0Itec/zkclient/ZkAuthTest.java:47
MethodtestBadAuth
()
src/test/java/org/I0Itec/zkclient/AbstractAuthTest.java:52
MethodtestBytes
()
src/test/java/org/I0Itec/zkclient/ZkClientSerializationTest.java:34
MethodtestChildListenerAfterSessionExpiredException
()
src/test/java/org/I0Itec/zkclient/ServerZkClientTest.java:223
MethodtestConnection
Tests that a connection authenticates successfully. @throws IOException
src/test/java/org/I0Itec/zkclient/SaslAuthenticatedTest.java:118
MethodtestConnectionTimeout
()
src/test/java/org/I0Itec/zkclient/ServerZkClientTest.java:65
MethodtestCountChildren
()
src/test/java/org/I0Itec/zkclient/ServerZkClientTest.java:279
MethodtestCreateWithParentDirs
()
src/test/java/org/I0Itec/zkclient/ServerZkClientTest.java:332
MethodtestDataChanges1
()
src/test/java/org/I0Itec/zkclient/AbstractBaseZkClientTest.java:136
MethodtestDataChanges2
()
src/test/java/org/I0Itec/zkclient/AbstractBaseZkClientTest.java:169
MethodtestDelete
()
src/test/java/org/I0Itec/zkclient/AbstractBaseZkClientTest.java:74
← previousnext →201–300 of 343, ranked by callers