A B C D E F G H I K M N O Q R S T U W Z

A

acquireSemaphore(Semaphore) - Method in class org.apache.curator.test.compatibility.Timing2

Wait on the given semaphore

acquireSemaphore(Semaphore, int) - Method in class org.apache.curator.test.compatibility.Timing2

Wait on the given semaphore

acquireSemaphore(Semaphore) - Method in class org.apache.curator.test.Timing

Wait on the given semaphore

acquireSemaphore(Semaphore, int) - Method in class org.apache.curator.test.Timing

Wait on the given semaphore

awaitLatch(CountDownLatch) - Method in class org.apache.curator.test.compatibility.Timing2

Wait on the given latch

awaitLatch(CountDownLatch) - Method in class org.apache.curator.test.Timing

Wait on the given latch

awaitTermination(long, TimeUnit) - Method in class org.apache.curator.test.DelegatingExecutorService

B

BaseClassForTests - Class in org.apache.curator.test

BaseClassForTests() - Constructor for class org.apache.curator.test.BaseClassForTests

bindInstance(int, int) - Method in class org.apache.curator.test.QuorumConfigBuilder

buildConfig() - Method in class org.apache.curator.test.QuorumConfigBuilder

buildConfig(int) - Method in class org.apache.curator.test.QuorumConfigBuilder

buildConfig(int, int) - Method in class org.apache.curator.test.QuorumConfigBuilder

buildConfig() - Method in class org.apache.curator.test.QuorumPeerConfigBuilder

buildConfigProperties(int) - Method in class org.apache.curator.test.QuorumConfigBuilder

buildConfigProperties(int, int) - Method in class org.apache.curator.test.QuorumConfigBuilder

buildProperties() - Method in class org.apache.curator.test.QuorumPeerConfigBuilder

C

close() - Method in class org.apache.curator.test.QuorumConfigBuilder

close() - Method in class org.apache.curator.test.TestingCluster

Shutdown the ensemble, free resources, etc.

close() - Method in class org.apache.curator.test.TestingServer

Close the server and any open clients and delete the temp directory

close() - Method in class org.apache.curator.test.TestingZooKeeperMain

close() - Method in class org.apache.curator.test.TestingZooKeeperServer

close() - Method in class org.apache.curator.test.ZooKeeperServerEmbeddedAdapter

Compatibility - Class in org.apache.curator.test

Compatibility() - Constructor for class org.apache.curator.test.Compatibility

connection() - Method in class org.apache.curator.test.compatibility.Timing2

Return the value to use for ZK connection timeout

connection() - Method in class org.apache.curator.test.Timing

Return the value to use for ZK connection timeout

createAndStartCluster(int) - Method in class org.apache.curator.test.BaseClassForTests

createServer() - Method in class org.apache.curator.test.BaseClassForTests

createTempDirectory() - Static method in class org.apache.curator.test.DirectoryUtils

CuratorTestBase - Class in org.apache.curator.test.compatibility

CuratorTestBase() - Constructor for class org.apache.curator.test.compatibility.CuratorTestBase

D

DelegatingExecutorService - Class in org.apache.curator.test

DelegatingExecutorService(ExecutorService) - Constructor for class org.apache.curator.test.DelegatingExecutorService

deleteDataDirectoryOnClose() - Method in class org.apache.curator.test.InstanceSpec

deleteDirectoryContents(File) - Static method in class org.apache.curator.test.DirectoryUtils

deleteRecursively(File) - Static method in class org.apache.curator.test.DirectoryUtils

DirectoryUtils - Class in org.apache.curator.test

DirectoryUtils() - Constructor for class org.apache.curator.test.DirectoryUtils

E

equals(Object) - Method in class org.apache.curator.test.InstanceSpec

execute(Runnable) - Method in class org.apache.curator.test.DelegatingExecutorService

execute(Runnable) - Method in class org.apache.curator.test.ExecuteCalledWatchingExecutorService

ExecuteCalledWatchingExecutorService - Class in org.apache.curator.test

