Skip navigation links
A B C D E F G H I M N O P R S T U V Z 

A

add(Throwable) - Method in class org.apache.curator.utils.ExceptionAccumulator
Add an exception into the accumulated exceptions.
addCount(String, int) - Method in class org.apache.curator.drivers.AdvancedTracerDriver
Deprecated.
addCount(String, int) - Method in interface org.apache.curator.drivers.TracerDriver
Add to a named counter
addCount(String, int) - Method in class org.apache.curator.utils.DefaultTracerDriver
 
addEvent(EventTrace) - Method in class org.apache.curator.drivers.AdvancedTracerDriver
Add to a named counter
addTrace(OperationTrace) - Method in class org.apache.curator.drivers.AdvancedTracerDriver
Record the given trace event
addTrace(String, long, TimeUnit) - Method in class org.apache.curator.drivers.AdvancedTracerDriver
Deprecated.
addTrace(String, long, TimeUnit) - Method in interface org.apache.curator.drivers.TracerDriver
Record the given trace event
addTrace(String, long, TimeUnit) - Method in class org.apache.curator.utils.DefaultTracerDriver
 
AdvancedTracerDriver - Class in org.apache.curator.drivers
Expose more metrics for the operations and events
AdvancedTracerDriver() - Constructor for class org.apache.curator.drivers.AdvancedTracerDriver
 
allowRetry(int, long, RetrySleeper) - Method in class org.apache.curator.retry.RetryForever
 
allowRetry(int, long, RetrySleeper) - Method in class org.apache.curator.retry.RetryUntilElapsed
 
allowRetry(int, long, RetrySleeper) - Method in interface org.apache.curator.RetryPolicy
Called when an operation has failed for some reason.
allowRetry(Throwable) - Method in interface org.apache.curator.RetryPolicy
Called when an operation has failed with a specific exception.
allowRetry(int, long, RetrySleeper) - Method in class org.apache.curator.SessionFailedRetryPolicy
 
allowRetry(Throwable) - Method in class org.apache.curator.SessionFailedRetryPolicy
 
asContainers() - Method in class org.apache.curator.utils.EnsurePath
Deprecated.
 

B

blockUntilConnectedOrTimedOut() - Method in class org.apache.curator.CuratorZookeeperClient
This method blocks until the connection to ZK succeeds.
BoundedExponentialBackoffRetry - Class in org.apache.curator.retry
Retry policy that retries a set number of times with an increasing (up to a maximum bound) sleep time between retries
BoundedExponentialBackoffRetry(int, int, int) - Constructor for class org.apache.curator.retry.BoundedExponentialBackoffRetry
 

C

callWithRetry(CuratorZookeeperClient, Callable<T>) - Static method in class org.apache.curator.RetryLoop
Convenience utility: creates a retry loop calling the given proc and retrying if needed
callWithRetry(CuratorZookeeperClient, SessionFailRetryLoop.Mode, Callable<T>) - Static method in class org.apache.curator.SessionFailRetryLoop
Convenience utility: creates a "session fail" retry loop calling the given proc
cancel(boolean) - Method in class org.apache.curator.utils.CloseableExecutorService.InternalScheduledFutureTask
 
checkInterrupted(Throwable) - Static method in class org.apache.curator.utils.ThreadUtils
 
close() - Method in class org.apache.curator.CuratorZookeeperClient
Close the client.
close(int) - Method in class org.apache.curator.CuratorZookeeperClient
Close this client object as the CuratorZookeeperClient.close() method.
close() - Method in interface org.apache.curator.ensemble.EnsembleProvider
Curator will call this method when CuratorZookeeperClient.close() is called
close() - Method in class org.apache.curator.ensemble.fixed.FixedEnsembleProvider
 
close() - Method in class org.apache.curator.SessionFailRetryLoop
Must be called in a finally handler when done with the loop
close() - Method in class org.apache.curator.utils.CloseableExecutorService
Closes any tasks currently in progress
CloseableExecutorService - Class in org.apache.curator.utils
Decoration on an ExecutorService that tracks created futures and provides a method to close futures created via this class
CloseableExecutorService(ExecutorService) - Constructor for class org.apache.curator.utils.CloseableExecutorService
 
