MCPcopy Create free account

hub / github.com/sgroschupf/zkclient / functions

Functions343 in github.com/sgroschupf/zkclient

↓ 1 callersMethoddelete
(String path)
src/main/java/org/I0Itec/zkclient/InMemoryConnection.java:208
↓ 1 callersMethoddelete
(final String path)
src/main/java/org/I0Itec/zkclient/ZkClient.java:1042
↓ 1 callersMethodderializable
(byte[] data)
src/main/java/org/I0Itec/zkclient/ZkClient.java:1067
↓ 1 callersMethoddeserialize
(byte[] bytes)
src/main/java/org/I0Itec/zkclient/serialize/ZkSerializer.java:31
↓ 1 callersMethodestablishConnection
()
src/test/java/org/I0Itec/zkclient/ZkConnectionTest.java:30
↓ 1 callersMethodfireAllEvents
()
src/main/java/org/I0Itec/zkclient/ZkClient.java:663
↓ 1 callersMethodfireNewSessionEvents
()
src/main/java/org/I0Itec/zkclient/ZkClient.java:730
↓ 1 callersMethodfireSessionEstablishmentError
(final Throwable error)
src/main/java/org/I0Itec/zkclient/ZkClient.java:754
↓ 1 callersMethodfireStateChangedEvent
(final KeeperState state)
src/main/java/org/I0Itec/zkclient/ZkClient.java:742
↓ 1 callersMethodgetChildren
(String path, boolean watch)
src/main/java/org/I0Itec/zkclient/InMemoryConnection.java:257
↓ 1 callersMethodgetCreateTime
(String path)
src/main/java/org/I0Itec/zkclient/IZkConnection.java:56
↓ 1 callersMethodgetCreationTime
(String path)
src/main/java/org/I0Itec/zkclient/ZkClient.java:1247
↓ 1 callersMethodgetServerPort
()
src/test/java/org/I0Itec/zkclient/testutil/ZkTestSystem.java:105
↓ 1 callersMethodgetServers
()
src/main/java/org/I0Itec/zkclient/ZkConnection.java:160
↓ 1 callersMethodgetSmallestElement
(List<String> list)
src/main/java/org/I0Itec/zkclient/DistributedQueue.java:81
↓ 1 callersMethodhandleDataChange
(String dataPath, Object data)
src/main/java/org/I0Itec/zkclient/IZkDataListener.java:27
↓ 1 callersMethodhandleDataDeleted
(String dataPath)
src/main/java/org/I0Itec/zkclient/IZkDataListener.java:29
↓ 1 callersMethodhandleNewSession
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 callersMethodhandleSessionEstablishmentError
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 callersMethodhandleStateChanged
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 callersMethodhostNamesInList
(final String serverList, final String[] hostNames)
src/main/java/org/I0Itec/zkclient/NetworkUtil.java:68
↓ 1 callersMethodinterruptAndJoin
()
src/main/java/org/I0Itec/zkclient/GatewayThread.java:172
↓ 1 callersMethodipToString
(final byte[] bytes)
src/main/java/org/I0Itec/zkclient/NetworkUtil.java:57
↓ 1 callersMethodisPortFree
(int port)
src/main/java/org/I0Itec/zkclient/NetworkUtil.java:92
↓ 1 callersMethodisZkSaslEnabled
()
src/main/java/org/I0Itec/zkclient/ZkClient.java:890
↓ 1 callersMethodprocessDataOrChildChange
(WatchedEvent event)
src/main/java/org/I0Itec/zkclient/ZkClient.java:795
↓ 1 callersMethodprocessStateChanged
(WatchedEvent event)
src/main/java/org/I0Itec/zkclient/ZkClient.java:712
↓ 1 callersMethodreadData
()
src/main/java/org/I0Itec/zkclient/ContentWatcher.java:52
↓ 1 callersMethodreconnect
()
src/main/java/org/I0Itec/zkclient/ZkClient.java:1285
↓ 1 callersMethodretainInterruptFlag
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 callersMethodrun
()
src/test/java/org/I0Itec/zkclient/testutil/ZkTestSystem.java:83
↓ 1 callersMethodrun
()
src/main/java/org/I0Itec/zkclient/ZkEventThread.java:50
↓ 1 callersMethodserialize
(Object data)
src/main/java/org/I0Itec/zkclient/serialize/ZkSerializer.java:29
↓ 1 callersMethodsetCurrentState
(KeeperState currentState)
src/main/java/org/I0Itec/zkclient/ZkClient.java:1022
↓ 1 callersMethodsetFailOnConnect
(boolean failFlag)
src/test/java/org/I0Itec/zkclient/ZkStateChangeTest.java:138
↓ 1 callersMethodshowChilds
(String path)
src/main/java/org/I0Itec/zkclient/util/ZkPathUtil.java:70
↓ 1 callersMethodshowFolders
(OutputStream output)
src/main/java/org/I0Itec/zkclient/ZkClient.java:882
↓ 1 callersMethodstart
()
src/main/java/org/I0Itec/zkclient/ZkServer.java:78
↓ 1 callersMethodstartSingleZkServer
(final int tickTime, final File dataDir, final File dataLogDir, final int port)
src/main/java/org/I0Itec/zkclient/ZkServer.java:138
↓ 1 callersMethodstartZooKeeperServer
()
src/main/java/org/I0Itec/zkclient/ZkServer.java:100
↓ 1 callersMethodunsubscribeAll
()
src/main/java/org/I0Itec/zkclient/ZkClient.java:223
↓ 1 callersMethodunsubscribeChildChanges
(String path, IZkChildListener childListener)
src/main/java/org/I0Itec/zkclient/ZkClient.java:176
↓ 1 callersMethodunsubscribeStateChanges
(IZkStateListener stateListener)
src/main/java/org/I0Itec/zkclient/ZkClient.java:217
↓ 1 callersMethodupdate
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 callersMethodupdateDataSerialized
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 callersMethodwatchForChilds
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 callersMethodwatchForData
(final String path)
src/main/java/org/I0Itec/zkclient/ZkClient.java:1158
↓ 1 callersMethodwriteData
(String path, byte[] data, int expectedVersion)
src/main/java/org/I0Itec/zkclient/InMemoryConnection.java:320
↓ 1 callersMethodwriteData
(String path, Object object)
src/main/java/org/I0Itec/zkclient/ZkClient.java:1110
↓ 1 callersMethodwriteDataReturnStat
(String path, byte[] data, int expectedVersion)
src/main/java/org/I0Itec/zkclient/IZkConnection.java:52
↓ 1 callersMethodwriteDataReturnStat
(String path, byte[] data, int expectedVersion)
src/main/java/org/I0Itec/zkclient/InMemoryConnection.java:325
↓ 1 callersMethodwriteDataReturnStat
(final String path, Object datat, final int expectedVersion)
src/main/java/org/I0Itec/zkclient/ZkClient.java:1146
MethodAbstractConnectionTest
(IZkConnection connection)
src/test/java/org/I0Itec/zkclient/AbstractConnectionTest.java:31
MethodContentWatcher
(ZkClient zkClient, String fileName)
src/main/java/org/I0Itec/zkclient/ContentWatcher.java:41
MethodDataAndVersion
(byte[] data, int version, List<ACL> acl)
src/main/java/org/I0Itec/zkclient/InMemoryConnection.java:68
MethodDeferredGatewayStarter
(Gateway gateway, int delay)
src/test/java/org/I0Itec/zkclient/DeferredGatewayStarter.java:23
MethodDistributedQueue
(ZkClient zkClient, String root)
src/main/java/org/I0Itec/zkclient/DistributedQueue.java:48
MethodElement
(String name, T data)
src/main/java/org/I0Itec/zkclient/DistributedQueue.java:29
MethodEventThread
(Watcher watcher)
src/main/java/org/I0Itec/zkclient/InMemoryConnection.java:106
MethodGateway
(int port, int destinationPort)
src/main/java/org/I0Itec/zkclient/Gateway.java:24
MethodGatewayThread
(int port, int destinationPort)
src/main/java/org/I0Itec/zkclient/GatewayThread.java:46
MethodHolder
()
src/main/java/org/I0Itec/zkclient/Holder.java:22
MethodInMemoryConnection
()
src/main/java/org/I0Itec/zkclient/InMemoryConnection.java:126
MethodInMemoryConnectionTest
()
src/test/java/org/I0Itec/zkclient/InMemoryConnectionTest.java:21
MethodTcclAwareObjectIputStream
(InputStream in)
src/main/java/org/I0Itec/zkclient/serialize/TcclAwareObjectIputStream.java:29
MethodZkAuthFailedException
()
src/main/java/org/I0Itec/zkclient/exception/ZkAuthFailedException.java:22
MethodZkBadVersionException
()
src/main/java/org/I0Itec/zkclient/exception/ZkBadVersionException.java:24
MethodZkClient
(String serverstring)
src/main/java/org/I0Itec/zkclient/ZkClient.java:85
MethodZkConnection
(String zkServers)
src/main/java/org/I0Itec/zkclient/ZkConnection.java:52
MethodZkConnectionResolveHosts
()
src/test/java/org/I0Itec/zkclient/ZkConnectionResolveHostsTest.java:12
MethodZkConnectionTest
()
src/test/java/org/I0Itec/zkclient/ZkConnectionTest.java:26
MethodZkEvent
(String description)
src/main/java/org/I0Itec/zkclient/ZkEventThread.java:46
MethodZkEventThread
(String name)
src/main/java/org/I0Itec/zkclient/ZkEventThread.java:58
MethodZkException
()
src/main/java/org/I0Itec/zkclient/exception/ZkException.java:24
MethodZkInterruptedException
(InterruptedException e)
src/main/java/org/I0Itec/zkclient/exception/ZkInterruptedException.java:22
MethodZkMarshallingError
()
src/main/java/org/I0Itec/zkclient/exception/ZkMarshallingError.java:22
MethodZkNoNodeException
()
src/main/java/org/I0Itec/zkclient/exception/ZkNoNodeException.java:24
MethodZkNodeExistsException
()
src/main/java/org/I0Itec/zkclient/exception/ZkNodeExistsException.java:24
MethodZkServer
(String dataDir, String logDir, IDefaultNameSpace defaultNameSpace)
src/main/java/org/I0Itec/zkclient/ZkServer.java:53
MethodZkTestSystem
()
src/test/java/org/I0Itec/zkclient/testutil/ZkTestSystem.java:39
MethodZkTimeoutException
()
src/main/java/org/I0Itec/zkclient/exception/ZkTimeoutException.java:22
MethodaddAuthInfo
(String scheme, byte[] auth)
src/test/java/org/I0Itec/zkclient/ZkStateChangeTest.java:212
MethodaddAuthInfo
(String scheme, byte[] auth)
src/main/java/org/I0Itec/zkclient/InMemoryConnection.java:395
MethodaddAuthInfo
(String scheme, byte[] auth)
src/main/java/org/I0Itec/zkclient/ZkConnection.java:170
MethodaddAuthInfo
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
Methodafter
()
src/test/java/org/I0Itec/zkclient/testutil/ZkTestSystem.java:60
Methodbefore
()
src/test/java/org/I0Itec/zkclient/testutil/ZkTestSystem.java:54
Methodcall
()
src/test/java/org/I0Itec/zkclient/ContentWatcherTest.java:64
Methodcall
()
src/test/java/org/I0Itec/zkclient/AbstractBaseZkClientTest.java:160
Methodcall
()
src/test/java/org/I0Itec/zkclient/ServerZkClientTest.java:94
Methodclose
()
src/test/java/org/I0Itec/zkclient/ZkStateChangeTest.java:142
Methodclose
()
src/main/java/org/I0Itec/zkclient/InMemoryConnection.java:137
Methodclose
()
src/main/java/org/I0Itec/zkclient/ZkConnection.java:79
Methodconnect
(Watcher w)
src/test/java/org/I0Itec/zkclient/ZkStateChangeTest.java:119
Methodconnect
(Watcher watcher)
src/main/java/org/I0Itec/zkclient/InMemoryConnection.java:151
Methodconnect
(Watcher watcher)
src/main/java/org/I0Itec/zkclient/ZkConnection.java:61
Methodcreate
(String path, byte[] data, CreateMode mode)
src/test/java/org/I0Itec/zkclient/ZkStateChangeTest.java:147
Methodcreate
(String path, byte[] data, CreateMode mode)
src/main/java/org/I0Itec/zkclient/ZkConnection.java:93
MethodcreateEphemeral
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
MethodcreateEphemeralSequential
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
← previousnext →101–200 of 343, ranked by callers