ExecuteCalledWatchingExecutorService(ExecutorService) - Constructor for class org.apache.curator.test.ExecuteCalledWatchingExecutorService

F

FailedServerStartException - Exception in org.apache.curator.test

FailedServerStartException(Throwable) - Constructor for exception org.apache.curator.test.FailedServerStartException

FailedServerStartException(String) - Constructor for exception org.apache.curator.test.FailedServerStartException

findConnectionInstance(ZooKeeper) - Method in class org.apache.curator.test.TestingCluster

Given a ZooKeeper instance, returns which server it is connected to

forSessionSleep() - Method in class org.apache.curator.test.compatibility.Timing2

Return a new timing with a multiple that ensures a ZK session timeout

forSleepingABit() - Method in class org.apache.curator.test.compatibility.Timing2

Return a new timing with a multiple for sleeping a smaller amount of time

forWaiting() - Method in class org.apache.curator.test.compatibility.Timing2

Return a new timing with the standard multiple for waiting on latches, etc.

forWaiting() - Method in class org.apache.curator.test.Timing

Return a new timing with the standard multiple for waiting on latches, etc.

G

getChildWatches(ZooKeeper) - Static method in class org.apache.curator.test.WatchersDebug

getClientPort() - Method in class org.apache.curator.test.TestingZooKeeperMain

getClientPort() - Method in class org.apache.curator.test.ZooKeeperServerEmbeddedAdapter

getConnectString() - Method in class org.apache.curator.test.InstanceSpec

Deprecated.

use TestingServer.getConnectString() or TestingCluster.getConnectString() instead

getConnectString() - Method in class org.apache.curator.test.TestingCluster

Returns the connection string to pass to the ZooKeeper constructor

getConnectString() - Method in class org.apache.curator.test.TestingServer

Returns the connection string to use

getCustomProperties() - Method in class org.apache.curator.test.InstanceSpec

getDataDirectory() - Method in class org.apache.curator.test.InstanceSpec

getDataWatches(ZooKeeper) - Static method in class org.apache.curator.test.WatchersDebug

getElectionPort() - Method in class org.apache.curator.test.InstanceSpec

getExistWatches(ZooKeeper) - Static method in class org.apache.curator.test.WatchersDebug

getFirstProcessor() - Method in class org.apache.curator.test.TestingZooKeeperMain.TestZooKeeperServer

getHostname() - Method in class org.apache.curator.test.InstanceSpec

getInstances() - Method in class org.apache.curator.test.TestingCluster

Returns the set of servers in the ensemble

getInstanceSpec(int) - Method in class org.apache.curator.test.QuorumConfigBuilder

getInstanceSpec() - Method in class org.apache.curator.test.QuorumPeerConfigBuilder

getInstanceSpec() - Method in class org.apache.curator.test.TestingZooKeeperServer

getInstanceSpecs() - Method in class org.apache.curator.test.QuorumConfigBuilder

getInstanceSpecs() - Method in class org.apache.curator.test.TestingZooKeeperServer

getLocalPort() - Method in class org.apache.curator.test.TestingZooKeeperServer

getMaxClientCnxns() - Method in class org.apache.curator.test.InstanceSpec

getPort() - Method in class org.apache.curator.test.InstanceSpec

getPort() - Method in class org.apache.curator.test.TestingServer

Return the port being used or will be used.

getQuorumPort() - Method in class org.apache.curator.test.InstanceSpec

getRandomPort() - Static method in class org.apache.curator.test.InstanceSpec

getServerCnxnFactory() - Method in class org.apache.curator.test.ZooKeeperServerEmbeddedAdapter

getServerId() - Method in class org.apache.curator.test.InstanceSpec

getServers() - Method in class org.apache.curator.test.TestingCluster

getTempDirectory() - Method in class org.apache.curator.test.TestingServer

Returns the temp directory being used

getTickTime() - Method in class org.apache.curator.test.InstanceSpec

H

hashCode() - Method in class org.apache.curator.test.InstanceSpec

I

InstanceSpec - Class in org.apache.curator.test