CloseableExecutorService(ExecutorService, boolean) - Constructor for class org.apache.curator.utils.CloseableExecutorService
 
CloseableExecutorService.InternalFutureTask<T> - Class in org.apache.curator.utils
 
CloseableExecutorService.InternalScheduledFutureTask - Class in org.apache.curator.utils
 
CloseableScheduledExecutorService - Class in org.apache.curator.utils
Decoration on an ScheduledExecutorService that tracks created futures and provides a method to close futures created via this class
CloseableScheduledExecutorService(ScheduledExecutorService) - Constructor for class org.apache.curator.utils.CloseableScheduledExecutorService
 
CloseableScheduledExecutorService(ScheduledExecutorService, boolean) - Constructor for class org.apache.curator.utils.CloseableScheduledExecutorService
 
CloseableUtils - Class in org.apache.curator.utils
This class adds back functionality that was removed in Guava v16.0.
CloseableUtils() - Constructor for class org.apache.curator.utils.CloseableUtils
 
closeQuietly(Closeable) - Static method in class org.apache.curator.utils.CloseableUtils
This method has been added because Guava has removed the closeQuietly() method from Closeables in v16.0.
commit() - Method in class org.apache.curator.drivers.EventTrace
 
commit() - Method in class org.apache.curator.drivers.OperationTrace
 
commit() - Method in class org.apache.curator.TimeTrace
Record the elapsed time
Compatibility - Class in org.apache.curator.utils
Utils to help with ZK version compatibility
Compatibility() - Constructor for class org.apache.curator.utils.Compatibility
 
ConfigurableZookeeperFactory - Class in org.apache.curator.utils
Configurable ZookeeperFactory, by using org.apache.zookeeper.client.ZKClientConfig.
ConfigurableZookeeperFactory() - Constructor for class org.apache.curator.utils.ConfigurableZookeeperFactory
 
CuratorConnectionLossException - Exception in org.apache.curator
 
CuratorConnectionLossException() - Constructor for exception org.apache.curator.CuratorConnectionLossException
 
CuratorZookeeperClient - Class in org.apache.curator
A wrapper around Zookeeper that takes care of some low-level housekeeping
CuratorZookeeperClient(String, int, int, Watcher, RetryPolicy) - Constructor for class org.apache.curator.CuratorZookeeperClient
 
CuratorZookeeperClient(EnsembleProvider, int, int, Watcher, RetryPolicy) - Constructor for class org.apache.curator.CuratorZookeeperClient
 
CuratorZookeeperClient(ZookeeperFactory, EnsembleProvider, int, int, Watcher, RetryPolicy, boolean) - Constructor for class org.apache.curator.CuratorZookeeperClient
 
CuratorZookeeperClient(ZookeeperFactory, EnsembleProvider, int, int, int, Watcher, RetryPolicy, boolean) - Constructor for class org.apache.curator.CuratorZookeeperClient
 

D

DebugUtils - Class in org.apache.curator.utils
 
DefaultTracerDriver - Class in org.apache.curator.utils
Default tracer driver
DefaultTracerDriver() - Constructor for class org.apache.curator.utils.DefaultTracerDriver
 
DefaultZookeeperFactory - Class in org.apache.curator.utils
 
DefaultZookeeperFactory() - Constructor for class org.apache.curator.utils.DefaultZookeeperFactory
 
deleteChildren(ZooKeeper, String, boolean) - Static method in class org.apache.curator.utils.ZKPaths
Recursively deletes children of a node.
done() - Method in class org.apache.curator.utils.CloseableExecutorService.InternalFutureTask
 

E

EnsembleProvider - Interface in org.apache.curator.ensemble
Abstraction that provides the ZooKeeper connection string
ensure(CuratorZookeeperClient) - Method in class org.apache.curator.utils.EnsurePath
Deprecated.
First time, synchronizes and makes sure all nodes in the path are created.
EnsurePath - Class in org.apache.curator.utils
Deprecated.
Since 2.9.0 - Prefer CuratorFramework.create().creatingParentContainersIfNeeded() or CuratorFramework.exists().creatingParentContainersIfNeeded()
EnsurePath(String) - Constructor for class org.apache.curator.utils.EnsurePath
Deprecated.
 
