- 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
-
- getRequestTransactionCount() - Method in class org.apache.curator.drivers.OperationTrace
-
- getResponseBytesLength() - Method in class org.apache.curator.drivers.OperationTrace
-
- getResponseChildrenCount() - 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.
- 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.
- scheduleAtFixedRate(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 period; that is executions will commence after initialDelay then initialDelay+period, then initialDelay + 2 * period, and so
on.
- 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
-
- setRequestTransactionCount(int) - 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
-
- setResponseChildrenCount(int) - 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
-
- 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.