Abstracts one of the servers in the ensemble

InstanceSpec(File, int, int, int, boolean, int) - Constructor for class org.apache.curator.test.InstanceSpec

InstanceSpec(File, int, int, int, boolean, int, int, int) - Constructor for class org.apache.curator.test.InstanceSpec

InstanceSpec(File, int, int, int, boolean, int, int, int, Map<String, Object>) - Constructor for class org.apache.curator.test.InstanceSpec

InstanceSpec(File, int, int, int, boolean, int, int, int, Map<String, Object>, String) - Constructor for class org.apache.curator.test.InstanceSpec

invokeAll(Collection<? extends Callable<T>>) - Method in class org.apache.curator.test.DelegatingExecutorService

invokeAll(Collection<? extends Callable<T>>, long, TimeUnit) - Method in class org.apache.curator.test.DelegatingExecutorService

invokeAny(Collection<? extends Callable<T>>) - Method in class org.apache.curator.test.DelegatingExecutorService

invokeAny(Collection<? extends Callable<T>>, long, TimeUnit) - Method in class org.apache.curator.test.DelegatingExecutorService

isExecuteCalled() - Method in class org.apache.curator.test.ExecuteCalledWatchingExecutorService

isFromRandom() - Method in class org.apache.curator.test.QuorumConfigBuilder

isFromRandom() - Method in class org.apache.curator.test.QuorumPeerConfigBuilder

isRunning() - Method in class org.apache.curator.test.TestingZooKeeperMain.TestZooKeeperServer

isShutdown() - Method in class org.apache.curator.test.DelegatingExecutorService

isTerminated() - Method in class org.apache.curator.test.DelegatingExecutorService

K

kill(ZooKeeper) - Static method in class org.apache.curator.test.KillSession

Kill the given ZK session

kill(ZooKeeper, String) - Static method in class org.apache.curator.test.KillSession

Deprecated.

use KillSession.kill(ZooKeeper) instead

kill(ZooKeeper, String, int) - Static method in class org.apache.curator.test.KillSession

Deprecated.

use KillSession.kill(ZooKeeper) instead

kill() - Method in class org.apache.curator.test.TestingZooKeeperMain

kill() - Method in class org.apache.curator.test.TestingZooKeeperServer

kill() - Method in class org.apache.curator.test.ZooKeeperServerEmbeddedAdapter

killServer(InstanceSpec) - Method in class org.apache.curator.test.TestingCluster

Kills the given server.

KillSession - Class in org.apache.curator.test

Utility to simulate a ZK session dying.

KillSession() - Constructor for class org.apache.curator.test.KillSession

M

makeSpecs(int) - Static method in class org.apache.curator.test.TestingCluster

makeSpecs(int, boolean) - Static method in class org.apache.curator.test.TestingCluster

milliseconds() - Method in class org.apache.curator.test.compatibility.Timing2

Return the base time in milliseconds

milliseconds() - Method in class org.apache.curator.test.Timing

Return the base time in milliseconds

multiple(double) - Method in class org.apache.curator.test.compatibility.Timing2

Return a new timing that is a multiple of the this timing

multiple(double, int) - Method in class org.apache.curator.test.compatibility.Timing2

Return a new timing that is a multiple of the this timing

multiple(double) - Method in class org.apache.curator.test.Timing

Return a new timing that is a multiple of the this timing

N

newInstanceSpec() - Static method in class org.apache.curator.test.InstanceSpec

noteStartup() - Method in class org.apache.curator.test.TestingZooKeeperMain.TestZooKeeperServer

O

org.apache.curator.test - package org.apache.curator.test

org.apache.curator.test.compatibility - package org.apache.curator.test.compatibility

Q

QuorumConfigBuilder - Class in org.apache.curator.test

QuorumConfigBuilder(Collection<InstanceSpec>) - Constructor for class org.apache.curator.test.QuorumConfigBuilder

QuorumConfigBuilder(InstanceSpec...) - Constructor for class org.apache.curator.test.QuorumConfigBuilder