EnsurePath(String, InternalACLProvider) - Constructor for class org.apache.curator.utils.EnsurePath
Deprecated.
 
EnsurePath(String, AtomicReference<EnsurePath.Helper>, boolean, InternalACLProvider) - Constructor for class org.apache.curator.utils.EnsurePath
Deprecated.
 
equals(Object) - Method in class org.apache.curator.utils.ZKPaths.PathAndNode
 
EventTrace - Class in org.apache.curator.drivers
 
EventTrace(String, TracerDriver) - Constructor for class org.apache.curator.drivers.EventTrace
 
EventTrace(String, TracerDriver, long) - Constructor for class org.apache.curator.drivers.EventTrace
 
ExceptionAccumulator - Class in org.apache.curator.utils
Utility to accumulate multiple potential exceptions into one that is thrown at the end
ExceptionAccumulator() - Constructor for class org.apache.curator.utils.ExceptionAccumulator
 
excludingLast() - Method in class org.apache.curator.utils.EnsurePath
Deprecated.
Returns a view of this EnsurePath instance that does not make the last node.
ExponentialBackoffRetry - Class in org.apache.curator.retry
Retry policy that retries a set number of times with increasing sleep time between retries
ExponentialBackoffRetry(int, int) - Constructor for class org.apache.curator.retry.ExponentialBackoffRetry
 
ExponentialBackoffRetry(int, int, int) - Constructor for class org.apache.curator.retry.ExponentialBackoffRetry
 
extractSequentialSuffix(String) - Static method in class org.apache.curator.utils.ZKPaths
Extracts the ten-digit suffix from a sequential znode path.

F

FixedEnsembleProvider - Class in org.apache.curator.ensemble.fixed
Standard ensemble provider that wraps a fixed connection string
FixedEnsembleProvider(String) - Constructor for class org.apache.curator.ensemble.fixed.FixedEnsembleProvider
The connection string to use
FixedEnsembleProvider(String, boolean) - Constructor for class org.apache.curator.ensemble.fixed.FixedEnsembleProvider
The connection string to use
fixForNamespace(String, String) - Static method in class org.apache.curator.utils.ZKPaths
Apply the namespace to the given path
fixForNamespace(String, String, boolean) - Static method in class org.apache.curator.utils.ZKPaths
Apply the namespace to the given path

G

get() - Method in class org.apache.curator.utils.CloseableExecutorService.InternalScheduledFutureTask
 
get(long, TimeUnit) - Method in class org.apache.curator.utils.CloseableExecutorService.InternalScheduledFutureTask
 
getAclForPath(String) - Method in interface org.apache.curator.utils.InternalACLProvider
Return the ACL list to use for the given path
getBaseSleepTimeMs() - Method in class org.apache.curator.retry.ExponentialBackoffRetry
 
getConnectionString() - Method in interface org.apache.curator.ensemble.EnsembleProvider
Return the current connection string to use.
getConnectionString() - Method in class org.apache.curator.ensemble.fixed.FixedEnsembleProvider
 
getConnectionTimeoutMs() - Method in class org.apache.curator.CuratorZookeeperClient
Return the configured connection timeout
getContainerCreateMode() - Static method in class org.apache.curator.utils.ZKPaths
 
