Functions — github.com/Cue/greplin-zookeeper-utils

CodeHub MCPcopy Create free account

hub / github.com/Cue/greplin-zookeeper-utils / functions

Functions36 in github.com/Cue/greplin-zookeeper-utils

⨍ Functions 36 ◇ Types & classes 5

↓ 7 callersMethodgetClient

src/main/java/com/greplin/zookeeper/RobustZooKeeper.java:128

↓ 5 callersMethodwithLock

Execute the given Runnable once we obtain the zookeeper lock with the given name. Automatically release the lock once the Runnable completes. <p/> We

src/main/java/com/greplin/zookeeper/RobustZooKeeper.java:180

↓ 4 callersMethodcheckNoRemainingLocks

(String lockName)

src/test/java/com/greplin/zookeeper/RobustZooKeeperTest.java:57

↓ 4 callersMethodgetLockParent

(String lockName)

src/main/java/com/greplin/zookeeper/RobustZooKeeper.java:151

↓ 4 callersMethodisAlive

src/main/java/com/greplin/zookeeper/RobustZooKeeper.java:81

↓ 2 callersMethodconfigure

(ZooKeeperServer zooKeeperServer, ServerConfig config)

src/main/java/com/greplin/zookeeper/EmbeddedZookeeperServer.java:122

↓ 2 callersMethodlockRecipeStepTwo

(final String fullPath, final String relativePath, final String lockName, fin

src/main/java/com/greplin/zookeeper/RobustZooKeeper.java:206

↓ 2 callersMethodshutdown

src/main/java/com/greplin/zookeeper/RobustZooKeeper.java:95

↓ 1 callersMethodbuild

Builds and returns a new EmbeddedZookeeperServer based on this Builder's configuration.

src/main/java/com/greplin/zookeeper/EmbeddedZookeeperServer.java:227

↓ 1 callersMethodbuilder

Returns a new EmbeddedZookeeperServer Builder. @return A new server builder

src/main/java/com/greplin/zookeeper/EmbeddedZookeeperServer.java:180

↓ 1 callersMethodclientPort

Sets the port for an EmbeddedZookeeperServer to listen on.

src/main/java/com/greplin/zookeeper/EmbeddedZookeeperServer.java:203

↓ 1 callersMethodgetDataDir

Returns this server's configured data directory. @return The directory this server is storing snapshots and transaction logs in

src/main/java/com/greplin/zookeeper/EmbeddedZookeeperServer.java:164

↓ 1 callersMethodgetLockNode

(String lockName)

src/main/java/com/greplin/zookeeper/RobustZooKeeper.java:155

↓ 1 callersMethodgetTickTime

This server's configured ticktime. @return This server's configured ticktime

src/main/java/com/greplin/zookeeper/EmbeddedZookeeperServer.java:172

↓ 1 callersMethodrun

src/main/java/com/greplin/zookeeper/EmbeddedZookeeperServer.java:109

Constructs a new default builder.

src/main/java/com/greplin/zookeeper/EmbeddedZookeeperServer.java:196

MethodEmbeddedZookeeperServer

Creates a new embeddable ZookeeperServer. @param clientPort The port for the server to listen for client connections one @param dataDir The direct

src/main/java/com/greplin/zookeeper/EmbeddedZookeeperServer.java:61

MethodRobustZooKeeper

(String ensembleAddresses)

src/main/java/com/greplin/zookeeper/RobustZooKeeper.java:72

Sets the data directory for an EmbeddedZookeeperServer to store files.

src/main/java/com/greplin/zookeeper/EmbeddedZookeeperServer.java:211

MethodgetClientPort

Returns the port this server is listening on. @return The port thi server is listening on

src/main/java/com/greplin/zookeeper/EmbeddedZookeeperServer.java:156

MethodgetInstanceNumber

src/main/java/com/greplin/zookeeper/RobustZooKeeper.java:270

MethodgetReconnectionCount

Get the number of times the underlying zookeeper connection has had to be reconnected. Useful for monitoring/etc @return The number of reconnections

src/main/java/com/greplin/zookeeper/RobustZooKeeper.java:91

(WatchedEvent event)

src/test/java/com/greplin/zookeeper/RobustZooKeeperTest.java:59

(WatchedEvent event)

src/main/java/com/greplin/zookeeper/RobustZooKeeper.java:66

(WatchedEvent event)

src/main/java/com/greplin/zookeeper/RobustZooKeeper.java:251

MethodprocessResult

(int rc, String path, Object ctx)

src/main/java/com/greplin/zookeeper/RobustZooKeeper.java:114

src/test/java/com/greplin/zookeeper/RobustZooKeeperTest.java:73

src/test/java/com/greplin/zookeeper/RobustZooKeeperTest.java:45

Shuts down this server instance.

src/main/java/com/greplin/zookeeper/EmbeddedZookeeperServer.java:133

src/main/java/com/greplin/zookeeper/RobustZooKeeper.java:107

src/test/java/com/greplin/zookeeper/RobustZooKeeperTest.java:51

MethodtestLockBasic

src/test/java/com/greplin/zookeeper/RobustZooKeeperTest.java:68

MethodtestLockWithClientFailure

src/test/java/com/greplin/zookeeper/RobustZooKeeperTest.java:149

MethodtestMultiClientLockContention

src/test/java/com/greplin/zookeeper/RobustZooKeeperTest.java:117

MethodtestSingleClientLockContention

src/test/java/com/greplin/zookeeper/RobustZooKeeperTest.java:86

Sets the ticktime for an EmbeddedZookeeperServer.

src/main/java/com/greplin/zookeeper/EmbeddedZookeeperServer.java:219