QuorumPeerConfigBuilder - Class in org.apache.curator.test

R

registerJMX() - Method in class org.apache.curator.test.TestingZooKeeperMain.TestZooKeeperServer

reset() - Static method in class org.apache.curator.test.InstanceSpec

restart() - Method in class org.apache.curator.test.TestingServer

Restart the server.

restart() - Method in class org.apache.curator.test.TestingZooKeeperServer

Restart the server.

restartServer(InstanceSpec) - Method in class org.apache.curator.test.TestingCluster

Restart the given server of the cluster

S

seconds() - Method in class org.apache.curator.test.compatibility.Timing2

Return the base time in seconds

seconds() - Method in class org.apache.curator.test.Timing

Return the base time in seconds

server - Variable in class org.apache.curator.test.BaseClassForTests

serverCnxnClose(ServerCnxn) - Static method in class org.apache.curator.test.Compatibility

serverCnxnFactoryCloseAll(ServerCnxnFactory) - Static method in class org.apache.curator.test.Compatibility

session() - Method in class org.apache.curator.test.compatibility.Timing2

Return the value to use for ZK session timeout

session() - Method in class org.apache.curator.test.Timing

Return the value to use for ZK session timeout

setExecuteCalled(boolean) - Method in class org.apache.curator.test.ExecuteCalledWatchingExecutorService

setState(ZooKeeperServer.State) - Method in class org.apache.curator.test.TestingZooKeeperMain.TestZooKeeperServer

setup() - Method in class org.apache.curator.test.BaseClassForTests

shutdown() - Method in class org.apache.curator.test.DelegatingExecutorService

shutdown(boolean) - Method in class org.apache.curator.test.TestingZooKeeperMain.TestZooKeeperServer

shutdownNow() - Method in class org.apache.curator.test.DelegatingExecutorService

size() - Method in class org.apache.curator.test.QuorumConfigBuilder

sleep() - Method in class org.apache.curator.test.compatibility.Timing2

Sleep for a the full amount of time

sleepABit() - Method in class org.apache.curator.test.compatibility.Timing2

Sleep for a small amount of time

sleepABit() - Method in class org.apache.curator.test.Timing

Sleep for a small amount of time

start() - Method in class org.apache.curator.test.TestingCluster

Start the ensemble.

start() - Method in class org.apache.curator.test.TestingServer

Start the server

start(QuorumPeerConfigBuilder) - Method in class org.apache.curator.test.TestingZooKeeperMain

start() - Method in class org.apache.curator.test.TestingZooKeeperServer

start(QuorumPeerConfigBuilder) - Method in class org.apache.curator.test.ZooKeeperServerEmbeddedAdapter

stop() - Method in class org.apache.curator.test.TestingCluster

Shutdown the ensemble WITHOUT freeing resources, etc.

stop() - Method in class org.apache.curator.test.TestingServer

Stop the server without deleting the temp directory

stop() - Method in class org.apache.curator.test.TestingZooKeeperServer

submit(Callable<T>) - Method in class org.apache.curator.test.DelegatingExecutorService

submit(Runnable, T) - Method in class org.apache.curator.test.DelegatingExecutorService

submit(Runnable) - Method in class org.apache.curator.test.DelegatingExecutorService

T

takeFromQueue(BlockingQueue<T>) - Method in class org.apache.curator.test.compatibility.Timing2

Try to take an item from the given queue

teardown() - Method in class org.apache.curator.test.BaseClassForTests

TestingCluster - Class in org.apache.curator.test

manages an internally running ensemble of ZooKeeper servers.

TestingCluster(int) - Constructor for class org.apache.curator.test.TestingCluster

Creates an ensemble comprised of n servers.

TestingCluster(InstanceSpec...) - Constructor for class org.apache.curator.test.TestingCluster

Creates an ensemble using the given server specs

TestingCluster(Collection<InstanceSpec>) - Constructor for class org.apache.curator.test.TestingCluster

Creates an ensemble using the given server specs