getCurrentConnectionString() - Method in class org.apache.curator.CuratorZookeeperClient
Returns the current known connection string - not guaranteed to be correct value at any point in the future.
getDefaultAcl() - Method in interface org.apache.curator.utils.InternalACLProvider
Return the ACL list to use by default (usually ZooDefs.Ids#OPEN_ACL_UNSAFE).
getDefaultRetrySleeper() - Static method in class org.apache.curator.RetryLoop
Returns the default retry sleeper
getHostString(QuorumPeer.QuorumServer) - Static method in class org.apache.curator.utils.Compatibility
 
getInstanceIndex() - Method in class org.apache.curator.CuratorZookeeperClient
Every time a new ZooKeeper instance is allocated, the "instance index" is incremented.
getLastNegotiatedSessionTimeoutMs() - Method in class org.apache.curator.CuratorZookeeperClient
Return the most recent value of ZooKeeper.getSessionTimeout() or 0
getLatencyMs() - Method in class org.apache.curator.drivers.OperationTrace
 
getMaxSleepTimeMs() - Method in class org.apache.curator.retry.BoundedExponentialBackoffRetry
 
getName() - Method in class org.apache.curator.drivers.EventTrace
 
getName() - Method in class org.apache.curator.drivers.OperationTrace
 
getNode() - Method in class org.apache.curator.utils.ZKPaths.PathAndNode
 
getNodeFromPath(String) - Static method in class org.apache.curator.utils.ZKPaths
Given a full path, return the node name.
getPath() - Method in class org.apache.curator.drivers.OperationTrace
 
getPath() - Method in class org.apache.curator.utils.EnsurePath
Deprecated.
Returns the path being Ensured
getPath() - Method in class org.apache.curator.utils.ZKPaths.PathAndNode
 
getPathAndNode(String) - Static method in class org.apache.curator.utils.ZKPaths
Given a full path, return the node name and its path.
getProcessName(Class<?>) - Static method in class org.apache.curator.utils.ThreadUtils
 
getRequestBytesLength() - Method in class org.apache.curator.drivers.OperationTrace
 
getResponseBytesLength() - Method in class org.apache.curator.drivers.OperationTrace
 
getRetryLoop(Supplier<RetryLoop>) - Method in class org.apache.curator.connection.ThreadLocalRetryLoop
Call to get the current retry loop.
getRetryPolicy() - Method in class org.apache.curator.CuratorZookeeperClient
Return the current retry policy
getReturnCode() - Method in class org.apache.curator.drivers.OperationTrace
 
getSessionId() - Method in class org.apache.curator.drivers.EventTrace
 
getSessionId() - Method in class org.apache.curator.drivers.OperationTrace
 
getSleepTimeMs(int, long) - Method in class org.apache.curator.retry.BoundedExponentialBackoffRetry
 
getSleepTimeMs(int, long) - Method in class org.apache.curator.retry.ExponentialBackoffRetry
 
getSleepTimeMs(int, long) - Method in class org.apache.curator.retry.RetryNTimes
 
getSleepTimeMs(int, long) - Method in class org.apache.curator.retry.RetryUntilElapsed
 
getSortedChildren(ZooKeeper, String) - Static method in class org.apache.curator.utils.ZKPaths
Return the children of the given path sorted by sequence number
getStat() - Method in class org.apache.curator.drivers.OperationTrace
 
getTracerDriver() - Method in class org.apache.curator.CuratorZookeeperClient
Return the current tracing driver
getZooKeeper() - Method in class org.apache.curator.CuratorZookeeperClient
Return the managed ZK instance.

H

hasAddrField() - Static method in class org.apache.curator.utils.Compatibility
 
hasContainerSupport() - Static method in class org.apache.curator.utils.ZKPaths
Returns true if the version of ZooKeeper client in use supports containers
hasGetReachableOrOneMethod() - Static method in class org.apache.curator.utils.Compatibility
 
hashCode() - Method in class org.apache.curator.utils.ZKPaths.PathAndNode
 
hasPersistentWatchers() - Static method in class org.apache.curator.utils.Compatibility
 

I

InternalACLProvider - Interface in org.apache.curator.utils
 
internalBlockUntilConnectedOrTimedOut() - Method in class org.apache.curator.CuratorZookeeperClient
For internal use only
InternalScheduledFutureTask(ScheduledFuture<?>) - Constructor for class org.apache.curator.utils.CloseableExecutorService.InternalScheduledFutureTask
 
isCancelled() - Method in class org.apache.curator.utils.CloseableExecutorService.InternalScheduledFutureTask
 
isConnected() - Method in class org.apache.curator.CuratorZookeeperClient
Returns true if the client is current connected
isDone() - Method in class org.apache.curator.utils.CloseableExecutorService.InternalScheduledFutureTask
 
isOpen - Variable in class org.apache.curator.utils.CloseableExecutorService
 
isShutdown() - Method in class org.apache.curator.utils.CloseableExecutorService
Returns true if this executor has been shut down.
isWithWatcher() - Method in class org.apache.curator.drivers.OperationTrace
 

M

makePath(String, String) - Static method in class org.apache.curator.utils.ZKPaths
Given a parent path and a child node, create a combined full path
makePath(String, String, String...) - Static method in class org.apache.curator.utils.ZKPaths
Given a parent path and a list of children nodes, create a combined full path
markComplete() - Method in class org.apache.curator.RetryLoop
Call this when your operation has successfully completed
mkdirs(ZooKeeper, String) - Static method in class org.apache.curator.utils.ZKPaths
Make sure all the nodes in the path are created.
mkdirs(ZooKeeper, String, boolean) - Static method in class org.apache.curator.utils.ZKPaths
Make sure all the nodes in the path are created.
mkdirs(ZooKeeper, String, boolean, InternalACLProvider) - Static method in class org.apache.curator.utils.ZKPaths
Make sure all the nodes in the path are created.
mkdirs(ZooKeeper, String, boolean, InternalACLProvider, boolean) - Static method in class org.apache.curator.utils.ZKPaths
Make sure all the nodes in the path are created.

N

newFixedThreadPool(int, String) - Static method in class org.apache.curator.utils.ThreadUtils
 
newFixedThreadScheduledPool(int, String) - Static method in class org.apache.curator.utils.ThreadUtils
 
newGenericThreadFactory(String) - Static method in class org.apache.curator.utils.ThreadUtils
 
newRetryLoop() - Method in class org.apache.curator.CuratorZookeeperClient
Return a new retry loop.
newSessionFailRetryLoop(SessionFailRetryLoop.Mode) - Method in class org.apache.curator.CuratorZookeeperClient
Return a new "session fail" retry loop.
newSingleThreadExecutor(String) - Static method in class org.apache.curator.utils.ThreadUtils
 
newSingleThreadScheduledExecutor(String) - Static method in class org.apache.curator.utils.ThreadUtils
 
newThreadFactory(String) - Static method in class org.apache.curator.utils.ThreadUtils
 
newZooKeeper(String, int, Watcher, boolean, ZKClientConfig) - Method in class org.apache.curator.utils.ConfigurableZookeeperFactory
 
newZooKeeper(String, int, Watcher, boolean) - Method in class org.apache.curator.utils.DefaultZookeeperFactory
 
newZooKeeper(String, int, Watcher, boolean) - Method in class org.apache.curator.utils.NonAdminZookeeperFactory
 
newZooKeeper(String, int, Watcher, boolean) - Method in interface org.apache.curator.utils.ZookeeperFactory
Allocate a new ZooKeeper instance
newZooKeeper(String, int, Watcher, boolean, ZKClientConfig) - Method in interface org.apache.curator.utils.ZookeeperFactory
Allocate a new ZooKeeper instance
NonAdminZookeeperFactory - Class in org.apache.curator.utils
 
NonAdminZookeeperFactory() - Constructor for class org.apache.curator.utils.NonAdminZookeeperFactory
 

O

OperationTrace - Class in org.apache.curator.drivers
Used to trace the metrics of a certain Zookeeper operation.
OperationTrace(String, TracerDriver) - Constructor for class org.apache.curator.drivers.OperationTrace
 
OperationTrace(String, TracerDriver, long) - Constructor for class org.apache.curator.drivers.OperationTrace
 
org.apache.curator - package org.apache.curator
 
org.apache.curator.connection - package org.apache.curator.connection
 
org.apache.curator.drivers - package org.apache.curator.drivers
 
org.apache.curator.ensemble - package org.apache.curator.ensemble
 
org.apache.curator.ensemble.fixed - package org.apache.curator.ensemble.fixed
 
org.apache.curator.retry - package org.apache.curator.retry
 
org.apache.curator.utils - package org.apache.curator.utils
 

P

PATH_SEPARATOR - Static variable in class org.apache.curator.utils.ZKPaths
Zookeeper's path separator character.
PathAndNode(String, String) - Constructor for class org.apache.curator.utils.ZKPaths.PathAndNode
 
PathUtils - Class in org.apache.curator.utils
This class is copied from Apache ZooKeeper.
PathUtils() - Constructor for class org.apache.curator.utils.PathUtils
 
propagate() - Method in class org.apache.curator.utils.ExceptionAccumulator
If there is an accumulated exception, throw it
PROPERTY_DONT_LOG_CONNECTION_ISSUES - Static variable in class org.apache.curator.utils.DebugUtils
 
PROPERTY_LOG_EVENTS - Static variable in class org.apache.curator.utils.DebugUtils
 
PROPERTY_LOG_ONLY_FIRST_CONNECTION_ISSUE_AS_ERROR_LEVEL - Static variable in class org.apache.curator.utils.DebugUtils
 
PROPERTY_REMOVE_WATCHERS_IN_FOREGROUND - Static variable in class org.apache.curator.utils.DebugUtils
 
PROPERTY_VALIDATE_NAMESPACE_WATCHER_MAP_EMPTY - Static variable in class org.apache.curator.utils.DebugUtils
 
PROPERTY_VALIDATE_NO_REMAINING_WATCHERS - Static variable in class org.apache.curator.utils.DebugUtils
 

R

release() - Method in class org.apache.curator.connection.ThreadLocalRetryLoop
Must be called to release the retry loop.
reset() - Method in class org.apache.curator.CuratorZookeeperClient
For internal use only - reset the internally managed ZK handle
RetryForever - Class in org.apache.curator.retry
RetryPolicy implementation that always allowsRetry.
RetryForever(int) - Constructor for class org.apache.curator.retry.RetryForever
 
RetryLoop - Class in org.apache.curator
Mechanism to perform an operation on Zookeeper that is safe against disconnections and "recoverable" errors.
RetryLoop() - Constructor for class org.apache.curator.RetryLoop
 
RetryNTimes - Class in org.apache.curator.retry
Retry policy that retries a max number of times
RetryNTimes(int, int) - Constructor for class org.apache.curator.retry.RetryNTimes
 
RetryOneTime - Class in org.apache.curator.retry
A retry policy that retries only once
RetryOneTime(int) - Constructor for class org.apache.curator.retry.RetryOneTime
 
RetryPolicy - Interface in org.apache.curator
Abstracts the policy to use when retrying connections
RetrySleeper - Interface in org.apache.curator
Abstraction for retry policies to sleep
RetryUntilElapsed - Class in org.apache.curator.retry
A retry policy that retries until a given amount of time elapses
RetryUntilElapsed(int, int) - Constructor for class org.apache.curator.retry.RetryUntilElapsed
 

S

schedule(Runnable, long, TimeUnit) - Method in class org.apache.curator.utils.CloseableScheduledExecutorService
Creates and executes a one-shot action that becomes enabled after the given delay.
scheduleWithFixedDelay(Runnable, long, long, TimeUnit) - Method in class org.apache.curator.utils.CloseableScheduledExecutorService
Creates and executes a periodic action that becomes enabled first after the given initial delay, and subsequently with the given delay between the termination of one execution and the commencement of the next.
SessionFailedException() - Constructor for exception org.apache.curator.SessionFailRetryLoop.SessionFailedException
 
SessionFailedRetryPolicy - Class in org.apache.curator
RetryPolicy implementation that failed on session expired.
SessionFailedRetryPolicy(RetryPolicy) - Constructor for class org.apache.curator.SessionFailedRetryPolicy
 
SessionFailRetryLoop - Class in org.apache.curator
See RetryLoop for the main details on retry loops.
SessionFailRetryLoop.Mode - Enum in org.apache.curator
 
SessionFailRetryLoop.SessionFailedException - Exception in org.apache.curator
 
setConnectionString(String) - Method in interface org.apache.curator.ensemble.EnsembleProvider
A new connection string event was received
setConnectionString(String) - Method in class org.apache.curator.ensemble.fixed.FixedEnsembleProvider
 
setPath(String) - Method in class org.apache.curator.drivers.OperationTrace
 
setRequestBytesLength(long) - Method in class org.apache.curator.drivers.OperationTrace
 
setRequestBytesLength(String) - Method in class org.apache.curator.drivers.OperationTrace
 
setRequestBytesLength(byte[]) - Method in class org.apache.curator.drivers.OperationTrace
 
setResponseBytesLength(long) - Method in class org.apache.curator.drivers.OperationTrace
 
setResponseBytesLength(byte[]) - Method in class org.apache.curator.drivers.OperationTrace
 
setRetryPolicy(RetryPolicy) - Method in class org.apache.curator.CuratorZookeeperClient
Change the retry policy
setReturnCode(int) - Method in class org.apache.curator.drivers.OperationTrace
 
setStat(Stat) - Method in class org.apache.curator.drivers.OperationTrace
 
setTracerDriver(TracerDriver) - Method in class org.apache.curator.CuratorZookeeperClient
Change the tracing driver
setWithWatcher(boolean) - Method in class org.apache.curator.drivers.OperationTrace
 
shouldContinue() - Method in class org.apache.curator.RetryLoop
If true is returned, make an attempt at the operation
shouldContinue() - Method in class org.apache.curator.SessionFailRetryLoop
If true is returned, make an attempt at the set of operations
sleepFor(long, TimeUnit) - Method in interface org.apache.curator.RetrySleeper
Sleep for the given time
split(String) - Static method in class org.apache.curator.utils.ZKPaths
Given a full path, return the the individual parts, without slashes.
start() - Method in class org.apache.curator.CuratorZookeeperClient
Must be called after construction
start() - Method in interface org.apache.curator.ensemble.EnsembleProvider
Curator will call this method when CuratorZookeeperClient.start() is called
start() - Method in class org.apache.curator.ensemble.fixed.FixedEnsembleProvider
 
start() - Method in class org.apache.curator.SessionFailRetryLoop
SessionFailRetryLoop must be started
startAdvancedTracer(String) - Method in class org.apache.curator.CuratorZookeeperClient
Start a new advanced tracer with more metrics being recorded
startTracer(String) - Method in class org.apache.curator.CuratorZookeeperClient
Start a new tracer
submit(Callable<V>) - Method in class org.apache.curator.utils.CloseableExecutorService
Submits a value-returning task for execution and returns a Future representing the pending results of the task.
submit(Runnable) - Method in class org.apache.curator.utils.CloseableExecutorService
Submits a Runnable task for execution and returns a Future representing that task.

T

takeException(Exception) - Method in class org.apache.curator.RetryLoop
Pass any caught exceptions here
takeException(Exception) - Method in class org.apache.curator.SessionFailRetryLoop
Pass any caught exceptions here
ThreadLocalRetryLoop - Class in org.apache.curator.connection
Retry loops can easily end up getting nested which can cause exponential calls of the retry policy (see https://issues.apache.org/jira/browse/CURATOR-559).
ThreadLocalRetryLoop() - Constructor for class org.apache.curator.connection.ThreadLocalRetryLoop
 
ThreadUtils - Class in org.apache.curator.utils
 
ThreadUtils() - Constructor for class org.apache.curator.utils.ThreadUtils
 
TimeTrace - Class in org.apache.curator
Utility to time a method or portion of code
TimeTrace(String, TracerDriver) - Constructor for class org.apache.curator.TimeTrace
Create and start a timer
toString() - Method in class org.apache.curator.utils.ZKPaths.PathAndNode
 
TracerDriver - Interface in org.apache.curator.drivers
Mechanism for timing methods and recording counters

U

updateServerListEnabled() - Method in interface org.apache.curator.ensemble.EnsembleProvider
Return true if this ensemble provider supports ZooKeeper.updateServerList(String)
updateServerListEnabled() - Method in class org.apache.curator.ensemble.fixed.FixedEnsembleProvider
 

V

validatePath(String, boolean) - Static method in class org.apache.curator.utils.PathUtils
validate the provided znode path string
validatePath(String) - Static method in class org.apache.curator.utils.PathUtils
Validate the provided znode path string
valueOf(String) - Static method in enum org.apache.curator.SessionFailRetryLoop.Mode
Returns the enum constant of this type with the specified name.
values() - Static method in enum org.apache.curator.SessionFailRetryLoop.Mode
Returns an array containing the constants of this enum type, in the order they are declared.

Z

ZKPaths - Class in org.apache.curator.utils
 
ZKPaths.PathAndNode - Class in org.apache.curator.utils
 
ZookeeperFactory - Interface in org.apache.curator.utils
 
A B C D E F G H I M N O P R S T U V Z 
Skip navigation links

Copyright © 2011–2023 The Apache Software Foundation. All rights reserved.