TestingCluster(Map<InstanceSpec, Collection<InstanceSpec>>) - Constructor for class org.apache.curator.test.TestingCluster

Creates an ensemble using the given server specs

TestingServer - Class in org.apache.curator.test

manages an internally running ZooKeeper server.

TestingServer() - Constructor for class org.apache.curator.test.TestingServer

Create the server using a random port

TestingServer(boolean) - Constructor for class org.apache.curator.test.TestingServer

Create the server using a random port

TestingServer(int) - Constructor for class org.apache.curator.test.TestingServer

Create and start the server using the given port

TestingServer(int, boolean) - Constructor for class org.apache.curator.test.TestingServer

Create the server using the given port

TestingServer(int, File) - Constructor for class org.apache.curator.test.TestingServer

Create and start the server using the given port

TestingServer(int, File, boolean) - Constructor for class org.apache.curator.test.TestingServer

Create the server using the given port

TestingServer(InstanceSpec, boolean) - Constructor for class org.apache.curator.test.TestingServer

Create the server using the given port

TestingZooKeeperMain - Class in org.apache.curator.test

TestingZooKeeperMain() - Constructor for class org.apache.curator.test.TestingZooKeeperMain

TestingZooKeeperMain.TestZooKeeperServer - Class in org.apache.curator.test

TestingZooKeeperServer - Class in org.apache.curator.test

Thanks to Jeremie BORDIER (ahfeel) for this code

TestingZooKeeperServer(QuorumConfigBuilder) - Constructor for class org.apache.curator.test.TestingZooKeeperServer

TestingZooKeeperServer(QuorumConfigBuilder, int) - Constructor for class org.apache.curator.test.TestingZooKeeperServer

TestZooKeeperServer(FileTxnSnapLog, ServerConfig) - Constructor for class org.apache.curator.test.TestingZooKeeperMain.TestZooKeeperServer

tickTime() - Method in class org.apache.curator.test.compatibility.Timing2

Value to use for server "tickTime"

timing - Variable in class org.apache.curator.test.compatibility.CuratorTestBase

Timing - Class in org.apache.curator.test

Utility to get various testing times

Timing() - Constructor for class org.apache.curator.test.Timing

Use the default base time

Timing(double) - Constructor for class org.apache.curator.test.Timing

Use a multiple of the default base time

Timing(double, int) - Constructor for class org.apache.curator.test.Timing

Use a multiple of the default base time

Timing(long, TimeUnit) - Constructor for class org.apache.curator.test.Timing

Timing(long, TimeUnit, int) - Constructor for class org.apache.curator.test.Timing

Timing2 - Class in org.apache.curator.test.compatibility

Utility to get various testing times.

Timing2() - Constructor for class org.apache.curator.test.compatibility.Timing2

Use the default base time

Timing2(double) - Constructor for class org.apache.curator.test.compatibility.Timing2

Use a multiple of the default base time

Timing2(double, int) - Constructor for class org.apache.curator.test.compatibility.Timing2

Use a multiple of the default base time

Timing2(long, TimeUnit) - Constructor for class org.apache.curator.test.compatibility.Timing2

Timing2(long, TimeUnit, int) - Constructor for class org.apache.curator.test.compatibility.Timing2

toString() - Method in class org.apache.curator.test.InstanceSpec

U

unregisterJMX() - Method in class org.apache.curator.test.TestingZooKeeperMain.TestZooKeeperServer

W

WatchersDebug - Class in org.apache.curator.test

Z

zk35TestCompatibilityGroup - Static variable in class org.apache.curator.test.compatibility.CuratorTestBase

zk36Group - Static variable in class org.apache.curator.test.compatibility.CuratorTestBase

zk37Group - Static variable in class org.apache.curator.test.compatibility.CuratorTestBase

ZooKeeperServerEmbeddedAdapter - Class in org.apache.curator.test

ZooKeeperServerEmbeddedAdapter() - Constructor for class org.apache.curator.test.ZooKeeperServerEmbeddedAdapter

A B C D E F G H I K M N O Q R S T U W Z