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

A

acceptChild(String) - Method in class org.apache.curator.framework.recipes.cache.DefaultTreeCacheSelector
 
acceptChild(String) - Method in interface org.apache.curator.framework.recipes.cache.TreeCacheSelector
Return true if this node should be returned from the cache
ACLable<T> - Interface in org.apache.curator.framework.api
 
ACLBackgroundPathAndBytesable<T> - Interface in org.apache.curator.framework.api
 
ACLCreateModeBackgroundPathAndBytesable<T> - Interface in org.apache.curator.framework.api
 
ACLCreateModePathAndBytesable<T> - Interface in org.apache.curator.framework.api
 
ACLCreateModeStatBackgroundPathAndBytesable<T> - Interface in org.apache.curator.framework.api
 
aclList - Variable in class org.apache.curator.x.rpc.idl.structs.RpcCuratorEvent
 
ACLPathAndBytesable<T> - Interface in org.apache.curator.framework.api
 
ACLProvider - Interface in org.apache.curator.framework.api
 
aclProvider(ACLProvider) - Method in class org.apache.curator.framework.CuratorFrameworkFactory.Builder
 
acquire() - Method in interface org.apache.curator.framework.recipes.locks.InterProcessLock
Acquire the mutex - blocking until it's available.
acquire(long, TimeUnit) - Method in interface org.apache.curator.framework.recipes.locks.InterProcessLock
Acquire the mutex - blocks until it's available or the given time expires.
acquire() - Method in class org.apache.curator.framework.recipes.locks.InterProcessMultiLock
Acquire the mutex - blocking until it's available.
acquire(long, TimeUnit) - Method in class org.apache.curator.framework.recipes.locks.InterProcessMultiLock
Acquire the mutex - blocks until it's available or the given time expires.
acquire() - Method in class org.apache.curator.framework.recipes.locks.InterProcessMutex
Acquire the mutex - blocking until it's available.
acquire(long, TimeUnit) - Method in class org.apache.curator.framework.recipes.locks.InterProcessMutex
Acquire the mutex - blocks until it's available or the given time expires.
acquire() - Method in class org.apache.curator.framework.recipes.locks.InterProcessSemaphore
Deprecated.
Acquire a lease.
acquire(int) - Method in class org.apache.curator.framework.recipes.locks.InterProcessSemaphore
Deprecated.
Acquire qty leases.
acquire(long, TimeUnit) - Method in class org.apache.curator.framework.recipes.locks.InterProcessSemaphore
Deprecated.
Acquire a lease.
acquire(int, long, TimeUnit) - Method in class org.apache.curator.framework.recipes.locks.InterProcessSemaphore
Deprecated.
Acquire qty leases.
acquire() - Method in class org.apache.curator.framework.recipes.locks.InterProcessSemaphoreMutex
 
acquire(long, TimeUnit) - Method in class org.apache.curator.framework.recipes.locks.InterProcessSemaphoreMutex
 
acquire() - Method in class org.apache.curator.framework.recipes.locks.InterProcessSemaphoreV2
Acquire a lease.
acquire(int) - Method in class org.apache.curator.framework.recipes.locks.InterProcessSemaphoreV2
Acquire qty leases.
acquire(long, TimeUnit) - Method in class org.apache.curator.framework.recipes.locks.InterProcessSemaphoreV2
Acquire a lease.
acquire(int, long, TimeUnit) - Method in class org.apache.curator.framework.recipes.locks.InterProcessSemaphoreV2
Acquire qty leases.
acquireLock(InterProcessLock) - Method in class org.apache.curator.framework.recipes.locks.Locker
 
acquireLock(InterProcessLock, long, TimeUnit) - Method in class org.apache.curator.framework.recipes.locks.Locker
 
acquireLock(CuratorProjection, String, int) - Method in class org.apache.curator.x.rpc.idl.services.CuratorProjectionService
 
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
acquireSemaphore(CuratorProjection, String, int, int, int) - Method in class org.apache.curator.x.rpc.idl.services.CuratorProjectionService
 
add(Integer) - Method in class org.apache.curator.framework.recipes.atomic.DistributedAtomicInteger
Add delta to the current value and return the new value information.
add(Long) - Method in class org.apache.curator.framework.recipes.atomic.DistributedAtomicLong
Add delta to the current value and return the new value information.
add(T) - Method in interface org.apache.curator.framework.recipes.atomic.DistributedAtomicNumber
Add delta to the current value and return the new value information.
add(UriSpec.Part) - Method in class org.apache.curator.x.discovery.UriSpec
Add a part to the end of the list
add(String, CuratorFramework) - Method in class org.apache.curator.x.rpc.connections.ConnectionManager
 
Addable<T> - Interface in org.apache.curator.framework.api
 
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
addEvent(RpcCuratorEvent) - Method in class org.apache.curator.x.rpc.connections.CuratorEntry
 
addEvent(CuratorProjection, RpcCuratorEvent) - Method in class org.apache.curator.x.rpc.idl.services.CuratorProjectionService
 
adding(String...) - Method in interface org.apache.curator.framework.api.Addable
Sets one or more members that are meant to be part of the ensemble.
adding(List<String>) - Method in interface org.apache.curator.framework.api.Addable
Sets one or more members that are meant to be part of the ensemble.
additionalFilter(InstanceFilter<T>) - Method in interface org.apache.curator.x.discovery.ServiceProviderBuilder
Add an instance filter.
addListener(T) - Method in interface org.apache.curator.framework.listen.Listenable
Add the given listener.
addListener(T, Executor) - Method in interface org.apache.curator.framework.listen.Listenable
Add the given listener.
addListener(T) - Method in class org.apache.curator.framework.listen.ListenerContainer
 
addListener(T, Executor) - Method in class org.apache.curator.framework.listen.ListenerContainer
 
addListener(LeaderLatchListener) - Method in class org.apache.curator.framework.recipes.leader.LeaderLatch
Attaches a listener to this LeaderLatch
addListener(LeaderLatchListener, Executor) - Method in class org.apache.curator.framework.recipes.leader.LeaderLatch
Attaches a listener to this LeaderLatch
addListener(SharedCountListener) - Method in class org.apache.curator.framework.recipes.shared.SharedCount
 
addListener(SharedCountListener, Executor) - Method in class org.apache.curator.framework.recipes.shared.SharedCount
 
addListener(ServiceCacheListener) - Method in class org.apache.curator.x.discovery.details.ServiceCacheImpl
 
addListener(ServiceCacheListener, Executor) - Method in class org.apache.curator.x.discovery.details.ServiceCacheImpl
 
addPath(String) - Method in class org.apache.curator.framework.recipes.locks.ChildReaper
Deprecated.
Add a path to reap children from
addPath(String) - Method in class org.apache.curator.framework.recipes.locks.Reaper
Deprecated.
Add a path (using Mode.REAP_INDEFINITELY) to be checked by the reaper.
addPath(String, Reaper.Mode) - Method in class org.apache.curator.framework.recipes.locks.Reaper
Deprecated.
Add a path to be checked by the reaper.
address(String) - Method in class org.apache.curator.x.discovery.ServiceInstanceBuilder
 
address - Variable in class org.apache.curator.x.rpc.idl.discovery.DiscoveryInstance
 
AddStatConfigEnsembleable - Interface in org.apache.curator.framework.api
An non-incremental reconfiguration builder.
addStateChange(ConnectionState) - Method in class org.apache.curator.framework.state.ConnectionStateManager
Post a state change.
addThing(Object, Closer) - Method in class org.apache.curator.x.rpc.connections.CuratorEntry
 
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
 
AfterConnectionEstablished - Class in org.apache.curator.framework.recipes
Utility class to allow execution of logic once a ZooKeeper connection becomes available.
allocateQueue(CuratorFramework, String) - Method in interface org.apache.curator.framework.recipes.queue.QueueAllocator
 
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.
and() - Method in interface org.apache.curator.framework.api.transaction.CuratorTransactionBridge
Syntactic sugar to make the fluent interface more readable
asContainers() - Method in class org.apache.curator.utils.EnsurePath
Deprecated.
 
asyncContext - Variable in class org.apache.curator.x.rpc.idl.structs.CreateSpec
 
asyncContext - Variable in class org.apache.curator.x.rpc.idl.structs.DeleteSpec
 
asyncContext - Variable in class org.apache.curator.x.rpc.idl.structs.ExistsSpec
 
asyncContext - Variable in class org.apache.curator.x.rpc.idl.structs.GetChildrenSpec
 
asyncContext - Variable in class org.apache.curator.x.rpc.idl.structs.GetDataSpec
 
asyncContext - Variable in class org.apache.curator.x.rpc.idl.structs.SetDataSpec
 
AsyncCreateBuilder - Interface in org.apache.curator.x.async.api
Builder for ZNode creates
AsyncCuratorFramework - Interface in org.apache.curator.x.async
Zookeeper framework-style client that returns composable async operations that implement CompletionStage
AsyncCuratorFrameworkDsl - Interface in org.apache.curator.x.async.api
Zookeeper framework-style client
AsyncCuratorFrameworkImpl - Class in org.apache.curator.x.async.details
 
AsyncCuratorFrameworkImpl(CuratorFramework) - Constructor for class org.apache.curator.x.async.details.AsyncCuratorFrameworkImpl
 
AsyncCuratorFrameworkImpl(CuratorFrameworkImpl, Filters, WatchMode, boolean) - Constructor for class org.apache.curator.x.async.details.AsyncCuratorFrameworkImpl
 
AsyncDeleteBuilder - Interface in org.apache.curator.x.async.api
Builder for ZNode deletions
AsyncEnsemblable<T> - Interface in org.apache.curator.x.async.api
Terminal operation for config/reconfig builders
AsyncEventException - Exception in org.apache.curator.x.async
The exception type set for async watchers
AsyncEventException() - Constructor for exception org.apache.curator.x.async.AsyncEventException
 
AsyncExistsBuilder - Interface in org.apache.curator.x.async.api
Builder for ZNode exists
AsyncGetACLBuilder - Interface in org.apache.curator.x.async.api
Builder for getAcls
AsyncGetChildrenBuilder - Interface in org.apache.curator.x.async.api
Builder for getChildren()
AsyncGetConfigBuilder - Interface in org.apache.curator.x.async.api
Builder for getConfig()
AsyncGetDataBuilder - Interface in org.apache.curator.x.async.api
Builder to get ZNode data
AsyncMultiTransaction - Interface in org.apache.curator.x.async.api
Terminal operation to support multi/transactions
AsyncPathable<T> - Interface in org.apache.curator.x.async.api
Terminal operation for various builders
AsyncPathAndBytesable<T> - Interface in org.apache.curator.x.async.api
Terminal operation for various builders
AsyncReconfigBuilder - Interface in org.apache.curator.x.async.api
Builder for reconfigs
AsyncReconfigurable - Interface in org.apache.curator.framework.api
 
AsyncRemoveWatchesBuilder - Interface in org.apache.curator.x.async.api
Builder for watcher removal
AsyncResult<T> - Interface in org.apache.curator.x.async
Utility that combines the value, the ZooKeeper result code and the exception in one object allowing you to not worry about exceptional completions.
AsyncResultImpl<T> - Class in org.apache.curator.x.async.details
 
AsyncResultImpl() - Constructor for class org.apache.curator.x.async.details.AsyncResultImpl
 
AsyncResultImpl(KeeperException.Code) - Constructor for class org.apache.curator.x.async.details.AsyncResultImpl
 
AsyncResultImpl(T) - Constructor for class org.apache.curator.x.async.details.AsyncResultImpl
 
AsyncResultImpl(Throwable) - Constructor for class org.apache.curator.x.async.details.AsyncResultImpl
 
AsyncSetACLBuilder - Interface in org.apache.curator.x.async.api
Builder for setting ACLs
AsyncSetDataBuilder - Interface in org.apache.curator.x.async.api
Builder for setting ZNode data
AsyncStage<T> - Interface in org.apache.curator.x.async
A CompletionStage that is the result of most operations.
AsyncSyncBuilder - Interface in org.apache.curator.x.async.api
Builder for syncs
AsyncTransactionCheckBuilder - Interface in org.apache.curator.x.async.api
 
AsyncTransactionCreateBuilder - Interface in org.apache.curator.x.async.api
 
AsyncTransactionDeleteBuilder - Interface in org.apache.curator.x.async.api
 
AsyncTransactionOp - Interface in org.apache.curator.x.async.api
Builds operations that can be committed as a transaction via AsyncCuratorFrameworkDsl.transaction()
AsyncTransactionSetDataBuilder - Interface in org.apache.curator.x.async.api
 
AtomicStats - Class in org.apache.curator.framework.recipes.atomic
Debugging stats about operations
AtomicStats() - Constructor for class org.apache.curator.framework.recipes.atomic.AtomicStats
 
AtomicValue<T> - Interface in org.apache.curator.framework.recipes.atomic
Abstracts a value returned from one of the Atomics
attemptRevoke(CuratorFramework, String) - Static method in class org.apache.curator.framework.recipes.locks.Revoker
Utility to mark a lock for revocation.
AuthInfo - Class in org.apache.curator.framework
 
AuthInfo(String, byte[]) - Constructor for class org.apache.curator.framework.AuthInfo
 
authorization(String, byte[]) - Method in class org.apache.curator.framework.CuratorFrameworkFactory.Builder
Add connection authorization Subsequent calls to this method overwrite the prior calls.
authorization(List<AuthInfo>) - Method in class org.apache.curator.framework.CuratorFrameworkFactory.Builder
Add connection authorization.
AuthorizationConfiguration - Class in org.apache.curator.x.rpc.configuration
 
AuthorizationConfiguration() - Constructor for class org.apache.curator.x.rpc.configuration.AuthorizationConfiguration
 
autoRequeue() - Method in class org.apache.curator.framework.recipes.leader.LeaderSelector
By default, when LeaderSelectorListener.takeLeadership(CuratorFramework) returns, this instance is not requeued.
aversion - Variable in class org.apache.curator.x.rpc.idl.structs.RpcStat
 
await() - Method in class org.apache.curator.framework.recipes.leader.LeaderLatch
Causes the current thread to wait until this instance acquires leadership unless the thread is interrupted or closed.
await(long, TimeUnit) - Method in class org.apache.curator.framework.recipes.leader.LeaderLatch
Causes the current thread to wait until this instance acquires leadership unless the thread is interrupted, the specified waiting time elapses or the instance is closed.
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

Backgroundable<T> - Interface in org.apache.curator.framework.api
 
BackgroundCallback - Interface in org.apache.curator.framework.api
Functor for an async background operation
BackgroundEnsembleable<T> - Interface in org.apache.curator.framework.api
 
Backgrounding - Class in org.apache.curator.framework.imps
 
Backgrounding(BackgroundCallback, UnhandledErrorListener) - Constructor for class org.apache.curator.framework.imps.Backgrounding
 
BackgroundPathable<T> - Interface in org.apache.curator.framework.api
 
BackgroundPathableQuietlyable<T> - Interface in org.apache.curator.framework.api
 
BackgroundPathAndBytesable<T> - Interface in org.apache.curator.framework.api
 
BackgroundVersionable - Interface in org.apache.curator.framework.api
 
BaseClassForTests - Class in org.apache.curator.test
 
BaseClassForTests() - Constructor for class org.apache.curator.test.BaseClassForTests
 
basePath(String) - Method in class org.apache.curator.x.discovery.ServiceDiscoveryBuilder
Required - set the base path to store in ZK
beforeSuite(ITestContext) - Method in class org.apache.curator.test.BaseClassForTests
 
BlockingQueueConsumer<T> - Class in org.apache.curator.framework.recipes.queue
Utility - a queue consumer that provides behavior similar to a BlockingQueue
BlockingQueueConsumer(ConnectionStateListener) - Constructor for class org.apache.curator.framework.recipes.queue.BlockingQueueConsumer
Creates with capacity of Integer.MAX_VALUE
BlockingQueueConsumer(ConnectionStateListener, int) - Constructor for class org.apache.curator.framework.recipes.queue.BlockingQueueConsumer
 
BlockingQueueConsumer(ConnectionStateListener, BlockingQueue<T>) - Constructor for class org.apache.curator.framework.recipes.queue.BlockingQueueConsumer
Wrap the given blocking queue
blockUntilConnected(int, TimeUnit) - Method in interface org.apache.curator.framework.CuratorFramework
Block until a connection to ZooKeeper is available or the maxWaitTime has been exceeded
blockUntilConnected() - Method in interface org.apache.curator.framework.CuratorFramework
Block until a connection to ZooKeeper is available.
blockUntilConnected(int, TimeUnit) - Method in class org.apache.curator.framework.imps.CuratorFrameworkImpl
 
blockUntilConnected() - Method in class org.apache.curator.framework.imps.CuratorFrameworkImpl
 
blockUntilConnected(int, TimeUnit) - Method in class org.apache.curator.framework.state.ConnectionStateManager
 
blockUntilConnectedOrTimedOut() - Method in class org.apache.curator.CuratorZookeeperClient
This method blocks until the connection to ZK succeeds.
blockUntilStarted() - Method in class org.apache.curator.test.TestingZooKeeperMain
 
blockUntilStarted() - Method in interface org.apache.curator.test.ZooKeeperMainFace
 
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
 
BoundedExponentialBackoffRetryConfiguration - Class in org.apache.curator.x.rpc.configuration
 
BoundedExponentialBackoffRetryConfiguration() - Constructor for class org.apache.curator.x.rpc.configuration.BoundedExponentialBackoffRetryConfiguration
 
build() - Method in class org.apache.curator.framework.CuratorFrameworkFactory.Builder
Apply the current values and build a new CuratorFramework
build() - Method in class org.apache.curator.framework.recipes.atomic.PromotedToLock.Builder
Build the argument block
build() - Method in class org.apache.curator.framework.recipes.cache.TreeCache.Builder
Builds the TreeCache based on configured values.
build() - Method in class org.apache.curator.framework.recipes.queue.QueueSharderPolicies.Builder
 
build() - Method in class org.apache.curator.framework.schema.SchemaBuilder
Build a new schema from the currently set values
build() - Method in interface org.apache.curator.x.discovery.ServiceCacheBuilder
Return a new service cache with the current settings
build() - Method in class org.apache.curator.x.discovery.ServiceDiscoveryBuilder
Build a new service discovery with the currently set values.
build() - Method in class org.apache.curator.x.discovery.ServiceInstanceBuilder
Return a new instance with the currently set values
build() - Method in interface org.apache.curator.x.discovery.ServiceProviderBuilder
Allocate a new service provider based on the current builder settings
build() - Method in class org.apache.curator.x.discovery.UriSpec
Build into a UriSpec string
build(ServiceInstance<?>) - Method in class org.apache.curator.x.discovery.UriSpec
Build into a UriSpec string
build(Map<String, Object>) - Method in class org.apache.curator.x.discovery.UriSpec
Build into a UriSpec string
build(ServiceInstance<?>, Map<String, Object>) - Method in class org.apache.curator.x.discovery.UriSpec
Build into a UriSpec string
build() - Method in class org.apache.curator.x.rpc.configuration.BoundedExponentialBackoffRetryConfiguration
 
build() - Method in class org.apache.curator.x.rpc.configuration.ConfigurationBuilder
 
build() - Method in class org.apache.curator.x.rpc.configuration.ConnectionConfiguration
 
build() - Method in class org.apache.curator.x.rpc.configuration.ExponentialBackoffRetryConfiguration
 
build() - Method in class org.apache.curator.x.rpc.configuration.RetryNTimesConfiguration
 
build() - Method in class org.apache.curator.x.rpc.configuration.RetryPolicyConfiguration
 
buildConfig() - Method in class org.apache.curator.test.QuorumConfigBuilder
 
buildConfig(int) - Method in class org.apache.curator.test.QuorumConfigBuilder
 
buildDelayQueue() - Method in class org.apache.curator.framework.recipes.queue.QueueBuilder
Build a DistributedDelayQueue from the current builder values.
builder() - Static method in class org.apache.curator.framework.CuratorFrameworkFactory
Return a new builder that builds a CuratorFramework
builder() - Static method in class org.apache.curator.framework.recipes.atomic.PromotedToLock
Allocate a new builder
builder(CuratorFramework, QueueConsumer<T>, QueueSerializer<T>, String) - Static method in class org.apache.curator.framework.recipes.queue.QueueBuilder
Allocate a new builder
builder() - Static method in class org.apache.curator.framework.recipes.queue.QueueSharderPolicies
Allocate a new builder
builder(String) - Static method in class org.apache.curator.framework.schema.Schema
Start a builder for the given full path.
builder(Pattern) - Static method in class org.apache.curator.framework.schema.Schema
Start a builder for the given path pattern.
builder(Class<T>) - Static method in class org.apache.curator.x.discovery.ServiceDiscoveryBuilder
Return a new builder.
builder() - Static method in class org.apache.curator.x.discovery.ServiceInstance
Return a new builder.
builderForRecipe(String) - Static method in class org.apache.curator.framework.schema.Schema
Start a schema builder for a typical Curator recipe's children
builderForRecipeParent(String) - Static method in class org.apache.curator.framework.schema.Schema
Start a schema builder for a typical Curator recipe's parent node
buildIdQueue() - Method in class org.apache.curator.framework.recipes.queue.QueueBuilder
Build a DistributedIdQueue from the current builder values
buildPriorityQueue(int) - Method in class org.apache.curator.framework.recipes.queue.QueueBuilder
Build a DistributedPriorityQueue from the current builder values.
buildQueue() - Method in class org.apache.curator.framework.recipes.queue.QueueBuilder
Build a DistributedQueue from the current builder values
buildTemp() - Method in class org.apache.curator.framework.CuratorFrameworkFactory.Builder
Apply the current values and build a new temporary CuratorFramework.
buildTemp(long, TimeUnit) - Method in class org.apache.curator.framework.CuratorFrameworkFactory.Builder
Apply the current values and build a new temporary CuratorFramework.
buildUriSpec() - Method in class org.apache.curator.x.discovery.ServiceInstance
 
buildUriSpec(Map<String, Object>) - Method in class org.apache.curator.x.discovery.ServiceInstance
 

C

cache - package cache
 
cacheChanged() - Method in interface org.apache.curator.x.discovery.details.ServiceCacheListener
Called when the cache has changed (instances added/deleted, etc.)
CachedAtomicInteger - Class in org.apache.curator.framework.recipes.atomic
Uses an DistributedAtomicNumber and allocates values in chunks for better performance
CachedAtomicInteger(DistributedAtomicInteger, int) - Constructor for class org.apache.curator.framework.recipes.atomic.CachedAtomicInteger
 
CachedAtomicLong - Class in org.apache.curator.framework.recipes.atomic
Uses an DistributedAtomicNumber and allocates values in chunks for better performance
CachedAtomicLong(DistributedAtomicLong, int) - Constructor for class org.apache.curator.framework.recipes.atomic.CachedAtomicLong
 
cachedPath - Variable in class org.apache.curator.x.rpc.idl.structs.RpcPathChildrenCacheEvent
 
callWithRetry(CuratorZookeeperClient, Callable<T>) - Method in class org.apache.curator.connection.ClassicConnectionHandlingPolicy
 
callWithRetry(CuratorZookeeperClient, Callable<T>) - Method in interface org.apache.curator.connection.ConnectionHandlingPolicy
callWithRetry(CuratorZookeeperClient, Callable<T>) - Method in class org.apache.curator.connection.StandardConnectionHandlingPolicy
 
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
canBeDeleted() - Method in class org.apache.curator.framework.schema.Schema
 
canBeDeleted(boolean) - Method in class org.apache.curator.framework.schema.SchemaBuilder
 
canBeReadOnly(boolean) - Method in class org.apache.curator.framework.CuratorFrameworkFactory.Builder
 
canBeReadOnly() - Method in class org.apache.curator.framework.CuratorFrameworkFactory.Builder
 
cancel(boolean) - Method in class org.apache.curator.utils.CloseableExecutorService.InternalScheduledFutureTask
 
CancelLeadershipException - Exception in org.apache.curator.framework.recipes.leader
CancelLeadershipException() - Constructor for exception org.apache.curator.framework.recipes.leader.CancelLeadershipException
 
CancelLeadershipException(String) - Constructor for exception org.apache.curator.framework.recipes.leader.CancelLeadershipException
 
CancelLeadershipException(String, Throwable) - Constructor for exception org.apache.curator.framework.recipes.leader.CancelLeadershipException
 
CancelLeadershipException(Throwable) - Constructor for exception org.apache.curator.framework.recipes.leader.CancelLeadershipException
 
cancelStartTask() - Method in class org.apache.curator.framework.recipes.leader.LeaderLatch
 
check() - Method in interface org.apache.curator.framework.api.transaction.CuratorTransaction
Deprecated.
Start a check builder in the transaction
check() - Method in interface org.apache.curator.framework.api.transaction.TransactionOp
Start a check builder in the transaction
check() - Method in class org.apache.curator.framework.imps.TransactionOpImpl
 
check() - Method in interface org.apache.curator.x.async.api.AsyncTransactionOp
Start a check builder in the transaction
checkError() - Method in interface org.apache.curator.x.async.AsyncResult
If there was a general exception or a KeeperException a RuntimeException is thrown that wraps the exception.
checkError() - Method in class org.apache.curator.x.async.details.AsyncResultImpl
 
checkException() - Method in interface org.apache.curator.x.async.AsyncResult
If there was a general exception (but not a KeeperException) a RuntimeException is thrown that wraps the exception.
checkException() - Method in class org.apache.curator.x.async.details.AsyncResultImpl
 
checkExists() - Method in interface org.apache.curator.framework.CuratorFramework
Start an exists builder
checkExists() - Method in class org.apache.curator.framework.imps.CuratorFrameworkImpl
 
checkExists() - Method in interface org.apache.curator.x.async.api.WatchableAsyncCuratorFramework
Start an exists builder.
checkExists() - Method in class org.apache.curator.x.async.details.AsyncCuratorFrameworkImpl
 
checkInterrupted(Throwable) - Static method in class org.apache.curator.utils.ThreadUtils
 
checkTimeouts(Callable<String>, long, int, int) - Method in class org.apache.curator.connection.ClassicConnectionHandlingPolicy
 
checkTimeouts(Callable<String>, long, int, int) - Method in interface org.apache.curator.connection.ConnectionHandlingPolicy
Check timeouts.
checkTimeouts(Callable<String>, long, int, int) - Method in class org.apache.curator.connection.StandardConnectionHandlingPolicy
 
ChildData - Class in org.apache.curator.framework.recipes.cache
 
ChildData(String, Stat, byte[]) - Constructor for class org.apache.curator.framework.recipes.cache.ChildData
 
childEvent(CuratorFramework, PathChildrenCacheEvent) - Method in interface org.apache.curator.framework.recipes.cache.PathChildrenCacheListener
Called when a change has occurred
childEvent(CuratorFramework, TreeCacheEvent) - Method in interface org.apache.curator.framework.recipes.cache.TreeCacheListener
Called when a change has occurred
childEvent(CuratorFramework, PathChildrenCacheEvent) - Method in class org.apache.curator.x.discovery.details.ServiceCacheImpl
 
ChildReaper - Class in org.apache.curator.framework.recipes.locks
Deprecated.
Since 2.9.0 - Reaper/ChildReaper are no longer needed. Use CreateMode.CONTAINER. Also, all Curator recipes create container parents.
ChildReaper(CuratorFramework, String, Reaper.Mode) - Constructor for class org.apache.curator.framework.recipes.locks.ChildReaper
Deprecated.
 
ChildReaper(CuratorFramework, String, Reaper.Mode, int) - Constructor for class org.apache.curator.framework.recipes.locks.ChildReaper
Deprecated.
 
ChildReaper(CuratorFramework, String, Reaper.Mode, ScheduledExecutorService, int) - Constructor for class org.apache.curator.framework.recipes.locks.ChildReaper
Deprecated.
 
ChildReaper(CuratorFramework, String, Reaper.Mode, ScheduledExecutorService, int, String) - Constructor for class org.apache.curator.framework.recipes.locks.ChildReaper
Deprecated.
 
ChildReaper(CuratorFramework, String, Reaper.Mode, ScheduledExecutorService, int, String, Set<String>) - Constructor for class org.apache.curator.framework.recipes.locks.ChildReaper
Deprecated.
 
children - Variable in class org.apache.curator.x.rpc.idl.structs.OptionalChildrenList
 
children - Variable in class org.apache.curator.x.rpc.idl.structs.RpcCuratorEvent
 
childrenCacheEvent - Variable in class org.apache.curator.x.rpc.idl.structs.RpcCuratorEvent
 
ChildrenDeletable - Interface in org.apache.curator.framework.api
 
ClassicConnectionHandlingPolicy - Class in org.apache.curator.connection
Emulates the pre 3.0.0 Curator connection handling
ClassicConnectionHandlingPolicy() - Constructor for class org.apache.curator.connection.ClassicConnectionHandlingPolicy
 
clean() - Method in class org.apache.curator.framework.recipes.locks.LockInternals
Attempt to delete the lock node so that sequence numbers get reset
clear() - Method in class org.apache.curator.framework.listen.ListenerContainer
Remove all listeners
clear() - Method in class org.apache.curator.framework.recipes.cache.PathChildrenCache
Clears the current data without beginning a new query and without generating any events for listeners.
clearAndRefresh() - Method in class org.apache.curator.framework.recipes.cache.PathChildrenCache
Clear out current data and begin a new query on the path
clearDataBytes(String) - Method in class org.apache.curator.framework.recipes.cache.PathChildrenCache
As a memory optimization, you can clear the cached data bytes for a node.
clearDataBytes(String, int) - Method in class org.apache.curator.framework.recipes.cache.PathChildrenCache
As a memory optimization, you can clear the cached data bytes for a node.
clearWatcherReferences(Watcher) - Method in interface org.apache.curator.framework.CuratorFramework
Deprecated.
As of ZooKeeper 3.5 Curators recipes will handle removing watcher references when they are no longer used. If you write your own recipe, follow the example of Curator recipes and use CuratorFramework.newWatcherRemoveCuratorFramework() calling WatcherRemoveCuratorFramework.removeWatchers() when closing your instance.
clearWatcherReferences(Watcher) - Method in class org.apache.curator.framework.imps.CuratorFrameworkImpl
 
client(CuratorFramework) - Method in class org.apache.curator.x.discovery.ServiceDiscoveryBuilder
Required - set the client to use
close() - Method in class discovery.ExampleServer
 
close() - Method in class leader.ExampleClient
 
close() - Method in class org.apache.curator.CuratorZookeeperClient
Close the client
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.exhibitor.ExhibitorEnsembleProvider
 
close() - Method in class org.apache.curator.ensemble.fixed.FixedEnsembleProvider
 
close() - Method in interface org.apache.curator.framework.CuratorFramework
Stop the client
close() - Method in interface org.apache.curator.framework.CuratorTempFramework
Stop the client
close() - Method in class org.apache.curator.framework.imps.CuratorFrameworkImpl
 
close() - Method in class org.apache.curator.framework.imps.CuratorTempFrameworkImpl
 
close() - Method in class org.apache.curator.framework.imps.EnsembleTracker
 
close() - Method in class org.apache.curator.framework.recipes.cache.NodeCache
 
close() - Method in class org.apache.curator.framework.recipes.cache.PathChildrenCache
Close/end the cache
close() - Method in class org.apache.curator.framework.recipes.cache.TreeCache
Close/end the cache.
close() - Method in class org.apache.curator.framework.recipes.leader.LeaderLatch
Remove this instance from the leadership election.
close(LeaderLatch.CloseMode) - Method in class org.apache.curator.framework.recipes.leader.LeaderLatch
Remove this instance from the leadership election.
close() - Method in class org.apache.curator.framework.recipes.leader.LeaderSelector
Shutdown this selector and remove yourself from the leadership group
close() - Method in class org.apache.curator.framework.recipes.locks.ChildReaper
Deprecated.
 
close() - Method in interface org.apache.curator.framework.recipes.locks.Lease
Releases the lease so that other clients/processes can acquire it
close() - Method in class org.apache.curator.framework.recipes.locks.Locker
 
close() - Method in class org.apache.curator.framework.recipes.locks.Reaper
Deprecated.
 
close() - Method in class org.apache.curator.framework.recipes.nodes.GroupMember
Have thisId leave the group and stop caching membership
close() - Method in class org.apache.curator.framework.recipes.nodes.PersistentNode
 
close() - Method in class org.apache.curator.framework.recipes.queue.DistributedDelayQueue
 
close() - Method in class org.apache.curator.framework.recipes.queue.DistributedIdQueue
 
close() - Method in class org.apache.curator.framework.recipes.queue.DistributedPriorityQueue
 
close() - Method in class org.apache.curator.framework.recipes.queue.DistributedQueue
 
close() - Method in class org.apache.curator.framework.recipes.queue.QueueSharder
 
close() - Method in class org.apache.curator.framework.recipes.shared.SharedCount
 
close() - Method in class org.apache.curator.framework.recipes.shared.SharedValue
 
close() - Method in class org.apache.curator.framework.state.ConnectionStateManager
 
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.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.utils.CloseableExecutorService
Closes any tasks currently in progress
close() - Method in class org.apache.curator.x.discovery.details.ServiceCacheImpl
 
close() - Method in class org.apache.curator.x.discovery.details.ServiceDiscoveryImpl
 
close() - Method in class org.apache.curator.x.discovery.details.ServiceProviderImpl
close() - Method in class org.apache.curator.x.discovery.server.rest.InstanceCleanup
 
close() - Method in interface org.apache.curator.x.rpc.connections.Closer
 
close() - Method in class org.apache.curator.x.rpc.connections.ConnectionManager
 
close() - Method in class org.apache.curator.x.rpc.connections.CuratorEntry
 
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
 
closeCuratorProjection(CuratorProjection) - Method in class org.apache.curator.x.rpc.idl.services.CuratorProjectionService
 
closeGenericProjection(CuratorProjection, String) - Method in class org.apache.curator.x.rpc.idl.services.CuratorProjectionService
 
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.
Closer - Interface in org.apache.curator.x.rpc.connections
 
closeThing(String) - Method in class org.apache.curator.x.rpc.connections.CuratorEntry
 
commit() - Method in class org.apache.curator.drivers.EventTrace
 
commit() - Method in class org.apache.curator.drivers.OperationTrace
 
commit() - Method in interface org.apache.curator.framework.api.transaction.CuratorTransactionFinal
Commit all added operations as an atomic unit and return results for the operations.
commit() - Method in class org.apache.curator.TimeTrace
Record the elapsed time
compareAndSet(Integer, Integer) - Method in class org.apache.curator.framework.recipes.atomic.DistributedAtomicInteger
 
compareAndSet(Long, Long) - Method in class org.apache.curator.framework.recipes.atomic.DistributedAtomicLong
 
compareAndSet(T, T) - Method in interface org.apache.curator.framework.recipes.atomic.DistributedAtomicNumber
Atomically sets the value to the given updated value if the current value == the expected value.
compareAndSet(byte[], byte[]) - Method in class org.apache.curator.framework.recipes.atomic.DistributedAtomicValue
Atomically sets the value to the given updated value if the current value == the expected value.
compareTo(ChildData) - Method in class org.apache.curator.framework.recipes.cache.ChildData
Note: this class has a natural ordering that is inconsistent with equals.
compress(String, byte[]) - Method in interface org.apache.curator.framework.api.CompressionProvider
 
compress(String, byte[]) - Method in class org.apache.curator.framework.imps.GzipCompressionProvider
 
compressed() - Method in interface org.apache.curator.framework.api.Compressible
Cause the data to be compressed using the configured compression provider
compressed() - Method in class org.apache.curator.framework.imps.CreateBuilderImpl
 
compressed() - Method in class org.apache.curator.framework.imps.SetDataBuilderImpl
 
compressed() - Method in interface org.apache.curator.x.async.api.AsyncSetDataBuilder
Cause the data to be compressed using the configured compression provider
compressed() - Method in interface org.apache.curator.x.async.api.AsyncTransactionCreateBuilder
Cause the data to be compressed using the configured compression provider
compressed() - Method in interface org.apache.curator.x.async.api.AsyncTransactionSetDataBuilder
Cause the data to be compressed using the configured compression provider
compressed - Variable in class org.apache.curator.x.rpc.idl.structs.CreateSpec
 
compressed - Variable in class org.apache.curator.x.rpc.idl.structs.SetDataSpec
 
compressedWithVersion(int) - Method in interface org.apache.curator.x.async.api.AsyncSetDataBuilder
Cause the data to be compressed using the configured compression provider.
Compressible<T> - Interface in org.apache.curator.framework.api
 
CompressionProvider - Interface in org.apache.curator.framework.api
 
compressionProvider(CompressionProvider) - Method in class org.apache.curator.framework.CuratorFrameworkFactory.Builder
 
configToConnectionString(QuorumVerifier) - Static method in class org.apache.curator.framework.imps.EnsembleTracker
 
Configuration - Class in org.apache.curator.x.rpc.configuration
 
Configuration() - Constructor for class org.apache.curator.x.rpc.configuration.Configuration
 
ConfigurationBuilder - Class in org.apache.curator.x.rpc.configuration
 
ConfigurationBuilder(String) - Constructor for class org.apache.curator.x.rpc.configuration.ConfigurationBuilder
 
ConfigureEnsembleable - Interface in org.apache.curator.framework.api
 
connection() - Method in class org.apache.curator.test.Timing
Return the value to use for ZK connection timeout
ConnectionConfiguration - Class in org.apache.curator.x.rpc.configuration
 
ConnectionConfiguration() - Constructor for class org.apache.curator.x.rpc.configuration.ConnectionConfiguration
 
ConnectionHandlingPolicy - Interface in org.apache.curator.connection
Abstracts connection handling so that Curator can emulate it's old, pre 3.0.0 handling and update to newer handling.
connectionHandlingPolicy(ConnectionHandlingPolicy) - Method in class org.apache.curator.framework.CuratorFrameworkFactory.Builder
Change the connection handling policy.
ConnectionHandlingPolicy.CheckTimeoutsResult - Enum in org.apache.curator.connection
 
ConnectionManager - Class in org.apache.curator.x.rpc.connections
 
ConnectionManager(List<ConnectionConfiguration>, long) - Constructor for class org.apache.curator.x.rpc.connections.ConnectionManager
 
ConnectionState - Enum in org.apache.curator.framework.state
Represents state changes in the connection to ZK
connectionStateErrorPolicy(ConnectionStateErrorPolicy) - Method in class org.apache.curator.framework.CuratorFrameworkFactory.Builder
Set the error policy to use.
ConnectionStateErrorPolicy - Interface in org.apache.curator.framework.state
Recipes should use the configured error policy to decide how to handle errors such as ConnectionState changes.
ConnectionStateListener - Interface in org.apache.curator.framework.state
 
ConnectionStateManager - Class in org.apache.curator.framework.state
Used internally to manage connection state
ConnectionStateManager(CuratorFramework, ThreadFactory, int, int) - Constructor for class org.apache.curator.framework.state.ConnectionStateManager
 
connectionTimeoutMs(int) - Method in class org.apache.curator.framework.CuratorFrameworkFactory.Builder
 
connectString(String) - Method in class org.apache.curator.framework.CuratorFrameworkFactory.Builder
Set the list of servers to connect to.
consumeMessage(T) - Method in class org.apache.curator.framework.recipes.queue.BlockingQueueConsumer
 
consumeMessage(T) - Method in interface org.apache.curator.framework.recipes.queue.QueueConsumer
Process a message from the queue
context - Variable in class org.apache.curator.x.rpc.idl.structs.RpcCuratorEvent
 
countHasChanged(SharedCountReader, int) - Method in interface org.apache.curator.framework.recipes.shared.SharedCountListener
Called when the shared value has changed
create(CuratorFramework, String, byte[]) - Static method in class framework.CrudExamples
 
create() - Method in interface org.apache.curator.framework.api.transaction.CuratorTransaction
Deprecated.
Start a create builder in the transaction
create() - Method in interface org.apache.curator.framework.api.transaction.TransactionOp
Start a create builder in the transaction
create() - Method in interface org.apache.curator.framework.CuratorFramework
Start a create builder
create() - Method in class org.apache.curator.framework.imps.CuratorFrameworkImpl
 
create() - Method in class org.apache.curator.framework.imps.TransactionOpImpl
 
create() - Method in interface org.apache.curator.x.async.api.AsyncCuratorFrameworkDsl
Start a create builder
create() - Method in interface org.apache.curator.x.async.api.AsyncTransactionOp
Start a create builder in the transaction
create() - Method in class org.apache.curator.x.async.details.AsyncCuratorFrameworkImpl
 
CreateBackgroundModeACLable - Interface in org.apache.curator.framework.api
 
CreateBackgroundModeStatACLable - Interface in org.apache.curator.framework.api
 
CreateBuilder - Interface in org.apache.curator.framework.api
 
CreateBuilderImpl - Class in org.apache.curator.framework.imps
 
CreateBuilderImpl(CuratorFrameworkImpl, CreateMode, Backgrounding, boolean, boolean, boolean, boolean, boolean, List<ACL>, Stat) - Constructor for class org.apache.curator.framework.imps.CreateBuilderImpl
 
CreateBuilderMain - Interface in org.apache.curator.framework.api
 
CreateClientExamples - Class in framework
 
CreateClientExamples() - Constructor for class framework.CreateClientExamples
 
createContainers(String) - Method in interface org.apache.curator.framework.CuratorFramework
Create all nodes in the specified path as containers if they don't already exist
createContainers(String) - Method in class org.apache.curator.framework.imps.CuratorFrameworkImpl
 
createEphemeral(CuratorFramework, String, byte[]) - Static method in class framework.CrudExamples
 
createEphemeralSequential(CuratorFramework, String, byte[]) - Static method in class framework.CrudExamples
 
CreateModable<T> - Interface in org.apache.curator.framework.api
 
createNode(CuratorProjection, CreateSpec) - Method in class org.apache.curator.x.rpc.idl.services.CuratorProjectionService
 
CreateOption - Enum in org.apache.curator.x.async.api
Options when creating ZNodes
CreateProtectACLCreateModePathAndBytesable<T> - Interface in org.apache.curator.framework.api
 
createSimple(String) - Static method in class framework.CreateClientExamples
 
CreateSpec - Class in org.apache.curator.x.rpc.idl.structs
 
CreateSpec() - Constructor for class org.apache.curator.x.rpc.idl.structs.CreateSpec
 
CreateSpec(String, byte[], RpcCreateMode, String, boolean, boolean, boolean, boolean) - Constructor for class org.apache.curator.x.rpc.idl.structs.CreateSpec
 
createsTheLock(CuratorFramework, String, byte[]) - Method in interface org.apache.curator.framework.recipes.locks.LockInternalsDriver
 
createsTheLock(CuratorFramework, String, byte[]) - Method in class org.apache.curator.framework.recipes.locks.StandardLockInternalsDriver
 
createWithOptions(String, RetryPolicy, int, int) - Static method in class framework.CreateClientExamples
 
creatingParentContainersIfNeeded() - Method in interface org.apache.curator.framework.api.CreateBackgroundModeACLable
Causes any parent nodes to get created using CreateMode.CONTAINER if they haven't already been.
creatingParentContainersIfNeeded() - Method in interface org.apache.curator.framework.api.CreateBackgroundModeStatACLable
Causes any parent nodes to get created using CreateMode.CONTAINER if they haven't already been.
creatingParentContainersIfNeeded() - Method in interface org.apache.curator.framework.api.CreateBuilderMain
Causes any parent nodes to get created using CreateMode.CONTAINER if they haven't already been.
creatingParentContainersIfNeeded() - Method in interface org.apache.curator.framework.api.CreateProtectACLCreateModePathAndBytesable
Causes any parent nodes to get created using CreateMode.CONTAINER if they haven't already been.
creatingParentContainersIfNeeded() - Method in interface org.apache.curator.framework.api.ExistsBuilder
Causes any parent nodes to get created using CreateMode.CONTAINER if they haven't already been.
creatingParentContainersIfNeeded() - Method in class org.apache.curator.framework.imps.CreateBuilderImpl
 
creatingParentContainersIfNeeded() - Method in class org.apache.curator.framework.imps.ExistsBuilderImpl
 
creatingParentContainersIfNeeded - Variable in class org.apache.curator.x.rpc.idl.structs.CreateSpec
 
creatingParentsIfNeeded() - Method in interface org.apache.curator.framework.api.CreateBackgroundModeACLable
Causes any parent nodes to get created if they haven't already been
creatingParentsIfNeeded() - Method in interface org.apache.curator.framework.api.CreateBackgroundModeStatACLable
Causes any parent nodes to get created if they haven't already been
creatingParentsIfNeeded() - Method in interface org.apache.curator.framework.api.CreateBuilderMain
Causes any parent nodes to get created if they haven't already been
creatingParentsIfNeeded() - Method in interface org.apache.curator.framework.api.CreateProtectACLCreateModePathAndBytesable
Causes any parent nodes to get created if they haven't already been
creatingParentsIfNeeded() - Method in interface org.apache.curator.framework.api.ExistsBuilder
Causes any parent nodes to get created if they haven't already been
creatingParentsIfNeeded() - Method in class org.apache.curator.framework.imps.CreateBuilderImpl
 
creatingParentsIfNeeded() - Method in class org.apache.curator.framework.imps.ExistsBuilderImpl
 
creatingParentsIfNeeded - Variable in class org.apache.curator.x.rpc.idl.structs.CreateSpec
 
CrudExamples - Class in framework
 
CrudExamples() - Constructor for class framework.CrudExamples
 
ctime - Variable in class org.apache.curator.x.rpc.idl.structs.RpcStat
 
CuratorConnectionLossException - Exception in org.apache.curator
This is needed to differentiate between ConnectionLossException thrown by ZooKeeper and ConnectionLossException thrown by ConnectionState.checkTimeouts()
CuratorConnectionLossException() - Constructor for exception org.apache.curator.CuratorConnectionLossException
 
CuratorEntry - Class in org.apache.curator.x.rpc.connections
 
CuratorEntry(CuratorFramework) - Constructor for class org.apache.curator.x.rpc.connections.CuratorEntry
 
CuratorEvent - Interface in org.apache.curator.framework.api
A super set of all the various Zookeeper events/background methods.
CuratorEventType - Enum in org.apache.curator.framework.api
 
CuratorFramework - Interface in org.apache.curator.framework
Zookeeper framework-style client
CuratorFrameworkFactory - Class in org.apache.curator.framework
Factory methods for creating framework-style clients
CuratorFrameworkFactory.Builder - Class in org.apache.curator.framework
 
CuratorFrameworkImpl - Class in org.apache.curator.framework.imps
 
CuratorFrameworkImpl(CuratorFrameworkFactory.Builder) - Constructor for class org.apache.curator.framework.imps.CuratorFrameworkImpl
 
CuratorFrameworkImpl(CuratorFrameworkImpl) - Constructor for class org.apache.curator.framework.imps.CuratorFrameworkImpl
 
CuratorFrameworkState - Enum in org.apache.curator.framework.imps
 
CuratorListener - Interface in org.apache.curator.framework.api
Receives notifications about errors and background events
CuratorMultiTransaction - Interface in org.apache.curator.framework.api.transaction
 
CuratorMultiTransactionImpl - Class in org.apache.curator.framework.imps
 
CuratorMultiTransactionImpl(CuratorFrameworkImpl) - Constructor for class org.apache.curator.framework.imps.CuratorMultiTransactionImpl
 
CuratorMultiTransactionImpl(CuratorFrameworkImpl, Backgrounding) - Constructor for class org.apache.curator.framework.imps.CuratorMultiTransactionImpl
 
CuratorMultiTransactionMain - Interface in org.apache.curator.framework.api.transaction
 
CuratorOp - Interface in org.apache.curator.framework.api.transaction
Internal representation of a transaction operation
CuratorProjection - Class in org.apache.curator.x.rpc.idl.structs
 
CuratorProjection() - Constructor for class org.apache.curator.x.rpc.idl.structs.CuratorProjection
 
CuratorProjection(String) - Constructor for class org.apache.curator.x.rpc.idl.structs.CuratorProjection
 
CuratorProjectionServer - Class in org.apache.curator.x.rpc
 
CuratorProjectionServer(Configuration) - Constructor for class org.apache.curator.x.rpc.CuratorProjectionServer
 
CuratorProjectionService - Class in org.apache.curator.x.rpc.idl.services
 
CuratorProjectionService(ConnectionManager) - Constructor for class org.apache.curator.x.rpc.idl.services.CuratorProjectionService
 
CuratorTempFramework - Interface in org.apache.curator.framework
Temporary CuratorFramework instances are meant for single requests to ZooKeeper ensembles over a failure prone network such as a WAN.
CuratorTempFrameworkImpl - Class in org.apache.curator.framework.imps
 
CuratorTempFrameworkImpl(CuratorFrameworkFactory.Builder, long) - Constructor for class org.apache.curator.framework.imps.CuratorTempFrameworkImpl
 
CuratorTransaction - Interface in org.apache.curator.framework.api.transaction
CuratorTransactionBridge - Interface in org.apache.curator.framework.api.transaction
 
CuratorTransactionFinal - Interface in org.apache.curator.framework.api.transaction
Adds commit to the transaction interface
CuratorTransactionResult - Class in org.apache.curator.framework.api.transaction
Holds the result of one transactional operation
CuratorTransactionResult(OperationType, String, String, Stat) - Constructor for class org.apache.curator.framework.api.transaction.CuratorTransactionResult
 
CuratorTransactionResult(OperationType, String, String, Stat, int) - Constructor for class org.apache.curator.framework.api.transaction.CuratorTransactionResult
 
CuratorWatcher - Interface in org.apache.curator.framework.api
A version of Watcher that can throw an exception
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, Watcher, RetryPolicy, boolean, ConnectionHandlingPolicy) - Constructor for class org.apache.curator.CuratorZookeeperClient
 
cversion - Variable in class org.apache.curator.x.rpc.idl.structs.RpcStat
 
czxid - Variable in class org.apache.curator.x.rpc.idl.structs.RpcStat
 

D

data - Variable in class org.apache.curator.x.rpc.idl.structs.CreateSpec
 
data - Variable in class org.apache.curator.x.rpc.idl.structs.OptionalData
 
data - Variable in class org.apache.curator.x.rpc.idl.structs.RpcChildData
 
data - Variable in class org.apache.curator.x.rpc.idl.structs.RpcCuratorEvent
 
data - Variable in class org.apache.curator.x.rpc.idl.structs.RpcPathChildrenCacheEvent
 
data - Variable in class org.apache.curator.x.rpc.idl.structs.SetDataSpec
 
DataCallbackable<T> - Interface in org.apache.curator.framework.api
 
dataLength - Variable in class org.apache.curator.x.rpc.idl.structs.RpcStat
 
dataValidator(SchemaValidator) - Method in class org.apache.curator.framework.schema.SchemaBuilder
 
debugUnhandledErrorListener - Variable in class org.apache.curator.framework.imps.CuratorFrameworkImpl
 
DebugUtils - Class in org.apache.curator.utils
 
decompress(String, byte[]) - Method in interface org.apache.curator.framework.api.CompressionProvider
 
decompress(String, byte[]) - Method in class org.apache.curator.framework.imps.GzipCompressionProvider
 
decompressed() - Method in interface org.apache.curator.framework.api.Decompressible
Cause the data to be de-compressed using the configured compression provider
decompressed() - Method in class org.apache.curator.framework.imps.GetDataBuilderImpl
 
decompressed() - Method in interface org.apache.curator.x.async.api.AsyncGetDataBuilder
Cause the data to be de-compressed using the configured compression provider
decompressed - Variable in class org.apache.curator.x.rpc.idl.structs.GetDataSpec
 
decompressedStoringStatIn(Stat) - Method in interface org.apache.curator.x.async.api.AsyncGetDataBuilder
Have the operation fill the provided stat object and have the data be de-compressed
Decompressible<T> - Interface in org.apache.curator.framework.api
 
decrement() - Method in class org.apache.curator.framework.recipes.atomic.DistributedAtomicInteger
Subtract 1 from the current value and return the new value information.
decrement() - Method in class org.apache.curator.framework.recipes.atomic.DistributedAtomicLong
Subtract 1 from the current value and return the new value information.
decrement() - Method in interface org.apache.curator.framework.recipes.atomic.DistributedAtomicNumber
Subtract 1 from the current value and return the new value information.
DefaultACLProvider - Class in org.apache.curator.framework.imps
 
DefaultACLProvider() - Constructor for class org.apache.curator.framework.imps.DefaultACLProvider
 
defaultData(byte[]) - Method in class org.apache.curator.framework.CuratorFrameworkFactory.Builder
Sets the data to use when PathAndBytesable.forPath(String) is used.
DefaultExhibitorRestClient - Class in org.apache.curator.ensemble.exhibitor
 
DefaultExhibitorRestClient() - Constructor for class org.apache.curator.ensemble.exhibitor.DefaultExhibitorRestClient
 
DefaultExhibitorRestClient(boolean) - Constructor for class org.apache.curator.ensemble.exhibitor.DefaultExhibitorRestClient
 
DefaultSchemaValidator - Class in org.apache.curator.framework.schema
The default data validator - always returns true
DefaultSchemaValidator() - Constructor for class org.apache.curator.framework.schema.DefaultSchemaValidator
 
DefaultTracerDriver - Class in org.apache.curator.utils
Default tracer driver
DefaultTracerDriver() - Constructor for class org.apache.curator.utils.DefaultTracerDriver
 
DefaultTreeCacheSelector - Class in org.apache.curator.framework.recipes.cache
Default TreeCache selector - returns true for all methods
DefaultTreeCacheSelector() - Constructor for class org.apache.curator.framework.recipes.cache.DefaultTreeCacheSelector
 
DefaultZookeeperFactory - Class in org.apache.curator.utils
 
DefaultZookeeperFactory() - Constructor for class org.apache.curator.utils.DefaultZookeeperFactory
 
DelegatingExecutorService - Class in org.apache.curator.test
 
DelegatingExecutorService(ExecutorService) - Constructor for class org.apache.curator.test.DelegatingExecutorService
 
delete(CuratorFramework, String) - Static method in class framework.CrudExamples
 
delete() - Method in interface org.apache.curator.framework.api.transaction.CuratorTransaction
Deprecated.
Start a delete builder in the transaction
delete() - Method in interface org.apache.curator.framework.api.transaction.TransactionOp
Start a delete builder in the transaction
delete() - Method in interface org.apache.curator.framework.CuratorFramework
Start a delete builder
delete() - Method in class org.apache.curator.framework.imps.CuratorFrameworkImpl
 
delete() - Method in class org.apache.curator.framework.imps.TransactionOpImpl
 
delete() - Method in interface org.apache.curator.x.async.api.AsyncCuratorFrameworkDsl
Start a delete builder
delete() - Method in interface org.apache.curator.x.async.api.AsyncTransactionOp
Start a delete builder in the transaction
delete() - Method in class org.apache.curator.x.async.details.AsyncCuratorFrameworkImpl
 
DeleteBuilder - Interface in org.apache.curator.framework.api
 
DeleteBuilderImpl - Class in org.apache.curator.framework.imps
 
DeleteBuilderImpl(CuratorFrameworkImpl, int, Backgrounding, boolean, boolean, boolean) - Constructor for class org.apache.curator.framework.imps.DeleteBuilderImpl
 
DeleteBuilderMain - Interface in org.apache.curator.framework.api
 
deleteChildren(ZooKeeper, String, boolean) - Static method in class org.apache.curator.utils.ZKPaths
Recursively deletes children of a node.
deleteDataDirectoryOnClose() - Method in class org.apache.curator.test.InstanceSpec
 
deleteDirectoryContents(File) - Static method in class org.apache.curator.test.DirectoryUtils
 
deleteNode(CuratorProjection, DeleteSpec) - Method in class org.apache.curator.x.rpc.idl.services.CuratorProjectionService
 
DeleteOption - Enum in org.apache.curator.x.async.api
Options to use when deleting ZNodes
deleteRecursively(File) - Static method in class org.apache.curator.test.DirectoryUtils
 
DeleteSpec - Class in org.apache.curator.x.rpc.idl.structs
 
DeleteSpec() - Constructor for class org.apache.curator.x.rpc.idl.structs.DeleteSpec
 
DeleteSpec(String, boolean, String, Version) - Constructor for class org.apache.curator.x.rpc.idl.structs.DeleteSpec
 
deletingChildrenIfNeeded() - Method in interface org.apache.curator.framework.api.ChildrenDeletable
Will also delete children if they exist.
deletingChildrenIfNeeded() - Method in class org.apache.curator.framework.imps.DeleteBuilderImpl
 
deserialize(byte[]) - Method in interface org.apache.curator.framework.recipes.queue.QueueSerializer
Deserialize bytes into a queue item
deserialize(byte[]) - Method in interface org.apache.curator.x.discovery.details.InstanceSerializer
Deserialize a byte array into an instance
deserialize(byte[]) - Method in class org.apache.curator.x.discovery.details.JsonInstanceSerializer
 
DirectoryUtils - Class in org.apache.curator.test
 
DirectoryUtils() - Constructor for class org.apache.curator.test.DirectoryUtils
 
discovery - package discovery
 
DiscoveryContext<T> - Interface in org.apache.curator.x.discovery.server.rest
Bridge between the specifics of your needs and the generic implementation
DiscoveryExample - Class in discovery
 
DiscoveryExample() - Constructor for class discovery.DiscoveryExample
 
DiscoveryInstance - Class in org.apache.curator.x.rpc.idl.discovery
 
DiscoveryInstance() - Constructor for class org.apache.curator.x.rpc.idl.discovery.DiscoveryInstance
 
DiscoveryInstance(ServiceInstance<byte[]>) - Constructor for class org.apache.curator.x.rpc.idl.discovery.DiscoveryInstance
 
DiscoveryInstance(String, String, String, int, int, byte[], long, DiscoveryInstanceType, String) - Constructor for class org.apache.curator.x.rpc.idl.discovery.DiscoveryInstance
 
DiscoveryInstanceType - Enum in org.apache.curator.x.rpc.idl.discovery
 
DiscoveryProjection - Class in org.apache.curator.x.rpc.idl.discovery
 
DiscoveryProjection() - Constructor for class org.apache.curator.x.rpc.idl.discovery.DiscoveryProjection
 
DiscoveryProjection(String) - Constructor for class org.apache.curator.x.rpc.idl.discovery.DiscoveryProjection
 
DiscoveryProviderProjection - Class in org.apache.curator.x.rpc.idl.discovery
 
DiscoveryProviderProjection() - Constructor for class org.apache.curator.x.rpc.idl.discovery.DiscoveryProviderProjection
 
DiscoveryProviderProjection(String) - Constructor for class org.apache.curator.x.rpc.idl.discovery.DiscoveryProviderProjection
 
DiscoveryResource<T> - Class in org.apache.curator.x.discovery.server.rest
The JAX-RS web service.
DiscoveryResource(DiscoveryContext<T>) - Constructor for class org.apache.curator.x.discovery.server.rest.DiscoveryResource
 
DiscoveryService - Class in org.apache.curator.x.rpc.idl.discovery
 
DiscoveryService(ConnectionManager) - Constructor for class org.apache.curator.x.rpc.idl.discovery.DiscoveryService
 
DiscoveryServiceLowLevel - Class in org.apache.curator.x.rpc.idl.discovery
 
DiscoveryServiceLowLevel(ConnectionManager) - Constructor for class org.apache.curator.x.rpc.idl.discovery.DiscoveryServiceLowLevel
 
DistributedAtomicInteger - Class in org.apache.curator.framework.recipes.atomic
A counter that attempts atomic increments.
DistributedAtomicInteger(CuratorFramework, String, RetryPolicy) - Constructor for class org.apache.curator.framework.recipes.atomic.DistributedAtomicInteger
Creates in optimistic mode only - i.e.
DistributedAtomicInteger(CuratorFramework, String, RetryPolicy, PromotedToLock) - Constructor for class org.apache.curator.framework.recipes.atomic.DistributedAtomicInteger
Creates in mutex promotion mode.
DistributedAtomicLong - Class in org.apache.curator.framework.recipes.atomic
A counter that attempts atomic increments.
DistributedAtomicLong(CuratorFramework, String, RetryPolicy) - Constructor for class org.apache.curator.framework.recipes.atomic.DistributedAtomicLong
Creates in optimistic mode only - i.e.
DistributedAtomicLong(CuratorFramework, String, RetryPolicy, PromotedToLock) - Constructor for class org.apache.curator.framework.recipes.atomic.DistributedAtomicLong
Creates in mutex promotion mode.
DistributedAtomicNumber<T> - Interface in org.apache.curator.framework.recipes.atomic
 
DistributedAtomicValue - Class in org.apache.curator.framework.recipes.atomic
A distributed value that attempts atomic sets.
DistributedAtomicValue(CuratorFramework, String, RetryPolicy) - Constructor for class org.apache.curator.framework.recipes.atomic.DistributedAtomicValue
Creates in optimistic mode only - i.e.
DistributedAtomicValue(CuratorFramework, String, RetryPolicy, PromotedToLock) - Constructor for class org.apache.curator.framework.recipes.atomic.DistributedAtomicValue
Creates in mutex promotion mode.
DistributedBarrier - Class in org.apache.curator.framework.recipes.barriers
A barrier as described in the ZK recipes.
DistributedBarrier(CuratorFramework, String) - Constructor for class org.apache.curator.framework.recipes.barriers.DistributedBarrier
 
DistributedDelayQueue<T> - Class in org.apache.curator.framework.recipes.queue
A variation of the DistributedPriorityQueue that uses time as the priority.
DistributedDoubleBarrier - Class in org.apache.curator.framework.recipes.barriers
A double barrier as described in the ZK recipes.
DistributedDoubleBarrier(CuratorFramework, String, int) - Constructor for class org.apache.curator.framework.recipes.barriers.DistributedDoubleBarrier
Creates the barrier abstraction.
DistributedIdQueue<T> - Class in org.apache.curator.framework.recipes.queue
A version of DistributedQueue that allows IDs to be associated with queue items.
DistributedPriorityQueue<T> - Class in org.apache.curator.framework.recipes.queue
An implementation of the Distributed Priority Queue ZK recipe.
DistributedQueue<T> - Class in org.apache.curator.framework.recipes.queue
An implementation of the Distributed Queue ZK recipe.
DistributedQueue.ProcessType - Enum in org.apache.curator.framework.recipes.queue
 
documentation(String) - Method in class org.apache.curator.framework.schema.SchemaBuilder
 
done() - Method in class org.apache.curator.utils.CloseableExecutorService.InternalFutureTask
 
dontUseContainerParents() - Method in class org.apache.curator.framework.CuratorFrameworkFactory.Builder
By default, Curator uses CreateBuilderMain.creatingParentContainersIfNeeded() if the ZK JAR supports CreateMode.CONTAINER.
DownInstancePolicy - Class in org.apache.curator.x.discovery
Abstraction for values that determine when an instance is down
DownInstancePolicy() - Constructor for class org.apache.curator.x.discovery.DownInstancePolicy
Policy with default values
DownInstancePolicy(long, TimeUnit, int) - Constructor for class org.apache.curator.x.discovery.DownInstancePolicy
 
downInstancePolicy(DownInstancePolicy) - Method in interface org.apache.curator.x.discovery.ServiceProviderBuilder
Set the down instance policy
doWork(long, TimeUnit) - Method in class locking.ExampleClientThatLocks
 
drainTo(Collection<? super T>) - Method in class org.apache.curator.framework.recipes.queue.BlockingQueueConsumer
Removes all available elements from this queue and adds them to the given collection.

E

element() - Method in class org.apache.curator.framework.recipes.queue.SimpleDistributedQueue
Return the head of the queue without modifying the queue.
enabled(boolean) - Method in class org.apache.curator.x.discovery.ServiceInstanceBuilder
 
enabledSessionExpiredStateAware() - Method in class org.apache.curator.test.BaseClassForTests
 
Ensembleable<T> - Interface in org.apache.curator.framework.api
 
EnsembleProvider - Interface in org.apache.curator.ensemble
Abstraction that provides the ZooKeeper connection string
ensembleProvider(EnsembleProvider) - Method in class org.apache.curator.framework.CuratorFrameworkFactory.Builder
Set the list ensemble provider.
EnsembleTracker - Class in org.apache.curator.framework.imps
 
ensure() - Method in class org.apache.curator.framework.EnsureContainers
The first time this method is called, all nodes in the path will be created as containers if needed
ensure(CuratorZookeeperClient) - Method in class org.apache.curator.utils.EnsurePath
Deprecated.
First time, synchronizes and makes sure all nodes in the path are created.
EnsureContainers - Class in org.apache.curator.framework
Similar to EnsurePath but creates containers.
EnsureContainers(CuratorFramework, String) - Constructor for class org.apache.curator.framework.EnsureContainers
 
ensurePath() - Method in class org.apache.curator.framework.recipes.cache.PathChildrenCache
 
ensurePath() - Method in class org.apache.curator.framework.recipes.queue.SimpleDistributedQueue
 
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.
 
enter() - Method in class org.apache.curator.framework.recipes.barriers.DistributedDoubleBarrier
Enter the barrier and block until all members have entered
enter(long, TimeUnit) - Method in class org.apache.curator.framework.recipes.barriers.DistributedDoubleBarrier
Enter the barrier and block until all members have entered or the timeout has elapsed
ephemeral(Schema.Allowance) - Method in class org.apache.curator.framework.schema.SchemaBuilder
 
ephemeralOwner - Variable in class org.apache.curator.x.rpc.idl.structs.RpcStat
 
equals(Object) - Method in class org.apache.curator.framework.recipes.cache.ChildData
 
equals(Object) - Method in class org.apache.curator.framework.recipes.leader.Participant
 
equals(Object) - Method in class org.apache.curator.framework.schema.Schema
 
equals(Object) - Method in class org.apache.curator.test.InstanceSpec
 
equals(Object) - Method in class org.apache.curator.x.async.details.AsyncResultImpl
 
equals(Object) - Method in class org.apache.curator.x.discovery.ServiceInstance
 
equals(Object) - Method in class org.apache.curator.x.discovery.UriSpec
 
equals(Object) - Method in class org.apache.curator.x.discovery.UriSpec.Part
 
ErrorListenerEnsembleable<T> - Interface in org.apache.curator.framework.api
 
ErrorListenerMultiTransactionMain - Interface in org.apache.curator.framework.api
 
ErrorListenerPathable<T> - Interface in org.apache.curator.framework.api
 
ErrorListenerPathAndBytesable<T> - Interface in org.apache.curator.framework.api
 
ErrorListenerReconfigBuilderMain - Interface in org.apache.curator.framework.api
 
ErrorMode - Enum in org.apache.curator.framework.recipes.queue
Used when the queue is created with a QueueBuilder.lockPath(String).
event() - Method in interface org.apache.curator.x.async.AsyncStage
If the WatchableAsyncCuratorFramework facade is used (via AsyncCuratorFrameworkDsl.watched()), this returns the completion stage used when the watcher is triggered
eventReceived(CuratorFramework, CuratorEvent) - Method in interface org.apache.curator.framework.api.CuratorListener
Called when a background task has completed or a watch has triggered
EventService - Class in org.apache.curator.x.rpc.idl.services
 
EventService(ConnectionManager, long) - Constructor for class org.apache.curator.x.rpc.idl.services.EventService
 
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
 
eventType - Variable in class org.apache.curator.x.rpc.idl.structs.RpcWatchedEvent
 
ExampleClient - Class in leader
An example leader selector client.
ExampleClient(CuratorFramework, String, String) - Constructor for class leader.ExampleClient
 
ExampleClientThatLocks - Class in locking
 
ExampleClientThatLocks(CuratorFramework, String, FakeLimitedResource, String) - Constructor for class locking.ExampleClientThatLocks
 
ExampleServer - Class in discovery
This shows a very simplified method of registering an instance with the service discovery.
ExampleServer(CuratorFramework, String, String, String) - Constructor for class discovery.ExampleServer
 
ExceptionType - Enum in org.apache.curator.x.rpc.idl.exceptions
 
excludingLast() - Method in class org.apache.curator.utils.EnsurePath
Deprecated.
Returns a view of this EnsurePath instance that does not make the last node.
execute(CuratorFramework, Runnable) - Static method in class org.apache.curator.framework.recipes.AfterConnectionEstablished
Spawns a new new background thread that will block until a connection is available and then execute the 'runAfterConnection' logic
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
 
executor - Variable in class org.apache.curator.framework.listen.ListenerEntry
 
executor(Executor) - Method in class org.apache.curator.framework.recipes.queue.QueueBuilder
Change the executor used.
executorService(ExecutorService) - Method in interface org.apache.curator.x.discovery.ServiceCacheBuilder
Optional ExecutorService to use for the cache's background thread.
executorService(CloseableExecutorService) - Method in interface org.apache.curator.x.discovery.ServiceCacheBuilder
Optional CloseableExecutorService to use for the cache's background thread.
ExhibitorEnsembleProvider - Class in org.apache.curator.ensemble.exhibitor
Ensemble provider that polls a cluster of Exhibitor (https://github.com/Netflix/exhibitor) instances for the connection string.
ExhibitorEnsembleProvider(Exhibitors, ExhibitorRestClient, String, int, RetryPolicy) - Constructor for class org.apache.curator.ensemble.exhibitor.ExhibitorEnsembleProvider
 
ExhibitorRestClient - Interface in org.apache.curator.ensemble.exhibitor
 
Exhibitors - Class in org.apache.curator.ensemble.exhibitor
POJO for specifying the cluster of Exhibitor instances
Exhibitors(Collection<String>, int, Exhibitors.BackupConnectionStringProvider) - Constructor for class org.apache.curator.ensemble.exhibitor.Exhibitors
 
Exhibitors.BackupConnectionStringProvider - Interface in org.apache.curator.ensemble.exhibitor
 
exists(CuratorProjection, ExistsSpec) - Method in class org.apache.curator.x.rpc.idl.services.CuratorProjectionService
 
ExistsBuilder - Interface in org.apache.curator.framework.api
 
ExistsBuilderImpl - Class in org.apache.curator.framework.imps
 
ExistsBuilderImpl(CuratorFrameworkImpl, Backgrounding, Watcher, boolean, boolean) - Constructor for class org.apache.curator.framework.imps.ExistsBuilderImpl
 
ExistsBuilderMain - Interface in org.apache.curator.framework.api
 
ExistsOption - Enum in org.apache.curator.x.async.api
Options to use when checking for ZNode existence
ExistsSpec - Class in org.apache.curator.x.rpc.idl.structs
 
ExistsSpec() - Constructor for class org.apache.curator.x.rpc.idl.structs.ExistsSpec
 
ExistsSpec(String, boolean, String) - Constructor for class org.apache.curator.x.rpc.idl.structs.ExistsSpec
 
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
 
ExponentialBackoffRetryConfiguration - Class in org.apache.curator.x.rpc.configuration
 
ExponentialBackoffRetryConfiguration() - Constructor for class org.apache.curator.x.rpc.configuration.ExponentialBackoffRetryConfiguration
 

F

FakeLimitedResource - Class in locking
Simulates some external resource that can only be access by one process at a time
FakeLimitedResource() - Constructor for class locking.FakeLimitedResource
 
FIELD_ADDRESS - Static variable in class org.apache.curator.x.discovery.UriSpec
If a ServiceInstance is passed when building, the replacement is ServiceInstance.getAddress()
FIELD_CLOSE_BRACE - Static variable in class org.apache.curator.x.discovery.UriSpec
Always replaced with '}' - i.e.
FIELD_ID - Static variable in class org.apache.curator.x.discovery.UriSpec
If a ServiceInstance is passed when building, the replacement is ServiceInstance.getId()
FIELD_NAME - Static variable in class org.apache.curator.x.discovery.UriSpec
If a ServiceInstance is passed when building, the replacement is ServiceInstance.getName()
FIELD_OPEN_BRACE - Static variable in class org.apache.curator.x.discovery.UriSpec
Always replaced with '{' - i.e.
FIELD_PORT - Static variable in class org.apache.curator.x.discovery.UriSpec
If a ServiceInstance is passed when building, the replacement is ServiceInstance.getPort()
FIELD_REGISTRATION_TIME_UTC - Static variable in class org.apache.curator.x.discovery.UriSpec
If a ServiceInstance is passed when building, the replacement is ServiceInstance.getRegistrationTimeUTC()
FIELD_SCHEME - Static variable in class org.apache.curator.x.discovery.UriSpec
This defaults to "http".
FIELD_SERVICE_TYPE - Static variable in class org.apache.curator.x.discovery.UriSpec
If a ServiceInstance is passed when building, the replacement is ServiceInstance.getServiceType()
FIELD_SSL_PORT - Static variable in class org.apache.curator.x.discovery.UriSpec
If a ServiceInstance is passed when building, the replacement is ServiceInstance.getSslPort()
Filters - Class in org.apache.curator.x.async.details
 
Filters(UnhandledErrorListener, UnaryOperator<CuratorEvent>, UnaryOperator<WatchedEvent>) - Constructor for class org.apache.curator.x.async.details.Filters
 
finalFlushTime(int, TimeUnit) - Method in class org.apache.curator.framework.recipes.queue.QueueBuilder
Sets an amount of time to call DistributedQueue.flushPuts(long, TimeUnit) when the queue is closed.
findConnectionInstance(ZooKeeper) - Method in class org.apache.curator.test.TestingCluster
Given a ZooKeeper instance, returns which server it is connected to
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
fixForSorting(String, String) - Method in interface org.apache.curator.framework.recipes.locks.LockInternalsSorter
 
fixForSorting(String, String) - Method in class org.apache.curator.framework.recipes.locks.StandardLockInternalsDriver
 
flushPuts(long, TimeUnit) - Method in class org.apache.curator.framework.recipes.queue.DistributedDelayQueue
 
flushPuts(long, TimeUnit) - Method in class org.apache.curator.framework.recipes.queue.DistributedIdQueue
 
flushPuts(long, TimeUnit) - Method in class org.apache.curator.framework.recipes.queue.DistributedPriorityQueue
 
flushPuts(long, TimeUnit) - Method in class org.apache.curator.framework.recipes.queue.DistributedQueue
Wait until any pending puts are committed
flushPuts(long, TimeUnit) - Method in interface org.apache.curator.framework.recipes.queue.QueueBase
Wait until any pending puts are committed
forceSet(Integer) - Method in class org.apache.curator.framework.recipes.atomic.DistributedAtomicInteger
 
forceSet(Long) - Method in class org.apache.curator.framework.recipes.atomic.DistributedAtomicLong
 
forceSet(T) - Method in interface org.apache.curator.framework.recipes.atomic.DistributedAtomicNumber
Forcibly sets the value of the counter without any guarantees of atomicity.
forceSet(byte[]) - Method in class org.apache.curator.framework.recipes.atomic.DistributedAtomicValue
Forcibly sets the value any guarantees of atomicity.
forEach(Function<T, Void>) - Method in class org.apache.curator.framework.listen.ListenerContainer
Utility - apply the given function to each listener.
forEnsemble() - Method in interface org.apache.curator.framework.api.Ensembleable
 
forEnsemble() - Method in class org.apache.curator.framework.imps.GetConfigBuilderImpl
 
forEnsemble() - Method in class org.apache.curator.framework.imps.ReconfigBuilderImpl
 
forEnsemble() - Method in interface org.apache.curator.x.async.api.AsyncEnsemblable
Commit the currently building operation and invoke ZooKeeper
forOperations(CuratorOp...) - Method in interface org.apache.curator.framework.api.transaction.CuratorMultiTransactionMain
Commit the given operations as a single transaction.
forOperations(List<CuratorOp>) - Method in interface org.apache.curator.framework.api.transaction.CuratorMultiTransactionMain
Commit the given operations as a single transaction.
forOperations(CuratorOp...) - Method in class org.apache.curator.framework.imps.CuratorMultiTransactionImpl
 
forOperations(List<CuratorOp>) - Method in class org.apache.curator.framework.imps.CuratorMultiTransactionImpl
 
forOperations(List<CuratorOp>) - Method in interface org.apache.curator.x.async.api.AsyncMultiTransaction
Invoke ZooKeeper to commit the given operations as a single transaction.
forPath(String) - Method in interface org.apache.curator.framework.api.Pathable
Commit the currently building operation using the given path
forPath(String, byte[]) - Method in interface org.apache.curator.framework.api.PathAndBytesable
Commit the currently building operation using the given path and data
forPath(String) - Method in interface org.apache.curator.framework.api.PathAndBytesable
Commit the currently building operation using the given path and the default data for the client (usually a byte[0] unless changed via CuratorFrameworkFactory.Builder#defaultData(byte[])).
forPath(String) - Method in class org.apache.curator.framework.imps.CreateBuilderImpl
 
forPath(String, byte[]) - Method in class org.apache.curator.framework.imps.CreateBuilderImpl
 
forPath(String) - Method in class org.apache.curator.framework.imps.DeleteBuilderImpl
 
forPath(String) - Method in class org.apache.curator.framework.imps.ExistsBuilderImpl
 
forPath(String) - Method in class org.apache.curator.framework.imps.GetACLBuilderImpl
 
forPath(String) - Method in class org.apache.curator.framework.imps.GetChildrenBuilderImpl
 
forPath(String) - Method in class org.apache.curator.framework.imps.GetDataBuilderImpl
 
forPath(String) - Method in class org.apache.curator.framework.imps.RemoveWatchesBuilderImpl
 
forPath(String) - Method in class org.apache.curator.framework.imps.SetACLBuilderImpl
 
forPath(String) - Method in class org.apache.curator.framework.imps.SetDataBuilderImpl
 
forPath(String, byte[]) - Method in class org.apache.curator.framework.imps.SetDataBuilderImpl
 
forPath(String) - Method in class org.apache.curator.framework.imps.SyncBuilderImpl
 
forPath(String) - Method in interface org.apache.curator.x.async.api.AsyncPathable
Commit the currently building operation using the given path and invoke ZooKeeper
forPath(String, byte[]) - Method in interface org.apache.curator.x.async.api.AsyncPathAndBytesable
Commit the currently building operation using the given path and data and invoke ZooKeeper
forSessionSleep() - Method in class org.apache.curator.test.Timing
Return a new timing with a multiple that ensures a ZK session timeout
forSleepingABit() - Method in class org.apache.curator.test.Timing
Return a new timing with a multiple for sleeping a smaller amount of time
forWaiting() - Method in class org.apache.curator.test.Timing
Return a new timing with the standard multiple for waiting on latches, etc.
framework - package framework
 
fromConfig(long) - Method in interface org.apache.curator.framework.api.AsyncReconfigurable
Sets the configuration version to use.
fromConfig(long) - Method in interface org.apache.curator.framework.api.ConfigureEnsembleable
Sets the configuration version to use.

G

GenericDiscoveryContext<T> - Class in org.apache.curator.x.discovery.server.contexts
For convenience, a version of DiscoveryContext that uses any generic type as the payload
GenericDiscoveryContext(ServiceDiscovery<T>, ProviderStrategy<T>, int, Class<T>) - Constructor for class org.apache.curator.x.discovery.server.contexts.GenericDiscoveryContext
 
GenericDiscoveryContext(ServiceDiscovery<T>, ProviderStrategy<T>, int, TypeToken<T>) - Constructor for class org.apache.curator.x.discovery.server.contexts.GenericDiscoveryContext
 
get() - Method in interface org.apache.curator.framework.api.transaction.CuratorOp
 
get() - Method in class org.apache.curator.framework.recipes.atomic.DistributedAtomicInteger
 
get() - Method in class org.apache.curator.framework.recipes.atomic.DistributedAtomicLong
 
get() - Method in interface org.apache.curator.framework.recipes.atomic.DistributedAtomicNumber
Returns the current value of the counter.
get() - Method in class org.apache.curator.framework.recipes.atomic.DistributedAtomicValue
Returns the current value of the counter.
get() - Method in class org.apache.curator.utils.CloseableExecutorService.InternalScheduledFutureTask
 
get(long, TimeUnit) - Method in class org.apache.curator.utils.CloseableExecutorService.InternalScheduledFutureTask
 
get(String, String) - Method in class org.apache.curator.x.discovery.server.rest.DiscoveryResource
 
get(String) - Method in class org.apache.curator.x.rpc.connections.ConnectionManager
 
getACL() - Method in interface org.apache.curator.framework.CuratorFramework
Start a get ACL builder
getACL() - Method in class org.apache.curator.framework.imps.CuratorFrameworkImpl
 
getAcl() - Method in class org.apache.curator.framework.schema.SchemaViolation.ViolatorData
The ACLs used in the API or null
getACL() - Method in interface org.apache.curator.x.async.api.AsyncCuratorFrameworkDsl
Start a get ACL builder
getACL() - Method in class org.apache.curator.x.async.details.AsyncCuratorFrameworkImpl
 
GetACLBuilder - Interface in org.apache.curator.framework.api
 
GetACLBuilderImpl - Class in org.apache.curator.framework.imps
 
GetACLBuilderImpl(CuratorFrameworkImpl, Backgrounding, Stat) - Constructor for class org.apache.curator.framework.imps.GetACLBuilderImpl
 
getAclForPath(String) - Method in interface org.apache.curator.framework.api.ACLProvider
Return the ACL list to use for the given path
getAclForPath(String) - Method in class org.apache.curator.framework.imps.DefaultACLProvider
 
getAclForPath(String) - Method in interface org.apache.curator.utils.InternalACLProvider
Return the ACL list to use for the given path
getACLList() - Method in interface org.apache.curator.framework.api.CuratorEvent
 
getAclProvider() - Method in class org.apache.curator.framework.CuratorFrameworkFactory.Builder
 
getActualPath() - Method in class org.apache.curator.framework.recipes.nodes.PersistentNode
Returns the currently set path or null if the node does not exist
getAddress() - Method in class org.apache.curator.x.discovery.ServiceInstance
 
getAll(String) - Method in class org.apache.curator.x.discovery.server.rest.DiscoveryResource
 
getAllInstances() - Method in class org.apache.curator.x.discovery.details.ServiceProviderImpl
Return the current available set of instances IMPORTANT: users should not hold on to the instance returned.
getAllInstances() - Method in interface org.apache.curator.x.discovery.ServiceProvider
Return the current available set of instances IMPORTANT: users should not hold on to the instance returned.
getAllInstances(CuratorProjection, DiscoveryProviderProjection) - Method in class org.apache.curator.x.rpc.idl.discovery.DiscoveryService
 
getAllLocalIPs() - Static method in class org.apache.curator.x.discovery.ServiceInstanceBuilder
based on http://pastebin.com/5X073pUc
getAllNames() - Method in class org.apache.curator.x.discovery.server.rest.DiscoveryResource
 
getAny(String) - Method in class org.apache.curator.x.discovery.server.rest.DiscoveryResource
 
getAuth() - Method in class org.apache.curator.framework.AuthInfo
 
getAuth() - Method in class org.apache.curator.x.rpc.configuration.AuthorizationConfiguration
 
getAuthInfos() - Method in class org.apache.curator.framework.CuratorFrameworkFactory.Builder
 
getAuthorization() - Method in class org.apache.curator.x.rpc.configuration.ConnectionConfiguration
 
getAuthScheme() - Method in class org.apache.curator.framework.CuratorFrameworkFactory.Builder
Deprecated.
getAuthValue() - Method in class org.apache.curator.framework.CuratorFrameworkFactory.Builder
Deprecated.
getBackupConnectionString() - Method in interface org.apache.curator.ensemble.exhibitor.Exhibitors.BackupConnectionStringProvider
 
getBackupConnectionString() - Method in class org.apache.curator.ensemble.exhibitor.Exhibitors
 
getBaseSleepTime() - Method in class org.apache.curator.x.rpc.configuration.BoundedExponentialBackoffRetryConfiguration
 
getBaseSleepTime() - Method in class org.apache.curator.x.rpc.configuration.ExponentialBackoffRetryConfiguration
 
getBaseSleepTimeMs() - Method in class org.apache.curator.retry.ExponentialBackoffRetry
 
getChildren() - Method in interface org.apache.curator.framework.api.CuratorEvent
 
getChildren() - Method in interface org.apache.curator.framework.CuratorFramework
Start a get children builder
getChildren() - Method in class org.apache.curator.framework.imps.CuratorFrameworkImpl
 
getChildren() - Method in class org.apache.curator.framework.recipes.queue.DistributedQueue
 
getChildren() - Method in interface org.apache.curator.x.async.api.WatchableAsyncCuratorFramework
Start a get children builder
getChildren() - Method in class org.apache.curator.x.async.details.AsyncCuratorFrameworkImpl
 
getChildren(CuratorProjection, GetChildrenSpec) - Method in class org.apache.curator.x.rpc.idl.services.CuratorProjectionService
 
GetChildrenBuilder - Interface in org.apache.curator.framework.api
 
GetChildrenBuilderImpl - Class in org.apache.curator.framework.imps
 
GetChildrenBuilderImpl(CuratorFrameworkImpl, Watcher, Backgrounding, Stat) - Constructor for class org.apache.curator.framework.imps.GetChildrenBuilderImpl
 
getChildrenForEntering() - Method in class org.apache.curator.framework.recipes.barriers.DistributedDoubleBarrier
 
GetChildrenSpec - Class in org.apache.curator.x.rpc.idl.structs
 
GetChildrenSpec() - Constructor for class org.apache.curator.x.rpc.idl.structs.GetChildrenSpec
 
GetChildrenSpec(String, boolean, String) - Constructor for class org.apache.curator.x.rpc.idl.structs.GetChildrenSpec
 
getChildWatches(ZooKeeper) - Static method in class org.apache.curator.test.WatchersDebug
 
getClient() - Method in class org.apache.curator.x.rpc.connections.CuratorEntry
 
getCode() - Method in interface org.apache.curator.x.async.AsyncResult
Return the ZooKeeper result code.
getCode() - Method in class org.apache.curator.x.async.details.AsyncResultImpl
 
getCompressionProvider() - Method in class org.apache.curator.framework.CuratorFrameworkFactory.Builder
 
getConfig() - Method in interface org.apache.curator.framework.CuratorFramework
Start a getConfig builder
getConfig() - Method in class org.apache.curator.framework.imps.CuratorFrameworkImpl
 
getConfig() - Method in interface org.apache.curator.x.async.api.WatchableAsyncCuratorFramework
Start a getConfig builder
getConfig() - Method in class org.apache.curator.x.async.details.AsyncCuratorFrameworkImpl
 
GetConfigBuilder - Interface in org.apache.curator.framework.api
 
GetConfigBuilderImpl - Class in org.apache.curator.framework.imps
 
GetConfigBuilderImpl(CuratorFrameworkImpl) - Constructor for class org.apache.curator.framework.imps.GetConfigBuilderImpl
 
GetConfigBuilderImpl(CuratorFrameworkImpl, Backgrounding, Watcher, Stat) - Constructor for class org.apache.curator.framework.imps.GetConfigBuilderImpl
 
getConnectionHandlingPolicy() - Method in class org.apache.curator.CuratorZookeeperClient
Return the configured connection handling policy
getConnectionHandlingPolicy() - Method in class org.apache.curator.framework.CuratorFrameworkFactory.Builder
 
getConnections() - Method in class org.apache.curator.x.rpc.configuration.Configuration
 
getConnectionStateErrorPolicy() - Method in interface org.apache.curator.framework.CuratorFramework
Return the configured error policy
getConnectionStateErrorPolicy() - Method in class org.apache.curator.framework.CuratorFrameworkFactory.Builder
 
getConnectionStateErrorPolicy() - Method in class org.apache.curator.framework.imps.CuratorFrameworkImpl
 
getConnectionStateListenable() - Method in interface org.apache.curator.framework.CuratorFramework
Returns the listenable interface for the Connect State
getConnectionStateListenable() - Method in class org.apache.curator.framework.imps.CuratorFrameworkImpl
 
getConnectionString() - Method in interface org.apache.curator.ensemble.EnsembleProvider
Return the current connection string to use.
getConnectionString() - Method in class org.apache.curator.ensemble.exhibitor.ExhibitorEnsembleProvider
 
getConnectionString() - Method in class org.apache.curator.ensemble.fixed.FixedEnsembleProvider
 
getConnectionString() - Method in class org.apache.curator.x.rpc.configuration.ConnectionConfiguration
 
getConnectionTimeout() - Method in class org.apache.curator.x.rpc.configuration.ConnectionConfiguration
 
getConnectionTimeoutMs() - Method in class org.apache.curator.CuratorZookeeperClient
Return the configured connection timeout
getConnectionTimeoutMs() - Method in class org.apache.curator.framework.CuratorFrameworkFactory.Builder
 
getConnectString() - Method in class org.apache.curator.test.InstanceSpec
 
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
getContainerCreateMode() - Static method in class org.apache.curator.utils.ZKPaths
 
getContext() - Method in interface org.apache.curator.framework.api.CuratorEvent
 
getContext(Class<?>) - Method in class org.apache.curator.x.discovery.server.contexts.GenericDiscoveryContext
 
getContext(Class<?>) - Method in class org.apache.curator.x.discovery.server.contexts.IntegerDiscoveryContext
 
getContext(Class<?>) - Method in class org.apache.curator.x.discovery.server.contexts.StringDiscoveryContext
 
getCount() - Method in class org.apache.curator.framework.recipes.shared.SharedCount
 
getCount() - Method in interface org.apache.curator.framework.recipes.shared.SharedCountReader
Return the current value of the count
getCreateMode(boolean) - Method in enum org.apache.curator.framework.recipes.nodes.PersistentEphemeralNode.Mode
Deprecated.
 
getCuratorListenable() - Method in interface org.apache.curator.framework.CuratorFramework
Returns the listenable interface for events
getCuratorListenable() - Method in class org.apache.curator.framework.imps.CuratorFrameworkImpl
 
getCurrentChildren(String) - Method in class org.apache.curator.framework.recipes.cache.TreeCache
Return the current set of children at the given path, mapped by child name.
getCurrentConfig() - Method in interface org.apache.curator.framework.CuratorFramework
Current maintains a cached view of the Zookeeper quorum config.
getCurrentConfig() - Method in class org.apache.curator.framework.imps.CuratorFrameworkImpl
 
getCurrentConfig() - Method in class org.apache.curator.framework.imps.EnsembleTracker
Return the current quorum config
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.
getCurrentData() - Method in class org.apache.curator.framework.recipes.cache.NodeCache
Return the current data.
getCurrentData() - Method in class org.apache.curator.framework.recipes.cache.PathChildrenCache
Return the current data.
getCurrentData(String) - Method in class org.apache.curator.framework.recipes.cache.PathChildrenCache
Return the current data for the given path.
getCurrentData(String) - Method in class org.apache.curator.framework.recipes.cache.TreeCache
Return the current data for the given path.
getCurrentMembers() - Method in class org.apache.curator.framework.recipes.nodes.GroupMember
Return the current view of membership.
getCustomProperties() - Method in class org.apache.curator.test.InstanceSpec
 
getData() - Method in interface org.apache.curator.framework.api.CuratorEvent
 
getData() - Method in interface org.apache.curator.framework.CuratorFramework
Start a get data builder
getData() - Method in interface org.apache.curator.framework.CuratorTempFramework
Start a get data builder
getData() - Method in class org.apache.curator.framework.imps.CuratorFrameworkImpl
 
getData() - Method in class org.apache.curator.framework.imps.CuratorTempFrameworkImpl
 
getData() - Method in class org.apache.curator.framework.recipes.cache.ChildData
Returns the node data for this child when the cache mode is set to cache data.
getData() - Method in class org.apache.curator.framework.recipes.cache.PathChildrenCacheEvent
 
getData() - Method in class org.apache.curator.framework.recipes.cache.TreeCacheEvent
 
getData() - Method in interface org.apache.curator.framework.recipes.locks.Lease
Return the data stored in the node for this lease
getData() - Method in class org.apache.curator.framework.recipes.nodes.PersistentNode
Return the current value of our data
getData() - Method in class org.apache.curator.framework.schema.SchemaViolation.ViolatorData
The data used in the API or null
getData() - Method in interface org.apache.curator.x.async.api.WatchableAsyncCuratorFramework
Start a get data builder
getData() - Method in class org.apache.curator.x.async.details.AsyncCuratorFrameworkImpl
 
getData(CuratorProjection, GetDataSpec) - Method in class org.apache.curator.x.rpc.idl.services.CuratorProjectionService
 
GetDataBuilder - Interface in org.apache.curator.framework.api
 
GetDataBuilderImpl - Class in org.apache.curator.framework.imps
 
GetDataBuilderImpl(CuratorFrameworkImpl, Stat, Watcher, Backgrounding, boolean) - Constructor for class org.apache.curator.framework.imps.GetDataBuilderImpl
 
getDataDirectory() - Method in class org.apache.curator.test.InstanceSpec
 
GetDataSpec - Class in org.apache.curator.x.rpc.idl.structs
 
GetDataSpec() - Constructor for class org.apache.curator.x.rpc.idl.structs.GetDataSpec
 
GetDataSpec(String, boolean, String, boolean) - Constructor for class org.apache.curator.x.rpc.idl.structs.GetDataSpec
 
GetDataWatchBackgroundStatable - Interface in org.apache.curator.framework.api
 
getDataWatches(ZooKeeper) - Static method in class org.apache.curator.test.WatchersDebug
 
getDefaultAcl() - Method in interface org.apache.curator.framework.api.ACLProvider
Return the ACL list to use by default (usually ZooDefs.Ids#OPEN_ACL_UNSAFE).
getDefaultAcl() - Method in class org.apache.curator.framework.imps.DefaultACLProvider
 
getDefaultAcl() - Method in interface org.apache.curator.utils.InternalACLProvider
Return the ACL list to use by default (usually ZooDefs.Ids#OPEN_ACL_UNSAFE).
getDefaultData() - Method in class org.apache.curator.framework.CuratorFrameworkFactory.Builder
 
getDefaultRetrySleeper() - Static method in class org.apache.curator.RetryLoop
Returns the default retry sleeper
getDefaultSchemaSet() - Static method in class org.apache.curator.framework.schema.SchemaSet
Return the default (empty) schema set
getDelay(String) - Method in class org.apache.curator.framework.recipes.queue.DistributedQueue
 
getDeprecated(String, String) - Method in class org.apache.curator.x.discovery.server.rest.DiscoveryResource
Deprecated.
getDescription() - Method in class discovery.InstanceDetails
 
getDocumentation() - Method in class org.apache.curator.framework.schema.Schema
 
getElectionPort() - Method in class org.apache.curator.test.InstanceSpec
 
getEnsembleProvider() - Method in class org.apache.curator.framework.CuratorFrameworkFactory.Builder
 
getEphemeral() - Method in class org.apache.curator.framework.schema.Schema
 
getError() - Method in class org.apache.curator.framework.api.transaction.CuratorTransactionResult
Returns the operation generated error or 0 i.e.
getErrorThreshold() - Method in class org.apache.curator.x.discovery.DownInstancePolicy
 
getException() - Method in interface org.apache.curator.x.async.AsyncResult
An optional wrapper around any general exception
getException() - Method in class org.apache.curator.x.async.details.AsyncResultImpl
 
getExistWatches(ZooKeeper) - Static method in class org.apache.curator.test.WatchersDebug
 
getFirstProcessor() - Method in class org.apache.curator.test.TestingZooKeeperMain.TestZooKeeperServer
 
getForPath() - Method in class org.apache.curator.framework.api.transaction.CuratorTransactionResult
Returns the path that was passed to the operation when added
getForPath() - Method in class org.apache.curator.framework.api.transaction.TypeAndPath
 
getHostname() - Method in class org.apache.curator.test.InstanceSpec
 
getHostnames() - Method in class org.apache.curator.ensemble.exhibitor.Exhibitors
 
getId() - Method in class org.apache.curator.framework.recipes.leader.LeaderLatch
Return this instance's participant Id
getId() - Method in class org.apache.curator.framework.recipes.leader.LeaderSelector
Return the ID that was set via LeaderSelector.setId(String)
getId() - Method in class org.apache.curator.framework.recipes.leader.Participant
Returns the ID set via LeaderSelector.setId(String)
getId() - Method in class org.apache.curator.x.discovery.ServiceInstance
 
getInitialData() - Method in class org.apache.curator.framework.recipes.cache.PathChildrenCacheEvent
Special purpose method.
getInstance() - Method in class org.apache.curator.x.discovery.details.ServiceProviderImpl
Return an instance for a single use.
getInstance(InstanceProvider<T>) - Method in interface org.apache.curator.x.discovery.ProviderStrategy
Given a source of instances, return one of them for a single use.
getInstance() - Method in interface org.apache.curator.x.discovery.ServiceProvider
Return an instance for a single use.
getInstance(InstanceProvider<T>) - Method in class org.apache.curator.x.discovery.strategies.RandomStrategy
 
getInstance(InstanceProvider<T>) - Method in class org.apache.curator.x.discovery.strategies.RoundRobinStrategy
 
getInstance(InstanceProvider<T>) - Method in class org.apache.curator.x.discovery.strategies.StickyStrategy
 
getInstance(CuratorProjection, DiscoveryProviderProjection) - Method in class org.apache.curator.x.rpc.idl.discovery.DiscoveryService
 
getInstanceIndex() - Method in class org.apache.curator.CuratorZookeeperClient
Every time a new ZooKeeper instance is allocated, the "instance index" is incremented.
getInstanceNumber() - Method in class org.apache.curator.x.discovery.strategies.StickyStrategy
Each time a new instance is picked, an internal counter is incremented.
getInstanceRefreshMs() - Method in class org.apache.curator.x.discovery.server.contexts.GenericDiscoveryContext
 
getInstanceRefreshMs() - Method in class org.apache.curator.x.discovery.server.contexts.IntegerDiscoveryContext
 
getInstanceRefreshMs() - Method in class org.apache.curator.x.discovery.server.contexts.StringDiscoveryContext
 
getInstanceRefreshMs() - Method in interface org.apache.curator.x.discovery.server.rest.DiscoveryContext
Return the threshold in milliseconds to consider a registration stale
getInstances() - Method in class org.apache.curator.test.TestingCluster
Returns the set of servers in the ensemble
getInstances() - Method in interface org.apache.curator.x.discovery.details.InstanceProvider
Return the current available set of instances
getInstances() - Method in class org.apache.curator.x.discovery.details.ServiceCacheImpl
 
getInstances() - Method in interface org.apache.curator.x.discovery.ServiceCache
Return the current list of instances.
getInstanceSpec(int) - Method in class org.apache.curator.test.QuorumConfigBuilder
 
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
 
getItems() - Method in class org.apache.curator.framework.recipes.queue.BlockingQueueConsumer
Return any currently queued items without removing them from the queue
getKeeperState() - Method in exception org.apache.curator.x.async.AsyncEventException
Returns the error condition that temporarily triggered the watcher.
getLastMessageCount() - Method in class org.apache.curator.framework.recipes.queue.DistributedDelayQueue
Return the most recent message count from the queue.
getLastMessageCount() - Method in class org.apache.curator.framework.recipes.queue.DistributedIdQueue
 
getLastMessageCount() - Method in class org.apache.curator.framework.recipes.queue.DistributedPriorityQueue
Return the most recent message count from the queue.
getLastMessageCount() - Method in class org.apache.curator.framework.recipes.queue.DistributedQueue
Return the most recent message count from the queue.
getLastMessageCount() - Method in interface org.apache.curator.framework.recipes.queue.QueueBase
Return the most recent message count from the queue.
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
 
getLeader() - Method in class org.apache.curator.framework.recipes.leader.LeaderLatch
Return the id for the current leader.
getLeader() - Method in class org.apache.curator.framework.recipes.leader.LeaderSelector
Return the id for the current leader.
getLeaderParticipants(CuratorProjection, LeaderProjection) - Method in class org.apache.curator.x.rpc.idl.services.CuratorProjectionService
 
getListenable() - Method in class org.apache.curator.framework.recipes.cache.NodeCache
Return the cache listenable
getListenable() - Method in class org.apache.curator.framework.recipes.cache.PathChildrenCache
Return the cache listenable
getListenable() - Method in class org.apache.curator.framework.recipes.cache.TreeCache
Return the cache listenable
getListenable() - Method in class org.apache.curator.framework.recipes.shared.SharedValue
Returns the listenable
getListenable() - Method in interface org.apache.curator.framework.recipes.shared.SharedValueReader
Returns the listenable
getListenable() - Method in class org.apache.curator.framework.state.ConnectionStateManager
Return the listenable
getListener() - Method in class org.apache.curator.x.async.details.Filters
 
getLocalAddress() - Static method in class org.apache.curator.framework.CuratorFrameworkFactory
Return the local address as bytes that can be used as a node payload
getLocalIpFilter() - Static method in class org.apache.curator.x.discovery.ServiceInstanceBuilder
Return the current local ip filter used by ServiceInstanceBuilder.getAllLocalIPs()
getLockNodeBytes() - Method in class org.apache.curator.framework.recipes.locks.InterProcessMutex
 
getLockPath() - Method in class org.apache.curator.framework.recipes.locks.InterProcessMutex
 
getLogging() - Method in class org.apache.curator.x.rpc.configuration.Configuration
 
getMaxClientCnxns() - Method in class org.apache.curator.test.InstanceSpec
 
getMaxCloseWaitMs() - Method in class org.apache.curator.framework.CuratorFrameworkFactory.Builder
 
getMaxRetries() - Method in class org.apache.curator.x.rpc.configuration.BoundedExponentialBackoffRetryConfiguration
 
getMaxRetries() - Method in class org.apache.curator.x.rpc.configuration.ExponentialBackoffRetryConfiguration
 
getMaxSleepTime() - Method in class org.apache.curator.x.rpc.configuration.BoundedExponentialBackoffRetryConfiguration
 
getMaxSleepTimeMs() - Method in class org.apache.curator.retry.BoundedExponentialBackoffRetry
 
getMetadata() - Method in class org.apache.curator.framework.schema.Schema
 
getN() - Method in class org.apache.curator.x.rpc.configuration.RetryNTimesConfiguration
 
getName() - Method in class org.apache.curator.drivers.EventTrace
 
getName() - Method in class org.apache.curator.drivers.OperationTrace
 
getName() - Method in interface org.apache.curator.framework.api.CuratorEvent
 
getName() - Method in class org.apache.curator.framework.schema.Schema
 
getName() - Method in class org.apache.curator.x.discovery.ServiceInstance
 
getName() - Method in class org.apache.curator.x.rpc.configuration.ConnectionConfiguration
 
getNamedPath(CuratorFramework, String) - Static method in class org.apache.curator.framework.schema.SchemaSet
Utility to return a ZNode path for the given name
getNamedSchema(String) - Method in class org.apache.curator.framework.schema.SchemaSet
Return the schema with the given key/name
getNames() - Method in class org.apache.curator.x.discovery.server.entity.ServiceNames
 
getNamespace() - Method in interface org.apache.curator.framework.CuratorFramework
Return the current namespace or "" if none
getNamespace() - Method in class org.apache.curator.framework.CuratorFrameworkFactory.Builder
 
getNamespace() - Method in class org.apache.curator.framework.imps.CuratorFrameworkImpl
 
getNamespace() - Method in class org.apache.curator.x.rpc.configuration.ConnectionConfiguration
 
getNextEvent(CuratorProjection) - Method in class org.apache.curator.x.rpc.idl.services.EventService
 
getNode() - Method in class org.apache.curator.utils.ZKPaths.PathAndNode
 
getNodeCacheData(CuratorProjection, NodeCacheProjection) - Method in class org.apache.curator.x.rpc.idl.services.CuratorProjectionService
 
getNodeFromPath(String) - Static method in class org.apache.curator.utils.ZKPaths
Given a full path, return the node name.
getNodeName() - Method in interface org.apache.curator.framework.recipes.locks.Lease
Return the the node for this lease
getOpResults() - Method in interface org.apache.curator.framework.api.CuratorEvent
 
getOptimisticTimeMs() - Method in class org.apache.curator.framework.recipes.atomic.AtomicStats
Returns the time spent trying the operation with optimistic locks
getOptimisticTries() - Method in class org.apache.curator.framework.recipes.atomic.AtomicStats
Returns the number of optimistic locks used to perform the operation
getParticipantNodes() - Method in class org.apache.curator.framework.recipes.locks.InterProcessMutex
Return a sorted list of all current nodes participating in the lock
getParticipantNodes() - Method in class org.apache.curator.framework.recipes.locks.InterProcessSemaphoreV2
Return a list of all current nodes participating in the semaphore
getParticipantNodes(CuratorFramework, String, String, LockInternalsSorter) - Static method in class org.apache.curator.framework.recipes.locks.LockInternals
 
getParticipants() - Method in class org.apache.curator.framework.recipes.leader.LeaderLatch
Returns the set of current participants in the leader selection
getParticipants() - Method in class org.apache.curator.framework.recipes.leader.LeaderSelector
Returns the set of current participants in the leader selection
getParts() - Method in class org.apache.curator.x.discovery.UriSpec
 
getPath() - Method in class org.apache.curator.drivers.OperationTrace
 
getPath() - Method in interface org.apache.curator.framework.api.CuratorEvent
 
getPath() - Method in class org.apache.curator.framework.recipes.cache.ChildData
Returns the full path of the this child
getPath() - Method in class org.apache.curator.framework.schema.Schema
 
getPath() - Method in class org.apache.curator.framework.schema.SchemaViolation.ViolatorData
The path used in the API or null
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.
getPathChildrenCacheData(CuratorProjection, PathChildrenCacheProjection) - Method in class org.apache.curator.x.rpc.idl.services.CuratorProjectionService
 
getPathChildrenCacheDataForPath(CuratorProjection, PathChildrenCacheProjection, String) - Method in class org.apache.curator.x.rpc.idl.services.CuratorProjectionService
 
getPathRegex() - Method in class org.apache.curator.framework.schema.Schema
 
getPathToWatch() - Method in class org.apache.curator.framework.recipes.locks.PredicateResults
 
getPayload() - Method in class org.apache.curator.x.discovery.ServiceInstance
 
getPingTime() - Method in class org.apache.curator.x.rpc.configuration.Configuration
 
getPort() - Method in class org.apache.curator.test.InstanceSpec
 
getPort() - Method in class org.apache.curator.test.TestingServer
Return the port being used
getPort() - Method in class org.apache.curator.x.discovery.ServiceInstance
 
getProcessName(Class<?>) - Static method in class org.apache.curator.utils.ThreadUtils
 
getProjectionExpiration() - Method in class org.apache.curator.x.rpc.configuration.Configuration
 
getPromotedLockTries() - Method in class org.apache.curator.framework.recipes.atomic.AtomicStats
Returns the number of mutex locks used to perform the operation
getPromotedTimeMs() - Method in class org.apache.curator.framework.recipes.atomic.AtomicStats
Returns the time spent trying the operation with mutex locks
getProviderStrategy() - Method in class org.apache.curator.x.discovery.server.contexts.GenericDiscoveryContext
 
getProviderStrategy() - Method in class org.apache.curator.x.discovery.server.contexts.IntegerDiscoveryContext
 
getProviderStrategy() - Method in class org.apache.curator.x.discovery.server.contexts.StringDiscoveryContext
 
getProviderStrategy() - Method in interface org.apache.curator.x.discovery.server.rest.DiscoveryContext
Return the provider strategy to use for DiscoveryResource.getAny(String)
getPutListenerContainer() - Method in class org.apache.curator.framework.recipes.queue.DistributedDelayQueue
Return the manager for put listeners
getPutListenerContainer() - Method in class org.apache.curator.framework.recipes.queue.DistributedIdQueue
 
getPutListenerContainer() - Method in class org.apache.curator.framework.recipes.queue.DistributedPriorityQueue
Return the manager for put listeners
getPutListenerContainer() - Method in class org.apache.curator.framework.recipes.queue.DistributedQueue
Return the manager for put listeners
getPutListenerContainer() - Method in interface org.apache.curator.framework.recipes.queue.QueueBase
Return the manager for put listeners
getQueue() - Method in class org.apache.curator.framework.recipes.queue.QueueSharder
Return one of the managed queues - the selection method cannot be relied on.
getQueuePaths() - Method in class org.apache.curator.framework.recipes.queue.QueueSharder
Return the current set of shard paths
getQuorumPeer() - Method in class org.apache.curator.test.TestingZooKeeperMain
 
getQuorumPeer() - Method in class org.apache.curator.test.TestingZooKeeperServer
 
getQuorumPeer() - Method in interface org.apache.curator.test.ZooKeeperMainFace
 
getQuorumPort() - Method in class org.apache.curator.test.InstanceSpec
 
getRandomPort() - Static method in class org.apache.curator.test.InstanceSpec
 
getRaw(String, int, String, String) - Method in class org.apache.curator.ensemble.exhibitor.DefaultExhibitorRestClient
 
getRaw(String, int, String, String) - Method in interface org.apache.curator.ensemble.exhibitor.ExhibitorRestClient
Connect to the given Exhibitor and return the raw result
getRawException() - Method in interface org.apache.curator.x.async.AsyncResult
Return any general exception or null
getRawException() - Method in class org.apache.curator.x.async.details.AsyncResultImpl
 
getRawPath() - Method in class org.apache.curator.framework.schema.Schema
Return the raw path for this schema.
getRawValue() - Method in interface org.apache.curator.x.async.AsyncResult
Returns the raw result of the ZooKeeper method or null
getRawValue() - Method in class org.apache.curator.x.async.details.AsyncResultImpl
 
getRegistrationTimeUTC() - Method in class org.apache.curator.x.discovery.ServiceInstance
 
getRequestBytesLength() - Method in class org.apache.curator.drivers.OperationTrace
 
getResponseBytesLength() - Method in class org.apache.curator.drivers.OperationTrace
 
getRestPort() - Method in class org.apache.curator.ensemble.exhibitor.Exhibitors
 
getResultCode() - Method in interface org.apache.curator.framework.api.CuratorEvent
 
getResultFilter() - Method in class org.apache.curator.x.async.details.Filters
 
getResultPath() - Method in class org.apache.curator.framework.api.transaction.CuratorTransactionResult
Returns the operation generated path or null.
getResultStat() - Method in class org.apache.curator.framework.api.transaction.CuratorTransactionResult
Returns the operation generated stat or null.
getRetry() - Method in class org.apache.curator.x.rpc.configuration.ConnectionConfiguration
 
getRetryPolicy() - Method in class org.apache.curator.CuratorZookeeperClient
Return the current retry policy
getRetryPolicy() - Method in class org.apache.curator.framework.CuratorFrameworkFactory.Builder
 
getReturnCode() - Method in class org.apache.curator.drivers.OperationTrace
 
getSchema(String) - Method in class org.apache.curator.framework.schema.SchemaSet
Find the first matching schema for the path and return it
getSchema() - Method in exception org.apache.curator.framework.schema.SchemaViolation
 
getSchemas() - Method in class org.apache.curator.framework.schema.SchemaSet
Return the schemas
getSchemas() - Method in class org.apache.curator.framework.schema.SchemaSetLoader
 
getSchemaSet() - Method in interface org.apache.curator.framework.CuratorFramework
Return this instance's schema set
getSchemaSet() - Method in class org.apache.curator.framework.CuratorFrameworkFactory.Builder
 
getSchemaSet() - Method in class org.apache.curator.framework.imps.CuratorFrameworkImpl
 
getSchemaValidator() - Method in class org.apache.curator.framework.schema.Schema
 
getSchemaValidator(String) - Method in interface org.apache.curator.framework.schema.SchemaSetLoader.SchemaValidatorMapper
 
getScheme() - Method in class org.apache.curator.framework.AuthInfo
 
getScheme() - Method in class org.apache.curator.x.rpc.configuration.AuthorizationConfiguration
 
getSequential() - Method in class org.apache.curator.framework.schema.Schema
 
getServerId() - Method in class org.apache.curator.test.InstanceSpec
 
getServers() - Method in class org.apache.curator.test.TestingCluster
 
getServiceDiscovery() - Method in class org.apache.curator.x.discovery.server.contexts.GenericDiscoveryContext
 
getServiceDiscovery() - Method in class org.apache.curator.x.discovery.server.contexts.IntegerDiscoveryContext
 
getServiceDiscovery() - Method in class org.apache.curator.x.discovery.server.contexts.StringDiscoveryContext
 
getServiceDiscovery() - Method in interface org.apache.curator.x.discovery.server.rest.DiscoveryContext
Return the service singleton
getServices() - Method in class org.apache.curator.x.discovery.server.entity.ServiceInstances
 
getServiceType() - Method in class org.apache.curator.x.discovery.ServiceInstance
 
getSessionId() - Method in class org.apache.curator.drivers.EventTrace
 
getSessionId() - Method in class org.apache.curator.drivers.OperationTrace
 
getSessionLength() - Method in class org.apache.curator.x.rpc.configuration.ConnectionConfiguration
 
getSessionTimeoutMs() - Method in class org.apache.curator.framework.CuratorFrameworkFactory.Builder
 
getShardQty() - Method in class org.apache.curator.framework.recipes.queue.QueueSharder
Return the current number of mananged queues
getSimulatedSessionExpirationPercent() - Method in class org.apache.curator.connection.ClassicConnectionHandlingPolicy
 
getSimulatedSessionExpirationPercent() - Method in interface org.apache.curator.connection.ConnectionHandlingPolicy
Prior to 3.0.0, Curator did not try to manage session expiration other than the functionality provided by ZooKeeper itself.
getSimulatedSessionExpirationPercent() - Method in class org.apache.curator.connection.StandardConnectionHandlingPolicy
 
getSize(ServiceInstance<T>, Class<?>, Type, Annotation[], MediaType) - Method in class org.apache.curator.x.discovery.server.entity.JsonServiceInstanceMarshaller
 
getSize(ServiceInstances<T>, Class<?>, Type, Annotation[], MediaType) - Method in class org.apache.curator.x.discovery.server.entity.JsonServiceInstancesMarshaller
 
getSize(ServiceNames, Class<?>, Type, Annotation[], MediaType) - Method in class org.apache.curator.x.discovery.server.entity.JsonServiceNamesMarshaller
 
getSleepBetweenRetries() - Method in class org.apache.curator.x.rpc.configuration.RetryNTimesConfiguration
 
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(CuratorFramework, String, String, LockInternalsSorter) - Static method in class org.apache.curator.framework.recipes.locks.LockInternals
 
getSortedChildren(String, LockInternalsSorter, List<String>) - Static method in class org.apache.curator.framework.recipes.locks.LockInternals
 
getSortedChildren(ZooKeeper, String) - Static method in class org.apache.curator.utils.ZKPaths
Return the children of the given path sorted by sequence number
getSslPort() - Method in class org.apache.curator.x.discovery.ServiceInstance
 
getStat() - Method in class org.apache.curator.drivers.OperationTrace
 
getStat() - Method in interface org.apache.curator.framework.api.CuratorEvent
 
getStat() - Method in class org.apache.curator.framework.recipes.cache.ChildData
Returns the stat data for this child
getState() - Method in interface org.apache.curator.framework.CuratorFramework
Returns the state of this instance
getState() - Method in class org.apache.curator.framework.imps.CuratorFrameworkImpl
 
getState() - Method in class org.apache.curator.framework.recipes.leader.LeaderLatch
Returns this instances current state, this is the only way to verify that the object has been closed before closing again.
getStats() - Method in interface org.apache.curator.framework.recipes.atomic.AtomicValue
Returns debugging stats about the operation
getsTheLock(CuratorFramework, List<String>, String, int) - Method in interface org.apache.curator.framework.recipes.locks.LockInternalsDriver
 
getsTheLock() - Method in class org.apache.curator.framework.recipes.locks.PredicateResults
 
getsTheLock(CuratorFramework, List<String>, String, int) - Method in class org.apache.curator.framework.recipes.locks.StandardLockInternalsDriver
 
getTempDirectory() - Method in class org.apache.curator.test.TestingServer
Returns the temp directory being used
getThing(String, Class<T>) - Method in class org.apache.curator.x.rpc.connections.CuratorEntry
 
getThisInstance() - Method in class discovery.ExampleServer
 
getThreadFactory() - Method in class org.apache.curator.framework.CuratorFrameworkFactory.Builder
 
getThrift() - Method in class org.apache.curator.x.rpc.configuration.Configuration
 
getTickTime() - Method in class org.apache.curator.test.InstanceSpec
 
getTimeoutMs() - Method in class org.apache.curator.x.discovery.DownInstancePolicy
 
getTracerDriver() - Method in class org.apache.curator.CuratorZookeeperClient
Return the current tracing driver
getType() - Method in interface org.apache.curator.framework.api.CuratorEvent
check here first - this value determines the type of event and which methods will have valid values
getType() - Method in class org.apache.curator.framework.api.transaction.CuratorTransactionResult
Returns the operation type
getType() - Method in class org.apache.curator.framework.api.transaction.TypeAndPath
 
getType() - Method in class org.apache.curator.framework.recipes.cache.PathChildrenCacheEvent
 
getType() - Method in class org.apache.curator.framework.recipes.cache.TreeCacheEvent
 
getTypeAndPath() - Method in interface org.apache.curator.framework.api.transaction.CuratorOp
 
getUnhandledErrorListenable() - Method in interface org.apache.curator.framework.CuratorFramework
Returns the listenable interface for unhandled errors
getUnhandledErrorListenable() - Method in class org.apache.curator.framework.imps.CuratorFrameworkImpl
 
getUnhandledErrorListenable() - Method in class org.apache.curator.framework.recipes.cache.TreeCache
Allows catching unhandled errors in asynchornous operations.
getUriSpec() - Method in class org.apache.curator.x.discovery.ServiceInstance
 
getValue() - Method in class org.apache.curator.framework.recipes.shared.SharedValue
 
getValue() - Method in interface org.apache.curator.framework.recipes.shared.SharedValueReader
Return the current value of the count
getValue() - Method in class org.apache.curator.framework.recipes.shared.VersionedValue
 
getValue() - Method in interface org.apache.curator.x.async.AsyncResult
An optional wrapper around the ZooKeeper method result
getValue() - Method in class org.apache.curator.x.async.details.AsyncResultImpl
 
getValue() - Method in class org.apache.curator.x.discovery.UriSpec.Part
 
getVersion() - Method in class org.apache.curator.framework.imps.DeleteBuilderImpl
 
getVersion() - Method in class org.apache.curator.framework.recipes.shared.VersionedValue
 
getVersionedValue() - Method in class org.apache.curator.framework.recipes.shared.SharedCount
 
getVersionedValue() - Method in interface org.apache.curator.framework.recipes.shared.SharedCountReader
Return the current count and version
getVersionedValue() - Method in class org.apache.curator.framework.recipes.shared.SharedValue
 
getVersionedValue() - Method in interface org.apache.curator.framework.recipes.shared.SharedValueReader
Return the current version and value
getViolation() - Method in exception org.apache.curator.framework.schema.SchemaViolation
 
getViolatorData() - Method in exception org.apache.curator.framework.schema.SchemaViolation
 
getWatched() - Method in class org.apache.curator.framework.schema.Schema
 
getWatchedEvent() - Method in interface org.apache.curator.framework.api.CuratorEvent
If CuratorEvent.getType() returns CuratorEventType.WATCHED this will return the WatchedEvent
getWatcherFilter() - Method in class org.apache.curator.x.async.details.Filters
 
getZooKeeper() - Method in class org.apache.curator.CuratorZookeeperClient
Return the managed ZK instance.
getZookeeperClient() - Method in interface org.apache.curator.framework.CuratorFramework
Return the managed zookeeper client
getZookeeperClient() - Method in class org.apache.curator.framework.imps.CuratorFrameworkImpl
 
getZookeeperFactory() - Method in class org.apache.curator.framework.CuratorFrameworkFactory.Builder
 
GroupMember - Class in org.apache.curator.framework.recipes.nodes
Group membership management.
GroupMember(CuratorFramework, String, String) - Constructor for class org.apache.curator.framework.recipes.nodes.GroupMember
 
GroupMember(CuratorFramework, String, String, byte[]) - Constructor for class org.apache.curator.framework.recipes.nodes.GroupMember
 
Guaranteeable<T> - Interface in org.apache.curator.framework.api
 
GuaranteeableDeletable - Interface in org.apache.curator.framework.api
Solves this edge case: deleting a node can fail due to connection issues.
guaranteed() - Method in interface org.apache.curator.framework.api.Guaranteeable
Solves edge cases where an operation may succeed on the server but connection failure occurs before a response can be successfully returned to the client.
guaranteed() - Method in class org.apache.curator.framework.imps.DeleteBuilderImpl
 
guaranteed() - Method in class org.apache.curator.framework.imps.RemoveWatchesBuilderImpl
 
guaranteed - Variable in class org.apache.curator.x.rpc.idl.structs.DeleteSpec
 
guaranteedDelete(CuratorFramework, String) - Static method in class framework.CrudExamples
 
GzipCompressionProvider - Class in org.apache.curator.framework.imps
 
GzipCompressionProvider() - Constructor for class org.apache.curator.framework.imps.GzipCompressionProvider
 

H

handleException(Throwable) - Method in class org.apache.curator.framework.recipes.cache.NodeCache
Default behavior is just to log the exception
handleException(Throwable) - Method in class org.apache.curator.framework.recipes.cache.PathChildrenCache
Default behavior is just to log the exception
hasContainerSupport() - Static method in class org.apache.curator.utils.ZKPaths
Returns true if the version of ZooKeeper client in use supports containers
hashCode() - Method in class org.apache.curator.framework.recipes.cache.ChildData
 
hashCode() - Method in class org.apache.curator.framework.recipes.leader.Participant
 
hashCode() - Method in class org.apache.curator.framework.schema.Schema
 
hashCode() - Method in class org.apache.curator.test.InstanceSpec
 
hashCode() - Method in class org.apache.curator.x.async.details.AsyncResultImpl
 
hashCode() - Method in class org.apache.curator.x.discovery.ServiceInstance
 
hashCode() - Method in class org.apache.curator.x.discovery.UriSpec
 
hashCode() - Method in class org.apache.curator.x.discovery.UriSpec.Part
 
hasLeadership() - Method in class org.apache.curator.framework.recipes.leader.LeaderLatch
Return true if leadership is currently held by this instance
hasLeadership() - Method in class org.apache.curator.framework.recipes.leader.LeaderSelector
Return true if leadership is currently held by this instance
hasOutstanding() - Method in class org.apache.curator.framework.imps.EnsembleTracker
 

I

id(String) - Method in class org.apache.curator.x.discovery.ServiceInstanceBuilder
 
id - Variable in class org.apache.curator.x.rpc.idl.discovery.DiscoveryInstance
 
id - Variable in class org.apache.curator.x.rpc.idl.discovery.DiscoveryProjection
 
id - Variable in class org.apache.curator.x.rpc.idl.discovery.DiscoveryProviderProjection
 
id - Variable in class org.apache.curator.x.rpc.idl.structs.CuratorProjection
 
id - Variable in class org.apache.curator.x.rpc.idl.structs.LeaderProjection
 
id - Variable in class org.apache.curator.x.rpc.idl.structs.LeaseProjection
 
id - Variable in class org.apache.curator.x.rpc.idl.structs.LockProjection
 
id - Variable in class org.apache.curator.x.rpc.idl.structs.NodeCacheProjection
 
id - Variable in class org.apache.curator.x.rpc.idl.structs.PathChildrenCacheProjection
 
id - Variable in class org.apache.curator.x.rpc.idl.structs.PersistentEphemeralNodeProjection
 
id - Variable in class org.apache.curator.x.rpc.idl.structs.RpcAcl
 
id - Variable in class org.apache.curator.x.rpc.idl.structs.RpcId
 
id - Variable in class org.apache.curator.x.rpc.idl.structs.RpcParticipant
 
idFromPath(String) - Method in class org.apache.curator.framework.recipes.nodes.GroupMember
Given a full ZNode path, return the member ID
inBackground() - Method in interface org.apache.curator.framework.api.Backgroundable
Perform the action in the background
inBackground(Object) - Method in interface org.apache.curator.framework.api.Backgroundable
Perform the action in the background
inBackground(BackgroundCallback) - Method in interface org.apache.curator.framework.api.Backgroundable
Perform the action in the background
inBackground(BackgroundCallback, Object) - Method in interface org.apache.curator.framework.api.Backgroundable
Perform the action in the background
inBackground(BackgroundCallback, Executor) - Method in interface org.apache.curator.framework.api.Backgroundable
Perform the action in the background
inBackground(BackgroundCallback, Object, Executor) - Method in interface org.apache.curator.framework.api.Backgroundable
Perform the action in the background
inBackground(BackgroundCallback, Object) - Method in class org.apache.curator.framework.imps.CreateBuilderImpl
 
inBackground(BackgroundCallback, Object, Executor) - Method in class org.apache.curator.framework.imps.CreateBuilderImpl
 
inBackground(BackgroundCallback) - Method in class org.apache.curator.framework.imps.CreateBuilderImpl
 
inBackground(BackgroundCallback, Executor) - Method in class org.apache.curator.framework.imps.CreateBuilderImpl
 
inBackground() - Method in class org.apache.curator.framework.imps.CreateBuilderImpl
 
inBackground(Object) - Method in class org.apache.curator.framework.imps.CreateBuilderImpl
 
inBackground() - Method in class org.apache.curator.framework.imps.CuratorMultiTransactionImpl
 
inBackground(Object) - Method in class org.apache.curator.framework.imps.CuratorMultiTransactionImpl
 
inBackground(BackgroundCallback) - Method in class org.apache.curator.framework.imps.CuratorMultiTransactionImpl
 
inBackground(BackgroundCallback, Object) - Method in class org.apache.curator.framework.imps.CuratorMultiTransactionImpl
 
inBackground(BackgroundCallback, Executor) - Method in class org.apache.curator.framework.imps.CuratorMultiTransactionImpl
 
inBackground(BackgroundCallback, Object, Executor) - Method in class org.apache.curator.framework.imps.CuratorMultiTransactionImpl
 
inBackground(BackgroundCallback, Object) - Method in class org.apache.curator.framework.imps.DeleteBuilderImpl
 
inBackground(BackgroundCallback, Object, Executor) - Method in class org.apache.curator.framework.imps.DeleteBuilderImpl
 
inBackground(BackgroundCallback) - Method in class org.apache.curator.framework.imps.DeleteBuilderImpl
 
inBackground(BackgroundCallback, Executor) - Method in class org.apache.curator.framework.imps.DeleteBuilderImpl
 
inBackground() - Method in class org.apache.curator.framework.imps.DeleteBuilderImpl
 
inBackground(Object) - Method in class org.apache.curator.framework.imps.DeleteBuilderImpl
 
inBackground(BackgroundCallback, Object) - Method in class org.apache.curator.framework.imps.ExistsBuilderImpl
 
inBackground(BackgroundCallback, Object, Executor) - Method in class org.apache.curator.framework.imps.ExistsBuilderImpl
 
inBackground(BackgroundCallback) - Method in class org.apache.curator.framework.imps.ExistsBuilderImpl
 
inBackground(BackgroundCallback, Executor) - Method in class org.apache.curator.framework.imps.ExistsBuilderImpl
 
inBackground() - Method in class org.apache.curator.framework.imps.ExistsBuilderImpl
 
inBackground(Object) - Method in class org.apache.curator.framework.imps.ExistsBuilderImpl
 
inBackground(BackgroundCallback, Object) - Method in class org.apache.curator.framework.imps.GetACLBuilderImpl
 
inBackground(BackgroundCallback, Object, Executor) - Method in class org.apache.curator.framework.imps.GetACLBuilderImpl
 
inBackground() - Method in class org.apache.curator.framework.imps.GetACLBuilderImpl
 
inBackground(Object) - Method in class org.apache.curator.framework.imps.GetACLBuilderImpl
 
inBackground(BackgroundCallback) - Method in class org.apache.curator.framework.imps.GetACLBuilderImpl
 
inBackground(BackgroundCallback, Executor) - Method in class org.apache.curator.framework.imps.GetACLBuilderImpl
 
inBackground(BackgroundCallback, Object) - Method in class org.apache.curator.framework.imps.GetChildrenBuilderImpl
 
inBackground(BackgroundCallback, Object, Executor) - Method in class org.apache.curator.framework.imps.GetChildrenBuilderImpl
 
inBackground(BackgroundCallback) - Method in class org.apache.curator.framework.imps.GetChildrenBuilderImpl
 
inBackground(BackgroundCallback, Executor) - Method in class org.apache.curator.framework.imps.GetChildrenBuilderImpl
 
inBackground() - Method in class org.apache.curator.framework.imps.GetChildrenBuilderImpl
 
inBackground(Object) - Method in class org.apache.curator.framework.imps.GetChildrenBuilderImpl
 
inBackground() - Method in class org.apache.curator.framework.imps.GetConfigBuilderImpl
 
inBackground(Object) - Method in class org.apache.curator.framework.imps.GetConfigBuilderImpl
 
inBackground(BackgroundCallback) - Method in class org.apache.curator.framework.imps.GetConfigBuilderImpl
 
inBackground(BackgroundCallback, Object) - Method in class org.apache.curator.framework.imps.GetConfigBuilderImpl
 
inBackground(BackgroundCallback, Executor) - Method in class org.apache.curator.framework.imps.GetConfigBuilderImpl
 
inBackground(BackgroundCallback, Object, Executor) - Method in class org.apache.curator.framework.imps.GetConfigBuilderImpl
 
inBackground(BackgroundCallback, Object) - Method in class org.apache.curator.framework.imps.GetDataBuilderImpl
 
inBackground(BackgroundCallback, Object, Executor) - Method in class org.apache.curator.framework.imps.GetDataBuilderImpl
 
inBackground(BackgroundCallback) - Method in class org.apache.curator.framework.imps.GetDataBuilderImpl
 
inBackground(BackgroundCallback, Executor) - Method in class org.apache.curator.framework.imps.GetDataBuilderImpl
 
inBackground() - Method in class org.apache.curator.framework.imps.GetDataBuilderImpl
 
inBackground(Object) - Method in class org.apache.curator.framework.imps.GetDataBuilderImpl
 
inBackground() - Method in class org.apache.curator.framework.imps.ReconfigBuilderImpl
 
inBackground(Object) - Method in class org.apache.curator.framework.imps.ReconfigBuilderImpl
 
inBackground(BackgroundCallback) - Method in class org.apache.curator.framework.imps.ReconfigBuilderImpl
 
inBackground(BackgroundCallback, Object) - Method in class org.apache.curator.framework.imps.ReconfigBuilderImpl
 
inBackground(BackgroundCallback, Executor) - Method in class org.apache.curator.framework.imps.ReconfigBuilderImpl
 
inBackground(BackgroundCallback, Object, Executor) - Method in class org.apache.curator.framework.imps.ReconfigBuilderImpl
 
inBackground(BackgroundCallback, Object) - Method in class org.apache.curator.framework.imps.RemoveWatchesBuilderImpl
 
inBackground(BackgroundCallback, Object, Executor) - Method in class org.apache.curator.framework.imps.RemoveWatchesBuilderImpl
 
inBackground(BackgroundCallback) - Method in class org.apache.curator.framework.imps.RemoveWatchesBuilderImpl
 
inBackground(BackgroundCallback, Executor) - Method in class org.apache.curator.framework.imps.RemoveWatchesBuilderImpl
 
inBackground() - Method in class org.apache.curator.framework.imps.RemoveWatchesBuilderImpl
 
inBackground(Object) - Method in class org.apache.curator.framework.imps.RemoveWatchesBuilderImpl
 
inBackground() - Method in class org.apache.curator.framework.imps.SetACLBuilderImpl
 
inBackground(Object) - Method in class org.apache.curator.framework.imps.SetACLBuilderImpl
 
inBackground(BackgroundCallback) - Method in class org.apache.curator.framework.imps.SetACLBuilderImpl
 
inBackground(BackgroundCallback, Object) - Method in class org.apache.curator.framework.imps.SetACLBuilderImpl
 
inBackground(BackgroundCallback, Object, Executor) - Method in class org.apache.curator.framework.imps.SetACLBuilderImpl
 
inBackground(BackgroundCallback, Executor) - Method in class org.apache.curator.framework.imps.SetACLBuilderImpl
 
inBackground(BackgroundCallback, Object) - Method in class org.apache.curator.framework.imps.SetDataBuilderImpl
 
inBackground(BackgroundCallback, Object, Executor) - Method in class org.apache.curator.framework.imps.SetDataBuilderImpl
 
inBackground(BackgroundCallback) - Method in class org.apache.curator.framework.imps.SetDataBuilderImpl
 
inBackground() - Method in class org.apache.curator.framework.imps.SetDataBuilderImpl
 
inBackground(Object) - Method in class org.apache.curator.framework.imps.SetDataBuilderImpl
 
inBackground(BackgroundCallback, Executor) - Method in class org.apache.curator.framework.imps.SetDataBuilderImpl
 
inBackground() - Method in class org.apache.curator.framework.imps.SyncBuilderImpl
 
inBackground(Object) - Method in class org.apache.curator.framework.imps.SyncBuilderImpl
 
inBackground(BackgroundCallback) - Method in class org.apache.curator.framework.imps.SyncBuilderImpl
 
inBackground(BackgroundCallback, Object) - Method in class org.apache.curator.framework.imps.SyncBuilderImpl
 
inBackground(BackgroundCallback, Executor) - Method in class org.apache.curator.framework.imps.SyncBuilderImpl
 
inBackground(BackgroundCallback, Object, Executor) - Method in class org.apache.curator.framework.imps.SyncBuilderImpl
 
increment() - Method in class org.apache.curator.framework.recipes.atomic.DistributedAtomicInteger
Add 1 to the current value and return the new value information.
increment() - Method in class org.apache.curator.framework.recipes.atomic.DistributedAtomicLong
Add 1 to the current value and return the new value information.
increment() - Method in interface org.apache.curator.framework.recipes.atomic.DistributedAtomicNumber
Add 1 to the current value and return the new value information.
initialize(Integer) - Method in class org.apache.curator.framework.recipes.atomic.DistributedAtomicInteger
 
initialize(Long) - Method in class org.apache.curator.framework.recipes.atomic.DistributedAtomicLong
 
initialize(T) - Method in interface org.apache.curator.framework.recipes.atomic.DistributedAtomicNumber
Atomic values are initially set to the equivalent of NULL in a database.
initialize(byte[]) - Method in class org.apache.curator.framework.recipes.atomic.DistributedAtomicValue
Atomic values are initially set to the equivalent of NULL in a database.
InstanceCleanup - Class in org.apache.curator.x.discovery.server.rest
A background task that purges stale registrations.
InstanceCleanup(ServiceDiscovery<?>, int) - Constructor for class org.apache.curator.x.discovery.server.rest.InstanceCleanup
 
InstanceDetails - Class in discovery
In a real application, the Service payload will most likely be more detailed than this.
InstanceDetails() - Constructor for class discovery.InstanceDetails
 
InstanceDetails(String) - Constructor for class discovery.InstanceDetails
 
InstanceFilter<T> - Interface in org.apache.curator.x.discovery
Typedef for an Instance predicate
InstanceProvider<T> - Interface in org.apache.curator.x.discovery.details
Provides a set of available instances for a service so that a strategy can pick one of them
InstanceSerializer<T> - Interface in org.apache.curator.x.discovery.details
Injectable serializer for service instances
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
 
IntegerDiscoveryContext - Class in org.apache.curator.x.discovery.server.contexts
For convenience, a version of DiscoveryContext that uses an int as the payload
IntegerDiscoveryContext(ServiceDiscovery<Integer>, ProviderStrategy<Integer>, int) - Constructor for class org.apache.curator.x.discovery.server.contexts.IntegerDiscoveryContext
 
InternalACLProvider - Interface in org.apache.curator.utils
 
internalBlockUntilConnectedOrTimedOut() - Method in class org.apache.curator.CuratorZookeeperClient
For internal use only
internalRegisterService(ServiceInstance<T>) - Method in class org.apache.curator.x.discovery.details.ServiceDiscoveryImpl
 
InternalScheduledFutureTask(ScheduledFuture<?>) - Constructor for class org.apache.curator.utils.CloseableExecutorService.InternalScheduledFutureTask
 
internalSync(CuratorFrameworkImpl, String, Object) - Method in class org.apache.curator.framework.imps.CuratorFrameworkImpl
 
InterProcessLock - Interface in org.apache.curator.framework.recipes.locks
 
InterProcessMultiLock - Class in org.apache.curator.framework.recipes.locks
A container that manages multiple locks as a single entity.
InterProcessMultiLock(CuratorFramework, List<String>) - Constructor for class org.apache.curator.framework.recipes.locks.InterProcessMultiLock
Creates a multi lock of InterProcessMutexs
InterProcessMultiLock(List<InterProcessLock>) - Constructor for class org.apache.curator.framework.recipes.locks.InterProcessMultiLock
Creates a multi lock of any type of inter process lock
InterProcessMutex - Class in org.apache.curator.framework.recipes.locks
A re-entrant mutex that works across JVMs.
InterProcessMutex(CuratorFramework, String) - Constructor for class org.apache.curator.framework.recipes.locks.InterProcessMutex
 
InterProcessMutex(CuratorFramework, String, LockInternalsDriver) - Constructor for class org.apache.curator.framework.recipes.locks.InterProcessMutex
 
InterProcessReadWriteLock - Class in org.apache.curator.framework.recipes.locks
A re-entrant read/write mutex that works across JVMs.
InterProcessReadWriteLock(CuratorFramework, String) - Constructor for class org.apache.curator.framework.recipes.locks.InterProcessReadWriteLock
 
InterProcessReadWriteLock(CuratorFramework, String, byte[]) - Constructor for class org.apache.curator.framework.recipes.locks.InterProcessReadWriteLock
 
InterProcessSemaphore - Class in org.apache.curator.framework.recipes.locks
Deprecated.
Use InterProcessSemaphoreV2 instead of this class. It uses a better algorithm.
InterProcessSemaphore(CuratorFramework, String, int) - Constructor for class org.apache.curator.framework.recipes.locks.InterProcessSemaphore
Deprecated.
 
InterProcessSemaphore(CuratorFramework, String, SharedCountReader) - Constructor for class org.apache.curator.framework.recipes.locks.InterProcessSemaphore
Deprecated.
 
InterProcessSemaphoreMutex - Class in org.apache.curator.framework.recipes.locks
A NON re-entrant mutex that works across JVMs.
InterProcessSemaphoreMutex(CuratorFramework, String) - Constructor for class org.apache.curator.framework.recipes.locks.InterProcessSemaphoreMutex
 
InterProcessSemaphoreV2 - Class in org.apache.curator.framework.recipes.locks
A counting semaphore that works across JVMs.
InterProcessSemaphoreV2(CuratorFramework, String, int) - Constructor for class org.apache.curator.framework.recipes.locks.InterProcessSemaphoreV2
 
InterProcessSemaphoreV2(CuratorFramework, String, SharedCountReader) - Constructor for class org.apache.curator.framework.recipes.locks.InterProcessSemaphoreV2
 
interruptLeadership() - Method in class org.apache.curator.framework.recipes.leader.LeaderSelector
Attempt to cancel and interrupt the current leadership if this instance has leadership
inTransaction() - Method in interface org.apache.curator.framework.CuratorFramework
Deprecated.
inTransaction() - Method in interface org.apache.curator.framework.CuratorTempFramework
Start a transaction builder
inTransaction() - Method in class org.apache.curator.framework.imps.CuratorFrameworkImpl
 
inTransaction() - Method in class org.apache.curator.framework.imps.CuratorTempFrameworkImpl
 
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
 
isAcquiredInThisProcess() - Method in interface org.apache.curator.framework.recipes.locks.InterProcessLock
Returns true if the mutex is acquired by a thread in this JVM
isAcquiredInThisProcess() - Method in class org.apache.curator.framework.recipes.locks.InterProcessMultiLock
 
isAcquiredInThisProcess() - Method in class org.apache.curator.framework.recipes.locks.InterProcessMutex
Returns true if the mutex is acquired by a thread in this JVM
isAcquiredInThisProcess() - Method in class org.apache.curator.framework.recipes.locks.InterProcessSemaphoreMutex
 
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
isConnected() - Method in enum org.apache.curator.framework.state.ConnectionState
Check if this state indicates that Curator has a connection to ZooKeeper
isConnected() - Method in class org.apache.curator.framework.state.ConnectionStateManager
 
isDone() - Method in class org.apache.curator.utils.CloseableExecutorService.InternalScheduledFutureTask
 
isDynamic() - Method in enum org.apache.curator.x.discovery.ServiceType
 
isEnabled() - Method in class org.apache.curator.x.discovery.ServiceInstance
 
isErrorState(ConnectionState) - Method in interface org.apache.curator.framework.state.ConnectionStateErrorPolicy
Returns true if the given state should cause the recipe to act as though the connection has been lost.
isErrorState(ConnectionState) - Method in class org.apache.curator.framework.state.SessionConnectionStateErrorPolicy
 
isErrorState(ConnectionState) - Method in class org.apache.curator.framework.state.StandardConnectionStateErrorPolicy
 
isExecuteCalled() - Method in class org.apache.curator.test.ExecuteCalledWatchingExecutorService
 
isFromRandom() - Method in class org.apache.curator.test.QuorumConfigBuilder
 
isLeader() - Method in interface org.apache.curator.framework.recipes.leader.LeaderLatchListener
This is called when the LeaderLatch's state goes from hasLeadership = false to hasLeadership = true.
isLeader() - Method in class org.apache.curator.framework.recipes.leader.Participant
Returns true if this participant is the current leader
isLeader(CuratorProjection, LeaderProjection) - Method in class org.apache.curator.x.rpc.idl.services.CuratorProjectionService
 
isLeader - Variable in class org.apache.curator.x.rpc.idl.structs.LeaderEvent
 
isLeader - Variable in class org.apache.curator.x.rpc.idl.structs.LeaderResult
 
isLeader - Variable in class org.apache.curator.x.rpc.idl.structs.RpcParticipant
 
isOpen - Variable in class org.apache.curator.utils.CloseableExecutorService
 
isProtected() - Method in enum org.apache.curator.framework.recipes.nodes.PersistentEphemeralNode.Mode
Deprecated.
 
isReadable(Class<?>, Type, Annotation[], MediaType) - Method in class org.apache.curator.x.discovery.server.entity.JsonServiceInstanceMarshaller
 
isReadable(Class<?>, Type, Annotation[], MediaType) - Method in class org.apache.curator.x.discovery.server.entity.JsonServiceInstancesMarshaller
 
isReadable(Class<?>, Type, Annotation[], MediaType) - Method in class org.apache.curator.x.discovery.server.entity.JsonServiceNamesMarshaller
 
isRetryException(Throwable) - Static method in class org.apache.curator.RetryLoop
Utility - return true if the given exception is retry-able
isRunning() - Method in class org.apache.curator.test.TestingZooKeeperMain.TestZooKeeperServer
 
isShutdown() - Method in class org.apache.curator.test.DelegatingExecutorService
 
isShutdown() - Method in class org.apache.curator.utils.CloseableExecutorService
Returns true if this executor has been shut down.
isStarted() - Method in interface org.apache.curator.framework.CuratorFramework
Deprecated.
isStarted() - Method in class org.apache.curator.framework.imps.CuratorFrameworkImpl
Deprecated.
isTerminated() - Method in class org.apache.curator.test.DelegatingExecutorService
 
isValid(Schema, String, byte[], List<ACL>) - Method in class org.apache.curator.framework.schema.DefaultSchemaValidator
 
isValid(Schema, String, byte[], List<ACL>) - Method in interface org.apache.curator.framework.schema.SchemaValidator
 
isVariable() - Method in class org.apache.curator.x.discovery.UriSpec.Part
 
isWithWatcher() - Method in class org.apache.curator.drivers.OperationTrace
 
isWriteable(Class<?>, Type, Annotation[], MediaType) - Method in class org.apache.curator.x.discovery.server.entity.JsonServiceInstanceMarshaller
 
isWriteable(Class<?>, Type, Annotation[], MediaType) - Method in class org.apache.curator.x.discovery.server.entity.JsonServiceInstancesMarshaller
 
isWriteable(Class<?>, Type, Annotation[], MediaType) - Method in class org.apache.curator.x.discovery.server.entity.JsonServiceNamesMarshaller
 
iterator() - Method in class org.apache.curator.x.discovery.UriSpec
 

J

Joinable<T> - Interface in org.apache.curator.framework.api
 
joining(String...) - Method in interface org.apache.curator.framework.api.Joinable
Adds one or more servers to joining the ensemble.
joining(List<String>) - Method in interface org.apache.curator.framework.api.Joinable
Adds one or more servers to joining the ensemble.
joining(String...) - Method in class org.apache.curator.framework.imps.ReconfigBuilderImpl
 
joining(List<String>) - Method in class org.apache.curator.framework.imps.ReconfigBuilderImpl
 
JoinStatConfigEnsembleable - Interface in org.apache.curator.framework.api
An incremental reconfiguration builder.
JsonInstanceSerializer<T> - Class in org.apache.curator.x.discovery.details
A serializer that uses Jackson to serialize/deserialize as JSON.
JsonInstanceSerializer(Class<T>) - Constructor for class org.apache.curator.x.discovery.details.JsonInstanceSerializer
 
JsonServiceInstanceMarshaller<T> - Class in org.apache.curator.x.discovery.server.entity
Message body reader/writer.
JsonServiceInstanceMarshaller(DiscoveryContext<T>) - Constructor for class org.apache.curator.x.discovery.server.entity.JsonServiceInstanceMarshaller
 
JsonServiceInstancesMarshaller<T> - Class in org.apache.curator.x.discovery.server.entity
Message body reader/writer.
JsonServiceInstancesMarshaller(DiscoveryContext<T>) - Constructor for class org.apache.curator.x.discovery.server.entity.JsonServiceInstancesMarshaller
 
JsonServiceNamesMarshaller - Class in org.apache.curator.x.discovery.server.entity
Message body reader/writer.
JsonServiceNamesMarshaller() - Constructor for class org.apache.curator.x.discovery.server.entity.JsonServiceNamesMarshaller
 

K

keeperState - Variable in class org.apache.curator.x.rpc.idl.structs.RpcWatchedEvent
 
kill(ZooKeeper, String) - Static method in class org.apache.curator.test.KillServerSession
Kill the given ZK session
kill(ZooKeeper, String, int) - Static method in class org.apache.curator.test.KillServerSession
Kill the given ZK session
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.
kill(ZooKeeper, String, int) - Static method in class org.apache.curator.test.KillSession
Deprecated.
kill() - Method in class org.apache.curator.test.TestingZooKeeperMain
 
kill() - Method in class org.apache.curator.test.TestingZooKeeperServer
 
kill() - Method in interface org.apache.curator.test.ZooKeeperMainFace
 
killServer(InstanceSpec) - Method in class org.apache.curator.test.TestingCluster
Kills the given server.
KillServerSession - Class in org.apache.curator.test
Utility to simulate a ZK session dying.
KillServerSession() - Constructor for class org.apache.curator.test.KillServerSession
 
KillSession - Class in org.apache.curator.test
Utility to simulate a ZK session dying.
KillSession() - Constructor for class org.apache.curator.test.KillSession
 

L

leader - package leader
 
LeaderEvent - Class in org.apache.curator.x.rpc.idl.structs
 
LeaderEvent() - Constructor for class org.apache.curator.x.rpc.idl.structs.LeaderEvent
 
LeaderEvent(String, String, boolean) - Constructor for class org.apache.curator.x.rpc.idl.structs.LeaderEvent
 
leaderEvent - Variable in class org.apache.curator.x.rpc.idl.structs.RpcCuratorEvent
 
LeaderLatch - Class in org.apache.curator.framework.recipes.leader
Abstraction to select a "leader" amongst multiple contenders in a group of JMVs connected to a Zookeeper cluster.
LeaderLatch(CuratorFramework, String) - Constructor for class org.apache.curator.framework.recipes.leader.LeaderLatch
 
LeaderLatch(CuratorFramework, String, String) - Constructor for class org.apache.curator.framework.recipes.leader.LeaderLatch
 
LeaderLatch(CuratorFramework, String, String, LeaderLatch.CloseMode) - Constructor for class org.apache.curator.framework.recipes.leader.LeaderLatch
 
LeaderLatch.CloseMode - Enum in org.apache.curator.framework.recipes.leader
How to handle listeners when the latch is closed
LeaderLatch.State - Enum in org.apache.curator.framework.recipes.leader
 
LeaderLatchListener - Interface in org.apache.curator.framework.recipes.leader
A LeaderLatchListener can be used to be notified asynchronously about when the state of the LeaderLatch has changed.
LeaderProjection - Class in org.apache.curator.x.rpc.idl.structs
 
LeaderProjection() - Constructor for class org.apache.curator.x.rpc.idl.structs.LeaderProjection
 
LeaderProjection(String) - Constructor for class org.apache.curator.x.rpc.idl.structs.LeaderProjection
 
LeaderResult - Class in org.apache.curator.x.rpc.idl.structs
 
LeaderResult() - Constructor for class org.apache.curator.x.rpc.idl.structs.LeaderResult
 
LeaderResult(LeaderProjection, boolean) - Constructor for class org.apache.curator.x.rpc.idl.structs.LeaderResult
 
LeaderSelector - Class in org.apache.curator.framework.recipes.leader
Abstraction to select a "leader" amongst multiple contenders in a group of JMVs connected to a Zookeeper cluster.
LeaderSelector(CuratorFramework, String, LeaderSelectorListener) - Constructor for class org.apache.curator.framework.recipes.leader.LeaderSelector
 
LeaderSelector(CuratorFramework, String, ThreadFactory, Executor, LeaderSelectorListener) - Constructor for class org.apache.curator.framework.recipes.leader.LeaderSelector
Deprecated.
This constructor was poorly thought out. Custom executor is useless. Use this version instead: LeaderSelector.LeaderSelector(CuratorFramework, String, ExecutorService, LeaderSelectorListener)
LeaderSelector(CuratorFramework, String, ExecutorService, LeaderSelectorListener) - Constructor for class org.apache.curator.framework.recipes.leader.LeaderSelector
 
LeaderSelector(CuratorFramework, String, CloseableExecutorService, LeaderSelectorListener) - Constructor for class org.apache.curator.framework.recipes.leader.LeaderSelector
 
LeaderSelectorExample - Class in leader
 
LeaderSelectorExample() - Constructor for class leader.LeaderSelectorExample
 
LeaderSelectorListener - Interface in org.apache.curator.framework.recipes.leader
Notification for leadership
LeaderSelectorListenerAdapter - Class in org.apache.curator.framework.recipes.leader
An implementation of LeaderSelectorListener that adds the recommended handling for connection state problems
LeaderSelectorListenerAdapter() - Constructor for class org.apache.curator.framework.recipes.leader.LeaderSelectorListenerAdapter
 
Lease - Interface in org.apache.curator.framework.recipes.locks
Represents an acquired lease from an InterProcessSemaphore.
LeaseProjection - Class in org.apache.curator.x.rpc.idl.structs
 
LeaseProjection() - Constructor for class org.apache.curator.x.rpc.idl.structs.LeaseProjection
 
LeaseProjection(String) - Constructor for class org.apache.curator.x.rpc.idl.structs.LeaseProjection
 
leave() - Method in class org.apache.curator.framework.recipes.barriers.DistributedDoubleBarrier
Leave the barrier and block until all members have left
leave(long, TimeUnit) - Method in class org.apache.curator.framework.recipes.barriers.DistributedDoubleBarrier
Leave the barrier and block until all members have left or the timeout has elapsed
Leaveable<T> - Interface in org.apache.curator.framework.api
 
LeaveStatConfigEnsembleable - Interface in org.apache.curator.framework.api
An incremental reconfiguration builder.
leaving(String...) - Method in interface org.apache.curator.framework.api.Leaveable
Sets one or more servers to leaving the ensemble.
leaving(List<String>) - Method in interface org.apache.curator.framework.api.Leaveable
Sets one or more servers to leaving the ensemble.
leaving(String...) - Method in class org.apache.curator.framework.imps.ReconfigBuilderImpl
 
leaving(List<String>) - Method in class org.apache.curator.framework.imps.ReconfigBuilderImpl
 
Listenable<T> - Interface in org.apache.curator.framework.listen
Abstracts a listenable object
listener - Variable in class org.apache.curator.framework.listen.ListenerEntry
 
ListenerContainer<T> - Class in org.apache.curator.framework.listen
Abstracts an object that has listeners
ListenerContainer() - Constructor for class org.apache.curator.framework.listen.ListenerContainer
 
ListenerEntry<T> - Class in org.apache.curator.framework.listen
Generic holder POJO for a listener and its executor
ListenerEntry(T, Executor) - Constructor for class org.apache.curator.framework.listen.ListenerEntry
 
LocalIpFilter - Interface in org.apache.curator.x.discovery
 
locally() - Method in interface org.apache.curator.framework.api.RemoveWatchesLocal
Specify if the client should just remove client side watches if a connection to ZK is not available.
locally() - Method in class org.apache.curator.framework.imps.RemoveWatchesBuilderImpl
 
LOCK_SCHEMA - Static variable in class org.apache.curator.framework.recipes.locks.InterProcessSemaphoreV2
 
Locker - Class in org.apache.curator.framework.recipes.locks
Utility for safely acquiring a lock and releasing it using Java 7's try-with-resource feature.
Locker(InterProcessLock, long, TimeUnit) - Constructor for class org.apache.curator.framework.recipes.locks.Locker
 
Locker(InterProcessLock) - Constructor for class org.apache.curator.framework.recipes.locks.Locker
 
locking - package locking
 
LockingExample - Class in locking
 
LockingExample() - Constructor for class locking.LockingExample
 
LockInternals - Class in org.apache.curator.framework.recipes.locks
 
LockInternalsDriver - Interface in org.apache.curator.framework.recipes.locks
 
LockInternalsSorter - Interface in org.apache.curator.framework.recipes.locks
 
lockPath(String) - Method in class org.apache.curator.framework.recipes.atomic.PromotedToLock.Builder
Set the path for the mutex lock (required)
lockPath(String) - Method in class org.apache.curator.framework.recipes.queue.QueueBuilder
Without a lock set, queue items are removed before being sent to the queue consumer.
LockProjection - Class in org.apache.curator.x.rpc.idl.structs
 
LockProjection() - Constructor for class org.apache.curator.x.rpc.idl.structs.LockProjection
 
LockProjection(String) - Constructor for class org.apache.curator.x.rpc.idl.structs.LockProjection
 
lockProjection - Variable in class org.apache.curator.x.rpc.idl.structs.OptionalLockProjection
 

M

main(String[]) - Static method in class cache.PathCacheExample
 
main(String[]) - Static method in class discovery.DiscoveryExample
 
main(String[]) - Static method in class leader.LeaderSelectorExample
 
main(String[]) - Static method in class locking.LockingExample
 
main(String[]) - Static method in class org.apache.curator.x.rpc.CuratorProjectionServer
 
makeDiscoveryInstance(String, byte[], int) - Method in class org.apache.curator.x.rpc.idl.discovery.DiscoveryService
 
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
makeRequeueItemPath(String) - Method in class org.apache.curator.framework.recipes.queue.DistributedQueue
 
makeRevocable(RevocationListener<InterProcessMutex>) - Method in class org.apache.curator.framework.recipes.locks.InterProcessMutex
 
makeRevocable(RevocationListener<InterProcessMutex>, Executor) - Method in class org.apache.curator.framework.recipes.locks.InterProcessMutex
 
makeRevocable(RevocationListener<T>) - Method in interface org.apache.curator.framework.recipes.locks.Revocable
Make the lock revocable.
makeRevocable(RevocationListener<T>, Executor) - Method in interface org.apache.curator.framework.recipes.locks.Revocable
Make the lock revocable.
makeSpecs(int) - Static method in class org.apache.curator.test.TestingCluster
 
makeSpecs(int, boolean) - Static method in class org.apache.curator.test.TestingCluster
 
MapDiscoveryContext - Class in org.apache.curator.x.discovery.server.contexts
For convenience, a version of DiscoveryContext that uses a String-to-String map as the payload
MapDiscoveryContext(ServiceDiscovery<Map<String, String>>, ProviderStrategy<Map<String, String>>, int) - Constructor for class org.apache.curator.x.discovery.server.contexts.MapDiscoveryContext
 
markComplete() - Method in class org.apache.curator.RetryLoop
Call this when your operation has successfully completed
marshallJson(ObjectNode, String, T) - Method in class org.apache.curator.x.discovery.server.contexts.GenericDiscoveryContext
 
marshallJson(ObjectNode, String, Integer) - Method in class org.apache.curator.x.discovery.server.contexts.IntegerDiscoveryContext
 
marshallJson(ObjectNode, String, String) - Method in class org.apache.curator.x.discovery.server.contexts.StringDiscoveryContext
 
marshallJson(ObjectNode, String, T) - Method in interface org.apache.curator.x.discovery.server.rest.DiscoveryContext
Serialize your payload
maxCloseWaitMs(int) - Method in class org.apache.curator.framework.CuratorFrameworkFactory.Builder
 
maxItems(int) - Method in class org.apache.curator.framework.recipes.queue.QueueBuilder
By default, the various queues are unbounded.
maxQueues(int) - Method in class org.apache.curator.framework.recipes.queue.QueueSharderPolicies.Builder
Change the maximum number of queues to create.
Membersable<T> - Interface in org.apache.curator.framework.api
 
message - Variable in exception org.apache.curator.x.rpc.idl.exceptions.RpcException
 
metadata(Map<String, String>) - Method in class org.apache.curator.framework.schema.SchemaBuilder
 
milliseconds() - Method in class org.apache.curator.test.Timing
Return the base time in milliseconds
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.
mode - Variable in class org.apache.curator.x.rpc.idl.structs.CreateSpec
 
mtime - Variable in class org.apache.curator.x.rpc.idl.structs.RpcStat
 
MultiItem<T> - Interface in org.apache.curator.framework.recipes.queue
Abstraction for multiple items.
multiple(double) - Method in class org.apache.curator.test.Timing
Return a new timing that is a multiple of the this timing
multiple(double, int) - Method in class org.apache.curator.test.Timing
Return a new timing that is a multiple of the this timing
mustGetEntry(ConnectionManager, CuratorProjection) - Static method in class org.apache.curator.x.rpc.connections.CuratorEntry
 
mustGetThing(CuratorEntry, String, Class<T>) - Static method in class org.apache.curator.x.rpc.connections.CuratorEntry
 
mzxid - Variable in class org.apache.curator.x.rpc.idl.structs.RpcStat
 

N

name(String) - Method in class org.apache.curator.framework.schema.SchemaBuilder
 
name(String) - Method in interface org.apache.curator.x.discovery.ServiceCacheBuilder
The name of the service to cache (required)
name(String) - Method in class org.apache.curator.x.discovery.ServiceInstanceBuilder
 
name - Variable in class org.apache.curator.x.rpc.idl.discovery.DiscoveryInstance
 
name - Variable in class org.apache.curator.x.rpc.idl.structs.RpcCuratorEvent
 
namespace(String) - Method in class org.apache.curator.framework.CuratorFrameworkFactory.Builder
As ZooKeeper is a shared space, users of a given cluster should stay within a pre-defined namespace.
newBuilder(CuratorFramework, String) - Static method in class org.apache.curator.framework.recipes.cache.TreeCache
Create a TreeCache builder for the given client and path to configure advanced options.
newClient(String, RetryPolicy) - Static method in class org.apache.curator.framework.CuratorFrameworkFactory
Create a new client with default session timeout and default connection timeout
newClient(String, int, int, RetryPolicy) - Static method in class org.apache.curator.framework.CuratorFrameworkFactory
Create a new client
newConnection(String) - Method in class org.apache.curator.x.rpc.connections.ConnectionManager
 
newCuratorProjection(String) - Method in class org.apache.curator.x.rpc.idl.services.CuratorProjectionService
 
newExecutorService() - Static method in class org.apache.curator.framework.recipes.locks.ChildReaper
Deprecated.
 
newExecutorService() - Static method in class org.apache.curator.framework.recipes.locks.Reaper
Deprecated.
Allocate an executor service for the reaper
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
 
newId() - Static method in class org.apache.curator.x.rpc.connections.CuratorEntry
 
newInstanceSpec() - Static method in class org.apache.curator.test.InstanceSpec
 
newNamespaceAwareEnsurePath(String) - Method in interface org.apache.curator.framework.CuratorFramework
newNamespaceAwareEnsurePath(String) - Method in class org.apache.curator.framework.imps.CuratorFrameworkImpl
 
newPathChildrenCache(CuratorFramework, String) - Method in class org.apache.curator.framework.recipes.nodes.GroupMember
 
newPersistentEphemeralNode(CuratorFramework, String, String, byte[]) - Method in class org.apache.curator.framework.recipes.nodes.GroupMember
 
newQueueThreshold(int) - Method in class org.apache.curator.framework.recipes.queue.QueueSharderPolicies.Builder
Change the queue threshold.
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
 
newWatcherRemoveCuratorFramework() - Method in interface org.apache.curator.framework.CuratorFramework
Returns a facade of the current instance that tracks watchers created and allows a one-shot removal of all watchers via WatcherRemoveCuratorFramework.removeWatchers()
newWatcherRemoveCuratorFramework() - Method in class org.apache.curator.framework.imps.CuratorFrameworkImpl
 
newZooKeeper(String, int, Watcher, boolean) - Method in class org.apache.curator.utils.DefaultZookeeperFactory
 
newZooKeeper(String, int, Watcher, boolean) - Method in interface org.apache.curator.utils.ZookeeperFactory
Allocate a new ZooKeeper instance
next() - Method in class org.apache.curator.framework.recipes.atomic.CachedAtomicInteger
Returns the next value (incrementing by 1).
next() - Method in class org.apache.curator.framework.recipes.atomic.CachedAtomicLong
Returns the next value (incrementing by 1).
nextItem() - Method in interface org.apache.curator.framework.recipes.queue.MultiItem
Called repeatedly to get the items to add to the queue.
NodeCache - Class in org.apache.curator.framework.recipes.cache
A utility that attempts to keep the data from a node locally cached.
NodeCache(CuratorFramework, String) - Constructor for class org.apache.curator.framework.recipes.cache.NodeCache
 
NodeCache(CuratorFramework, String, boolean) - Constructor for class org.apache.curator.framework.recipes.cache.NodeCache
 
NodeCacheListener - Interface in org.apache.curator.framework.recipes.cache
 
NodeCacheProjection - Class in org.apache.curator.x.rpc.idl.structs
 
NodeCacheProjection() - Constructor for class org.apache.curator.x.rpc.idl.structs.NodeCacheProjection
 
NodeCacheProjection(String) - Constructor for class org.apache.curator.x.rpc.idl.structs.NodeCacheProjection
 
nodeChanged() - Method in interface org.apache.curator.framework.recipes.cache.NodeCacheListener
Called when a change has occurred
nodeException - Variable in exception org.apache.curator.x.rpc.idl.exceptions.RpcException
 
NodeExceptionType - Enum in org.apache.curator.x.rpc.idl.exceptions
 
nonNamespaceView() - Method in interface org.apache.curator.framework.CuratorFramework
Deprecated.
nonNamespaceView() - Method in class org.apache.curator.framework.imps.CuratorFrameworkImpl
Deprecated.
noteError(ServiceInstance<T>) - Method in class org.apache.curator.x.discovery.details.ServiceProviderImpl
 
noteError(ServiceInstance<T>) - Method in interface org.apache.curator.x.discovery.ServiceProvider
Take note of an error connecting to the given instance.
noteError(CuratorProjection, DiscoveryProviderProjection, String) - Method in class org.apache.curator.x.rpc.idl.discovery.DiscoveryService
 
noteStartup() - Method in class org.apache.curator.test.TestingZooKeeperMain.TestZooKeeperServer
 
notLeader() - Method in interface org.apache.curator.framework.recipes.leader.LeaderLatchListener
This is called when the LeaderLatch's state goes from hasLeadership = true to hasLeadership = false.
numChildren - Variable in class org.apache.curator.x.rpc.idl.structs.RpcStat
 

O

of(AsyncStage<T>) - Static method in interface org.apache.curator.x.async.AsyncResult
Return a new stage that wraps an async stage into a result-style completion stage.
offer(byte[]) - Method in class org.apache.curator.framework.recipes.queue.SimpleDistributedQueue
Inserts data into queue.
ofType(Watcher.WatcherType) - Method in interface org.apache.curator.framework.api.RemoveWatchesType
Specify the type of watcher to be removed.
ofType(Watcher.WatcherType) - Method in class org.apache.curator.framework.imps.RemoveWatchesBuilderImpl
 
ofTypeAndPath(OperationType, String) - Static method in class org.apache.curator.framework.api.transaction.CuratorTransactionResult
Utility that can be passed to Google Guava to find a particular result.
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
 
OperationType - Enum in org.apache.curator.framework.api.transaction
Transaction operation types
OptionalChildrenList - Class in org.apache.curator.x.rpc.idl.structs
 
OptionalChildrenList() - Constructor for class org.apache.curator.x.rpc.idl.structs.OptionalChildrenList
 
OptionalChildrenList(List<String>) - Constructor for class org.apache.curator.x.rpc.idl.structs.OptionalChildrenList
 
OptionalData - Class in org.apache.curator.x.rpc.idl.structs
 
OptionalData() - Constructor for class org.apache.curator.x.rpc.idl.structs.OptionalData
 
OptionalData(byte[]) - Constructor for class org.apache.curator.x.rpc.idl.structs.OptionalData
 
OptionalLockProjection - Class in org.apache.curator.x.rpc.idl.structs
 
OptionalLockProjection() - Constructor for class org.apache.curator.x.rpc.idl.structs.OptionalLockProjection
 
OptionalLockProjection(LockProjection) - Constructor for class org.apache.curator.x.rpc.idl.structs.OptionalLockProjection
 
OptionalPath - Class in org.apache.curator.x.rpc.idl.structs
 
OptionalPath() - Constructor for class org.apache.curator.x.rpc.idl.structs.OptionalPath
 
OptionalPath(String) - Constructor for class org.apache.curator.x.rpc.idl.structs.OptionalPath
 
OptionalRpcStat - Class in org.apache.curator.x.rpc.idl.structs
 
OptionalRpcStat() - Constructor for class org.apache.curator.x.rpc.idl.structs.OptionalRpcStat
 
OptionalRpcStat(RpcStat) - Constructor for class org.apache.curator.x.rpc.idl.structs.OptionalRpcStat
 
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.exhibitor - package org.apache.curator.ensemble.exhibitor
 
org.apache.curator.ensemble.fixed - package org.apache.curator.ensemble.fixed
 
org.apache.curator.framework - package org.apache.curator.framework
 
org.apache.curator.framework.api - package org.apache.curator.framework.api
 
org.apache.curator.framework.api.transaction - package org.apache.curator.framework.api.transaction
 
org.apache.curator.framework.imps - package org.apache.curator.framework.imps
 
org.apache.curator.framework.listen - package org.apache.curator.framework.listen
 
org.apache.curator.framework.recipes - package org.apache.curator.framework.recipes
 
org.apache.curator.framework.recipes.atomic - package org.apache.curator.framework.recipes.atomic
 
org.apache.curator.framework.recipes.barriers - package org.apache.curator.framework.recipes.barriers
 
org.apache.curator.framework.recipes.cache - package org.apache.curator.framework.recipes.cache
 
org.apache.curator.framework.recipes.leader - package org.apache.curator.framework.recipes.leader
 
org.apache.curator.framework.recipes.locks - package org.apache.curator.framework.recipes.locks
 
org.apache.curator.framework.recipes.nodes - package org.apache.curator.framework.recipes.nodes
 
org.apache.curator.framework.recipes.queue - package org.apache.curator.framework.recipes.queue
 
org.apache.curator.framework.recipes.shared - package org.apache.curator.framework.recipes.shared
 
org.apache.curator.framework.schema - package org.apache.curator.framework.schema
 
org.apache.curator.framework.state - package org.apache.curator.framework.state
 
org.apache.curator.retry - package org.apache.curator.retry
 
org.apache.curator.test - package org.apache.curator.test
 
org.apache.curator.utils - package org.apache.curator.utils
 
org.apache.curator.x.async - package org.apache.curator.x.async
 
org.apache.curator.x.async.api - package org.apache.curator.x.async.api
 
org.apache.curator.x.async.details - package org.apache.curator.x.async.details
 
org.apache.curator.x.discovery - package org.apache.curator.x.discovery
 
org.apache.curator.x.discovery.details - package org.apache.curator.x.discovery.details
 
org.apache.curator.x.discovery.server.contexts - package org.apache.curator.x.discovery.server.contexts
 
org.apache.curator.x.discovery.server.entity - package org.apache.curator.x.discovery.server.entity
 
org.apache.curator.x.discovery.server.rest - package org.apache.curator.x.discovery.server.rest
 
org.apache.curator.x.discovery.strategies - package org.apache.curator.x.discovery.strategies
 
org.apache.curator.x.rpc - package org.apache.curator.x.rpc
 
org.apache.curator.x.rpc.configuration - package org.apache.curator.x.rpc.configuration
 
org.apache.curator.x.rpc.connections - package org.apache.curator.x.rpc.connections
 
org.apache.curator.x.rpc.details - package org.apache.curator.x.rpc.details
 
org.apache.curator.x.rpc.idl.discovery - package org.apache.curator.x.rpc.idl.discovery
 
org.apache.curator.x.rpc.idl.exceptions - package org.apache.curator.x.rpc.idl.exceptions
 
org.apache.curator.x.rpc.idl.services - package org.apache.curator.x.rpc.idl.services
 
org.apache.curator.x.rpc.idl.structs - package org.apache.curator.x.rpc.idl.structs
 
orSetData() - Method in interface org.apache.curator.framework.api.CreateBuilder
 
orSetData() - Method in class org.apache.curator.framework.imps.CreateBuilderImpl
 

P

Part(String, boolean) - Constructor for class org.apache.curator.x.discovery.UriSpec.Part
 
Part() - Constructor for class org.apache.curator.x.discovery.UriSpec.Part
 
Participant - Class in org.apache.curator.framework.recipes.leader
Describes a participant in a leadership selection
Participant(String, boolean) - Constructor for class org.apache.curator.framework.recipes.leader.Participant
 
participantId - Variable in class org.apache.curator.x.rpc.idl.structs.LeaderEvent
 
path - Variable in class org.apache.curator.x.rpc.idl.structs.CreateSpec
 
path - Variable in class org.apache.curator.x.rpc.idl.structs.DeleteSpec
 
path - Variable in class org.apache.curator.x.rpc.idl.structs.ExistsSpec
 
path - Variable in class org.apache.curator.x.rpc.idl.structs.GetChildrenSpec
 
path - Variable in class org.apache.curator.x.rpc.idl.structs.GetDataSpec
 
path - Variable in class org.apache.curator.x.rpc.idl.structs.LeaderEvent
 
path - Variable in class org.apache.curator.x.rpc.idl.structs.OptionalPath
 
path - Variable in class org.apache.curator.x.rpc.idl.structs.RpcChildData
 
path - Variable in class org.apache.curator.x.rpc.idl.structs.RpcCuratorEvent
 
path - Variable in class org.apache.curator.x.rpc.idl.structs.RpcWatchedEvent
 
path - Variable in class org.apache.curator.x.rpc.idl.structs.SetDataSpec
 
PATH_SEPARATOR - Static variable in class org.apache.curator.utils.ZKPaths
Zookeeper's path separator character.
Pathable<T> - Interface in org.apache.curator.framework.api
 
PathAndBytesable<T> - Interface in org.apache.curator.framework.api
 
PathAndNode(String, String) - Constructor for class org.apache.curator.utils.ZKPaths.PathAndNode
 
PathCacheExample - Class in cache
An example of the PathChildrenCache.
PathCacheExample() - Constructor for class cache.PathCacheExample
 
PathChildrenCache - Class in org.apache.curator.framework.recipes.cache
A utility that attempts to keep all data from all children of a ZK path locally cached.
PathChildrenCache(CuratorFramework, String, PathChildrenCacheMode) - Constructor for class org.apache.curator.framework.recipes.cache.PathChildrenCache
PathChildrenCache(CuratorFramework, String, PathChildrenCacheMode, ThreadFactory) - Constructor for class org.apache.curator.framework.recipes.cache.PathChildrenCache
PathChildrenCache(CuratorFramework, String, boolean) - Constructor for class org.apache.curator.framework.recipes.cache.PathChildrenCache
 
PathChildrenCache(CuratorFramework, String, boolean, ThreadFactory) - Constructor for class org.apache.curator.framework.recipes.cache.PathChildrenCache
 
PathChildrenCache(CuratorFramework, String, boolean, boolean, ThreadFactory) - Constructor for class org.apache.curator.framework.recipes.cache.PathChildrenCache
 
PathChildrenCache(CuratorFramework, String, boolean, boolean, ExecutorService) - Constructor for class org.apache.curator.framework.recipes.cache.PathChildrenCache
 
PathChildrenCache(CuratorFramework, String, boolean, boolean, CloseableExecutorService) - Constructor for class org.apache.curator.framework.recipes.cache.PathChildrenCache
 
PathChildrenCache.StartMode - Enum in org.apache.curator.framework.recipes.cache
Method of priming cache on PathChildrenCache.start(StartMode)
PathChildrenCacheEvent - Class in org.apache.curator.framework.recipes.cache
POJO that abstracts a change to a path
PathChildrenCacheEvent(PathChildrenCacheEvent.Type, ChildData) - Constructor for class org.apache.curator.framework.recipes.cache.PathChildrenCacheEvent
 
PathChildrenCacheEvent.Type - Enum in org.apache.curator.framework.recipes.cache
Type of change
PathChildrenCacheListener - Interface in org.apache.curator.framework.recipes.cache
Listener for PathChildrenCache changes
PathChildrenCacheMode - Enum in org.apache.curator.framework.recipes.cache
PathChildrenCacheProjection - Class in org.apache.curator.x.rpc.idl.structs
 
PathChildrenCacheProjection() - Constructor for class org.apache.curator.x.rpc.idl.structs.PathChildrenCacheProjection
 
PathChildrenCacheProjection(String) - Constructor for class org.apache.curator.x.rpc.idl.structs.PathChildrenCacheProjection
 
PathChildrenCacheStartMode - Enum in org.apache.curator.x.rpc.idl.structs
 
PathUtils - Class in org.apache.curator.utils
This class is copied from Apache ZooKeeper.
PathUtils() - Constructor for class org.apache.curator.utils.PathUtils
 
payload(T) - Method in class org.apache.curator.x.discovery.ServiceInstanceBuilder
 
payload - Variable in class org.apache.curator.x.rpc.idl.discovery.DiscoveryInstance
 
peek() - Method in class org.apache.curator.framework.recipes.queue.SimpleDistributedQueue
Returns the data at the first element of the queue, or null if the queue is empty.
performBackgroundOperation(OperationAndData<PathAndBytes>) - Method in class org.apache.curator.framework.imps.CreateBuilderImpl
 
performBackgroundOperation(OperationAndData<CuratorMultiTransactionRecord>) - Method in class org.apache.curator.framework.imps.CuratorMultiTransactionImpl
 
performBackgroundOperation(OperationAndData<String>) - Method in class org.apache.curator.framework.imps.DeleteBuilderImpl
 
performBackgroundOperation(OperationAndData<String>) - Method in class org.apache.curator.framework.imps.ExistsBuilderImpl
 
performBackgroundOperation(OperationAndData<String>) - Method in class org.apache.curator.framework.imps.GetACLBuilderImpl
 
performBackgroundOperation(OperationAndData<String>) - Method in class org.apache.curator.framework.imps.GetChildrenBuilderImpl
 
performBackgroundOperation(OperationAndData<Void>) - Method in class org.apache.curator.framework.imps.GetConfigBuilderImpl
 
performBackgroundOperation(OperationAndData<String>) - Method in class org.apache.curator.framework.imps.GetDataBuilderImpl
 
performBackgroundOperation(OperationAndData<Void>) - Method in class org.apache.curator.framework.imps.ReconfigBuilderImpl
 
performBackgroundOperation(OperationAndData<String>) - Method in class org.apache.curator.framework.imps.RemoveWatchesBuilderImpl
 
performBackgroundOperation(OperationAndData<String>) - Method in class org.apache.curator.framework.imps.SetACLBuilderImpl
 
performBackgroundOperation(OperationAndData<PathAndBytes>) - Method in class org.apache.curator.framework.imps.SetDataBuilderImpl
 
performBackgroundOperation(OperationAndData<String>) - Method in class org.apache.curator.framework.imps.SyncBuilderImpl
 
perms - Variable in class org.apache.curator.x.rpc.idl.structs.RpcAcl
 
PersistentEphemeralNode - Class in org.apache.curator.framework.recipes.nodes
Deprecated.
This has been replaced with the more general PersistentNode
PersistentEphemeralNode(CuratorFramework, PersistentEphemeralNode.Mode, String, byte[]) - Constructor for class org.apache.curator.framework.recipes.nodes.PersistentEphemeralNode
Deprecated.
 
PersistentEphemeralNode.Mode - Enum in org.apache.curator.framework.recipes.nodes
Deprecated.
This has been replaced with the more general PersistentNode
PersistentEphemeralNodeProjection - Class in org.apache.curator.x.rpc.idl.structs
 
PersistentEphemeralNodeProjection() - Constructor for class org.apache.curator.x.rpc.idl.structs.PersistentEphemeralNodeProjection
 
PersistentEphemeralNodeProjection(String) - Constructor for class org.apache.curator.x.rpc.idl.structs.PersistentEphemeralNodeProjection
 
PersistentNode - Class in org.apache.curator.framework.recipes.nodes
A persistent node is a node that attempts to stay present in ZooKeeper, even through connection and session interruptions.
PersistentNode(CuratorFramework, CreateMode, boolean, String, byte[]) - Constructor for class org.apache.curator.framework.recipes.nodes.PersistentNode
 
pingCuratorProjection(CuratorProjection) - Method in class org.apache.curator.x.rpc.idl.services.CuratorProjectionService
 
poll() - Method in class org.apache.curator.ensemble.exhibitor.ExhibitorEnsembleProvider
 
poll(long, TimeUnit) - Method in class org.apache.curator.framework.recipes.queue.SimpleDistributedQueue
Retrieves and removes the head of this queue, waiting up to the specified wait time if necessary for an element to become available.
poll() - Method in class org.apache.curator.framework.recipes.queue.SimpleDistributedQueue
Attempts to remove the head of the queue and return it.
pollForEvent(long) - Method in class org.apache.curator.x.rpc.connections.CuratorEntry
 
pollForInitialEnsemble() - Method in class org.apache.curator.ensemble.exhibitor.ExhibitorEnsembleProvider
Can be called prior to starting the Curator instance to set the current connection string
port(int) - Method in class org.apache.curator.x.discovery.ServiceInstanceBuilder
 
port - Variable in class org.apache.curator.x.rpc.idl.discovery.DiscoveryInstance
 
postValue() - Method in interface org.apache.curator.framework.recipes.atomic.AtomicValue
Returns the value of the counter after to the operation
PredicateResults - Class in org.apache.curator.framework.recipes.locks
 
PredicateResults(String, boolean) - Constructor for class org.apache.curator.framework.recipes.locks.PredicateResults
 
preValue() - Method in interface org.apache.curator.framework.recipes.atomic.AtomicValue
Returns the value of the counter prior to the operation
process(WatchedEvent) - Method in interface org.apache.curator.framework.api.CuratorWatcher
Same as Watcher.process(WatchedEvent).
process(WatchedEvent) - Method in class org.apache.curator.framework.imps.EnsembleTracker
 
process(WatchedEvent) - Method in class org.apache.curator.x.rpc.details.RpcWatcher
 
processResult(CuratorFramework, CuratorEvent) - Method in interface org.apache.curator.framework.api.BackgroundCallback
Called when the async background operation completes
processResult(CuratorFramework, CuratorEvent) - Method in class org.apache.curator.x.rpc.details.RpcBackgroundCallback
 
processWithLockSafety(String, DistributedQueue.ProcessType) - Method in class org.apache.curator.framework.recipes.queue.DistributedQueue
 
projection - Variable in class org.apache.curator.x.rpc.idl.structs.LeaderResult
 
PromotedToLock - Class in org.apache.curator.framework.recipes.atomic
Abstraction of arguments for mutex promotion.
PromotedToLock.Builder - Class in org.apache.curator.framework.recipes.atomic
 
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
 
ProtectACLCreateModePathAndBytesable<T> - Interface in org.apache.curator.framework.api
 
ProtectACLCreateModeStatPathAndBytesable<T> - Interface in org.apache.curator.framework.api
 
ProviderStrategy<T> - Interface in org.apache.curator.x.discovery
A strategy for picking one from a set of instances
providerStrategy(ProviderStrategy<T>) - Method in interface org.apache.curator.x.discovery.ServiceProviderBuilder
optional - set the provider strategy.
ProviderStrategyType - Enum in org.apache.curator.x.rpc.idl.discovery
 
put(T, long) - Method in class org.apache.curator.framework.recipes.queue.DistributedDelayQueue
Add an item into the queue.
put(T, long, int, TimeUnit) - Method in class org.apache.curator.framework.recipes.queue.DistributedDelayQueue
Same as DistributedDelayQueue.put(Object, long) but allows a maximum wait time if an upper bound was set via QueueBuilder.maxItems.
put(T, String) - Method in class org.apache.curator.framework.recipes.queue.DistributedIdQueue
Put an item into the queue with the given Id

NOTE: if an upper bound was set via QueueBuilder.maxItems, this method will block until there is available space in the queue.
put(T, String, int, TimeUnit) - Method in class org.apache.curator.framework.recipes.queue.DistributedIdQueue
Same as DistributedIdQueue.put(Object, String) but allows a maximum wait time if an upper bound was set via QueueBuilder.maxItems.
put(T, int) - Method in class org.apache.curator.framework.recipes.queue.DistributedPriorityQueue
Add an item into the queue.
put(T, int, int, TimeUnit) - Method in class org.apache.curator.framework.recipes.queue.DistributedPriorityQueue
Same as DistributedPriorityQueue.put(Object, int) but allows a maximum wait time if an upper bound was set via QueueBuilder.maxItems.
put(T) - Method in class org.apache.curator.framework.recipes.queue.DistributedQueue
Add an item into the queue.
put(T, int, TimeUnit) - Method in class org.apache.curator.framework.recipes.queue.DistributedQueue
Same as DistributedQueue.put(Object) but allows a maximum wait time if an upper bound was set via QueueBuilder.maxItems.
putCompleted(T) - Method in interface org.apache.curator.framework.recipes.queue.QueuePutListener
Notification that a single item put has completed
putInBackground(boolean) - Method in class org.apache.curator.framework.recipes.queue.QueueBuilder
By default, messages are added in the background.
putMulti(MultiItem<T>, long) - Method in class org.apache.curator.framework.recipes.queue.DistributedDelayQueue
Add a set of items with the same priority into the queue.
putMulti(MultiItem<T>, long, int, TimeUnit) - Method in class org.apache.curator.framework.recipes.queue.DistributedDelayQueue
Same as DistributedDelayQueue.putMulti(MultiItem, long) but allows a maximum wait time if an upper bound was set via QueueBuilder.maxItems.
putMulti(MultiItem<T>, int) - Method in class org.apache.curator.framework.recipes.queue.DistributedPriorityQueue
Add a set of items with the same priority into the queue.
putMulti(MultiItem<T>, int, int, TimeUnit) - Method in class org.apache.curator.framework.recipes.queue.DistributedPriorityQueue
Same as DistributedPriorityQueue.putMulti(MultiItem, int) but allows a maximum wait time if an upper bound was set via QueueBuilder.maxItems.
putMulti(MultiItem<T>) - Method in class org.apache.curator.framework.recipes.queue.DistributedQueue
Add a set of items into the queue.
putMulti(MultiItem<T>, int, TimeUnit) - Method in class org.apache.curator.framework.recipes.queue.DistributedQueue
Same as DistributedQueue.putMulti(MultiItem) but allows a maximum wait time if an upper bound was set via QueueBuilder.maxItems.
putMultiCompleted(MultiItem<T>) - Method in interface org.apache.curator.framework.recipes.queue.QueuePutListener
Notification that a multi item put has completed
putService(ServiceInstance<T>, String, String) - Method in class org.apache.curator.x.discovery.server.rest.DiscoveryResource
 
pzxid - Variable in class org.apache.curator.x.rpc.idl.structs.RpcStat
 

Q

queryForInstance(String, String) - Method in class org.apache.curator.x.discovery.details.ServiceDiscoveryImpl
Return a service instance POJO
queryForInstance(String, String) - Method in interface org.apache.curator.x.discovery.ServiceDiscovery
Return a service instance POJO
queryForInstance(CuratorProjection, DiscoveryProjection, String, String) - Method in class org.apache.curator.x.rpc.idl.discovery.DiscoveryServiceLowLevel
 
queryForInstances(String) - Method in class org.apache.curator.x.discovery.details.ServiceDiscoveryImpl
Return all known instances for the given service
queryForInstances(String) - Method in interface org.apache.curator.x.discovery.ServiceDiscovery
Return all known instances for the given service
queryForInstances(CuratorProjection, DiscoveryProjection, String) - Method in class org.apache.curator.x.rpc.idl.discovery.DiscoveryServiceLowLevel
 
queryForNames() - Method in class org.apache.curator.x.discovery.details.ServiceDiscoveryImpl
Return the names of all known services
queryForNames() - Method in interface org.apache.curator.x.discovery.ServiceDiscovery
Return the names of all known services
queryForNames(CuratorProjection, DiscoveryProjection) - Method in class org.apache.curator.x.rpc.idl.discovery.DiscoveryServiceLowLevel
 
QueueAllocator<U,T extends QueueBase<U>> - Interface in org.apache.curator.framework.recipes.queue
 
QueueBase<T> - Interface in org.apache.curator.framework.recipes.queue
 
QueueBuilder<T> - Class in org.apache.curator.framework.recipes.queue
QueueConsumer<T> - Interface in org.apache.curator.framework.recipes.queue
Message Consumer
QueuePutListener<T> - Interface in org.apache.curator.framework.recipes.queue
Queue puts are done in the background.
QueueSafety<T> - Class in org.apache.curator.framework.recipes.queue
Parameter block for specifying queue safety with either DistributedQueue or DistributedPriorityQueue
QueueSafety(String, QueueConsumer<T>) - Constructor for class org.apache.curator.framework.recipes.queue.QueueSafety
 
QueueSerializer<T> - Interface in org.apache.curator.framework.recipes.queue
Helper to serialize/deserialize queue items
QueueSharder<U,T extends QueueBase<U>> - Class in org.apache.curator.framework.recipes.queue
A utility for shard a distributed queue.
QueueSharder(CuratorFramework, QueueAllocator<U, T>, String, String, QueueSharderPolicies) - Constructor for class org.apache.curator.framework.recipes.queue.QueueSharder
 
QueueSharderPolicies - Class in org.apache.curator.framework.recipes.queue
Various policies/options for sharding.
QueueSharderPolicies.Builder - Class in org.apache.curator.framework.recipes.queue
 
Quietly<T> - Interface in org.apache.curator.framework.api
 
quietly() - Method in interface org.apache.curator.framework.api.Quietly
 
quietly() - Method in class org.apache.curator.framework.imps.DeleteBuilderImpl
 
quietly() - Method in class org.apache.curator.framework.imps.RemoveWatchesBuilderImpl
 
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
 

R

RandomStrategy<T> - Class in org.apache.curator.x.discovery.strategies
This strategy always picks a random instance from the list
RandomStrategy() - Constructor for class org.apache.curator.x.discovery.strategies.RandomStrategy
 
readFrom(Class<ServiceInstance<T>>, Type, Annotation[], MediaType, MultivaluedMap<String, String>, InputStream) - Method in class org.apache.curator.x.discovery.server.entity.JsonServiceInstanceMarshaller
 
readFrom(Class<ServiceInstances<T>>, Type, Annotation[], MediaType, MultivaluedMap<String, String>, InputStream) - Method in class org.apache.curator.x.discovery.server.entity.JsonServiceInstancesMarshaller
 
readFrom(Class<ServiceNames>, Type, Annotation[], MediaType, MultivaluedMap<String, String>, InputStream) - Method in class org.apache.curator.x.discovery.server.entity.JsonServiceNamesMarshaller
 
readLock() - Method in class org.apache.curator.framework.recipes.locks.InterProcessReadWriteLock
Returns the lock used for reading.
reap(Reaper.PathHolder) - Method in class org.apache.curator.framework.recipes.locks.Reaper
Deprecated.
 
Reaper - Class in org.apache.curator.framework.recipes.locks
Deprecated.
Since 2.9.0 - Reaper/ChildReaper are no longer needed. Use CreateMode.CONTAINER. Also, all Curator recipes create container parents.
Reaper(CuratorFramework) - Constructor for class org.apache.curator.framework.recipes.locks.Reaper
Deprecated.
Uses the default reaping threshold of 5 minutes and creates an internal thread pool
Reaper(CuratorFramework, int) - Constructor for class org.apache.curator.framework.recipes.locks.Reaper
Deprecated.
Uses the given reaping threshold and creates an internal thread pool
Reaper(CuratorFramework, ScheduledExecutorService, int) - Constructor for class org.apache.curator.framework.recipes.locks.Reaper
Deprecated.
 
Reaper(CuratorFramework, ScheduledExecutorService, int, String) - Constructor for class org.apache.curator.framework.recipes.locks.Reaper
Deprecated.
 
Reaper(CuratorFramework, ScheduledExecutorService, int, LeaderLatch) - Constructor for class org.apache.curator.framework.recipes.locks.Reaper
Deprecated.
 
Reaper.Mode - Enum in org.apache.curator.framework.recipes.locks
Deprecated.
 
rebuild() - Method in class org.apache.curator.framework.recipes.cache.NodeCache
NOTE: this is a BLOCKING method.
rebuild() - Method in class org.apache.curator.framework.recipes.cache.PathChildrenCache
NOTE: this is a BLOCKING method.
rebuildNode(String) - Method in class org.apache.curator.framework.recipes.cache.PathChildrenCache
NOTE: this is a BLOCKING method.
reconfig() - Method in interface org.apache.curator.framework.CuratorFramework
Start a reconfig builder
reconfig() - Method in class org.apache.curator.framework.imps.CuratorFrameworkImpl
 
reconfig() - Method in interface org.apache.curator.x.async.api.AsyncCuratorFrameworkDsl
Start a reconfig builder
reconfig() - Method in class org.apache.curator.x.async.details.AsyncCuratorFrameworkImpl
 
ReconfigBuilder - Interface in org.apache.curator.framework.api
 
ReconfigBuilderImpl - Class in org.apache.curator.framework.imps
 
ReconfigBuilderImpl(CuratorFrameworkImpl) - Constructor for class org.apache.curator.framework.imps.ReconfigBuilderImpl
 
ReconfigBuilderImpl(CuratorFrameworkImpl, Backgrounding, Stat, long, List<String>, List<String>, List<String>) - Constructor for class org.apache.curator.framework.imps.ReconfigBuilderImpl
 
ReconfigBuilderMain - Interface in org.apache.curator.framework.api
 
registerInstance(CuratorProjection, DiscoveryProjection, DiscoveryInstance) - Method in class org.apache.curator.x.rpc.idl.discovery.DiscoveryServiceLowLevel
 
registerJMX() - Method in class org.apache.curator.test.TestingZooKeeperMain.TestZooKeeperServer
 
registerService(ServiceInstance<T>) - Method in class org.apache.curator.x.discovery.details.ServiceDiscoveryImpl
Register/re-register/update a service instance
registerService(ServiceInstance<T>) - Method in interface org.apache.curator.x.discovery.ServiceDiscovery
Register/re-register a service
registrationTimeUTC(long) - Method in class org.apache.curator.x.discovery.ServiceInstanceBuilder
 
registrationTimeUTC - Variable in class org.apache.curator.x.rpc.idl.discovery.DiscoveryInstance
 
release() - Method in interface org.apache.curator.framework.recipes.locks.InterProcessLock
Perform one release of the mutex.
release() - Method in class org.apache.curator.framework.recipes.locks.InterProcessMultiLock
Perform one release of the mutex.
release() - Method in class org.apache.curator.framework.recipes.locks.InterProcessMutex
Perform one release of the mutex if the calling thread is the same thread that acquired it.
release() - Method in class org.apache.curator.framework.recipes.locks.InterProcessSemaphoreMutex
 
releaseLock() - Method in class org.apache.curator.framework.recipes.locks.Locker
 
remove(Watcher) - Method in interface org.apache.curator.framework.api.RemoveWatchesBuilder
Specify the watcher to be removed
remove(CuratorWatcher) - Method in interface org.apache.curator.framework.api.RemoveWatchesBuilder
Specify the watcher to be removed
remove(Watcher) - Method in class org.apache.curator.framework.imps.RemoveWatchesBuilderImpl
 
remove(CuratorWatcher) - Method in class org.apache.curator.framework.imps.RemoveWatchesBuilderImpl
 
remove(String) - Method in class org.apache.curator.framework.recipes.cache.PathChildrenCache
 
remove(String) - Method in class org.apache.curator.framework.recipes.queue.DistributedIdQueue
Remove any items with the given Id
remove() - Method in class org.apache.curator.framework.recipes.queue.SimpleDistributedQueue
Attempts to remove the head of the queue and return it.
remove(UriSpec.Part) - Method in class org.apache.curator.x.discovery.UriSpec
Remove the given part
remove(String) - Method in class org.apache.curator.x.rpc.connections.ConnectionManager
 
removeAll() - Method in interface org.apache.curator.framework.api.RemoveWatchesBuilder
Specify that all watches should be removed
removeAll() - Method in class org.apache.curator.framework.imps.RemoveWatchesBuilderImpl
 
removeBarrier() - Method in class org.apache.curator.framework.recipes.barriers.DistributedBarrier
Utility to remove the barrier node
removeListener(T) - Method in interface org.apache.curator.framework.listen.Listenable
Remove the given listener
removeListener(T) - Method in class org.apache.curator.framework.listen.ListenerContainer
 
removeListener(LeaderLatchListener) - Method in class org.apache.curator.framework.recipes.leader.LeaderLatch
Removes a given listener from this LeaderLatch
removeListener(SharedCountListener) - Method in class org.apache.curator.framework.recipes.shared.SharedCount
 
removeListener(ServiceCacheListener) - Method in class org.apache.curator.x.discovery.details.ServiceCacheImpl
 
removePath(String) - Method in class org.apache.curator.framework.recipes.locks.ChildReaper
Deprecated.
Remove a path from reaping
removePath(String) - Method in class org.apache.curator.framework.recipes.locks.Reaper
Deprecated.
Stop reaping the given path
removeService(String, String) - Method in class org.apache.curator.x.discovery.server.rest.DiscoveryResource
 
RemoveWatcherOption - Enum in org.apache.curator.x.async.api
Options to use when removing watchers
removeWatchers() - Method in interface org.apache.curator.framework.WatcherRemoveCuratorFramework
Remove all outstanding watchers that have been set
removeWatches() - Method in interface org.apache.curator.x.async.api.AsyncCuratorFrameworkDsl
Start a remove watches builder
removeWatches() - Method in class org.apache.curator.x.async.details.AsyncCuratorFrameworkImpl
 
RemoveWatchesBuilder - Interface in org.apache.curator.framework.api
Builder to allow watches to be removed
RemoveWatchesBuilderImpl - Class in org.apache.curator.framework.imps
 
RemoveWatchesBuilderImpl(CuratorFrameworkImpl) - Constructor for class org.apache.curator.framework.imps.RemoveWatchesBuilderImpl
 
RemoveWatchesBuilderImpl(CuratorFrameworkImpl, Watcher, CuratorWatcher, Watcher.WatcherType, boolean, boolean, boolean, Backgrounding) - Constructor for class org.apache.curator.framework.imps.RemoveWatchesBuilderImpl
 
RemoveWatchesLocal - Interface in org.apache.curator.framework.api
Builder to allow the specification of whether it is acceptable to remove client side watch information in the case where ZK cannot be contacted.
RemoveWatchesType - Interface in org.apache.curator.framework.api
Builder to allow the specification of whether it is acceptable to remove client side watch information in the case where ZK cannot be contacted.
removing(Watcher) - Method in interface org.apache.curator.x.async.api.AsyncRemoveWatchesBuilder
 
removing(CuratorWatcher) - Method in interface org.apache.curator.x.async.api.AsyncRemoveWatchesBuilder
 
removing(Watcher, Set<RemoveWatcherOption>) - Method in interface org.apache.curator.x.async.api.AsyncRemoveWatchesBuilder
 
removing(CuratorWatcher, Set<RemoveWatcherOption>) - Method in interface org.apache.curator.x.async.api.AsyncRemoveWatchesBuilder
 
removing(Watcher, Watcher.WatcherType, Set<RemoveWatcherOption>) - Method in interface org.apache.curator.x.async.api.AsyncRemoveWatchesBuilder
Remove a watcher of a given type
removing(CuratorWatcher, Watcher.WatcherType, Set<RemoveWatcherOption>) - Method in interface org.apache.curator.x.async.api.AsyncRemoveWatchesBuilder
Remove a watcher of a given type
removing(Watcher, Watcher.WatcherType) - Method in interface org.apache.curator.x.async.api.AsyncRemoveWatchesBuilder
Remove a watcher of a given type
removing(CuratorWatcher, Watcher.WatcherType) - Method in interface org.apache.curator.x.async.api.AsyncRemoveWatchesBuilder
Remove a watcher of a given type
removingAll() - Method in interface org.apache.curator.x.async.api.AsyncRemoveWatchesBuilder
Remove all watchers
removingAll(Set<RemoveWatcherOption>) - Method in interface org.apache.curator.x.async.api.AsyncRemoveWatchesBuilder
Remove all watchers
removingAll(Watcher.WatcherType, Set<RemoveWatcherOption>) - Method in interface org.apache.curator.x.async.api.AsyncRemoveWatchesBuilder
Remove all watchers of a given type
removingAll(Watcher.WatcherType) - Method in interface org.apache.curator.x.async.api.AsyncRemoveWatchesBuilder
Remove all watchers of a given type
requeue() - Method in class org.apache.curator.framework.recipes.leader.LeaderSelector
Re-queue an attempt for leadership.
reset() - Method in class org.apache.curator.CuratorZookeeperClient
For internal use only - reset the internally managed ZK handle
reset() - Method in class org.apache.curator.framework.EnsureContainers
Reset so that the next call to EnsureContainers.ensure() will attempt to create containers
reset() - Static method in class org.apache.curator.test.InstanceSpec
 
reset() - Method in exception org.apache.curator.x.async.AsyncEventException
ZooKeeper temporarily triggers watchers when there is a connection event.
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
resultCode - Variable in class org.apache.curator.x.rpc.idl.structs.RpcCuratorEvent
 
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.
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
 
RetryNTimesConfiguration - Class in org.apache.curator.x.rpc.configuration
 
RetryNTimesConfiguration() - Constructor for class org.apache.curator.x.rpc.configuration.RetryNTimesConfiguration
 
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(RetryPolicy) - Method in class org.apache.curator.framework.CuratorFrameworkFactory.Builder
 
retryPolicy(RetryPolicy) - Method in class org.apache.curator.framework.recipes.atomic.PromotedToLock.Builder
Set the retry policy to use when an operation does not succeed
RetryPolicy - Interface in org.apache.curator
Abstracts the policy to use when retrying connections
RetryPolicyConfiguration - Class in org.apache.curator.x.rpc.configuration
 
RetryPolicyConfiguration() - Constructor for class org.apache.curator.x.rpc.configuration.RetryPolicyConfiguration
 
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
 
returnAll(Collection<Lease>) - Method in class org.apache.curator.framework.recipes.locks.InterProcessSemaphore
Deprecated.
Convenience method.
returnAll(Collection<Lease>) - Method in class org.apache.curator.framework.recipes.locks.InterProcessSemaphoreV2
Convenience method.
returnLease(Lease) - Method in class org.apache.curator.framework.recipes.locks.InterProcessSemaphore
Deprecated.
Convenience method.
returnLease(Lease) - Method in class org.apache.curator.framework.recipes.locks.InterProcessSemaphoreV2
Convenience method.
Revocable<T> - Interface in org.apache.curator.framework.recipes.locks
Specifies locks that can be revoked
RevocationListener<T> - Interface in org.apache.curator.framework.recipes.locks
 
revocationRequested(T) - Method in interface org.apache.curator.framework.recipes.locks.RevocationListener
Called when a revocation request has been received.
Revoker - Class in org.apache.curator.framework.recipes.locks
 
RoundRobinStrategy<T> - Class in org.apache.curator.x.discovery.strategies
This strategy rotates sequentially through the list of instances
RoundRobinStrategy() - Constructor for class org.apache.curator.x.discovery.strategies.RoundRobinStrategy
 
RpcAcl - Class in org.apache.curator.x.rpc.idl.structs
 
RpcAcl() - Constructor for class org.apache.curator.x.rpc.idl.structs.RpcAcl
 
RpcAcl(int, RpcId) - Constructor for class org.apache.curator.x.rpc.idl.structs.RpcAcl
 
RpcBackgroundCallback - Class in org.apache.curator.x.rpc.details
 
RpcBackgroundCallback(CuratorProjectionService, CuratorProjection) - Constructor for class org.apache.curator.x.rpc.details.RpcBackgroundCallback
 
RpcChildData - Class in org.apache.curator.x.rpc.idl.structs
 
RpcChildData() - Constructor for class org.apache.curator.x.rpc.idl.structs.RpcChildData
 
RpcChildData(ChildData) - Constructor for class org.apache.curator.x.rpc.idl.structs.RpcChildData
 
RpcChildData(String, RpcStat, byte[]) - Constructor for class org.apache.curator.x.rpc.idl.structs.RpcChildData
 
RpcCreateMode - Enum in org.apache.curator.x.rpc.idl.structs
 
RpcCuratorEvent - Class in org.apache.curator.x.rpc.idl.structs
 
RpcCuratorEvent() - Constructor for class org.apache.curator.x.rpc.idl.structs.RpcCuratorEvent
 
RpcCuratorEvent(RpcCuratorEventType, String) - Constructor for class org.apache.curator.x.rpc.idl.structs.RpcCuratorEvent
 
RpcCuratorEvent(RpcPathChildrenCacheEvent) - Constructor for class org.apache.curator.x.rpc.idl.structs.RpcCuratorEvent
 
RpcCuratorEvent(CuratorEvent) - Constructor for class org.apache.curator.x.rpc.idl.structs.RpcCuratorEvent
 
RpcCuratorEvent(ConnectionState) - Constructor for class org.apache.curator.x.rpc.idl.structs.RpcCuratorEvent
 
RpcCuratorEvent(WatchedEvent) - Constructor for class org.apache.curator.x.rpc.idl.structs.RpcCuratorEvent
 
RpcCuratorEvent(LeaderEvent) - Constructor for class org.apache.curator.x.rpc.idl.structs.RpcCuratorEvent
 
RpcCuratorEventType - Enum in org.apache.curator.x.rpc.idl.structs
 
RpcEventType - Enum in org.apache.curator.x.rpc.idl.structs
 
RpcException - Exception in org.apache.curator.x.rpc.idl.exceptions
 
RpcException() - Constructor for exception org.apache.curator.x.rpc.idl.exceptions.RpcException
 
RpcException(Exception) - Constructor for exception org.apache.curator.x.rpc.idl.exceptions.RpcException
 
RpcException(ExceptionType, ZooKeeperExceptionType, NodeExceptionType, String) - Constructor for exception org.apache.curator.x.rpc.idl.exceptions.RpcException
 
RpcId - Class in org.apache.curator.x.rpc.idl.structs
 
RpcId() - Constructor for class org.apache.curator.x.rpc.idl.structs.RpcId
 
RpcId(String, String) - Constructor for class org.apache.curator.x.rpc.idl.structs.RpcId
 
RpcKeeperState - Enum in org.apache.curator.x.rpc.idl.structs
 
RpcParticipant - Class in org.apache.curator.x.rpc.idl.structs
 
RpcParticipant() - Constructor for class org.apache.curator.x.rpc.idl.structs.RpcParticipant
 
RpcParticipant(String, boolean) - Constructor for class org.apache.curator.x.rpc.idl.structs.RpcParticipant
 
RpcPathChildrenCacheEvent - Class in org.apache.curator.x.rpc.idl.structs
 
RpcPathChildrenCacheEvent() - Constructor for class org.apache.curator.x.rpc.idl.structs.RpcPathChildrenCacheEvent
 
RpcPathChildrenCacheEvent(String, PathChildrenCacheEvent) - Constructor for class org.apache.curator.x.rpc.idl.structs.RpcPathChildrenCacheEvent
 
RpcPathChildrenCacheEvent(String, RpcPathChildrenCacheEventType, RpcChildData) - Constructor for class org.apache.curator.x.rpc.idl.structs.RpcPathChildrenCacheEvent
 
RpcPathChildrenCacheEventType - Enum in org.apache.curator.x.rpc.idl.structs
 
RpcPersistentEphemeralNodeMode - Enum in org.apache.curator.x.rpc.idl.structs
 
RpcStat - Class in org.apache.curator.x.rpc.idl.structs
 
RpcStat() - Constructor for class org.apache.curator.x.rpc.idl.structs.RpcStat
 
RpcStat(Stat) - Constructor for class org.apache.curator.x.rpc.idl.structs.RpcStat
 
RpcStat(long, long, long, long, int, int, int, long, int, int, long) - Constructor for class org.apache.curator.x.rpc.idl.structs.RpcStat
 
RpcWatchedEvent - Class in org.apache.curator.x.rpc.idl.structs
 
RpcWatchedEvent() - Constructor for class org.apache.curator.x.rpc.idl.structs.RpcWatchedEvent
 
RpcWatchedEvent(WatchedEvent) - Constructor for class org.apache.curator.x.rpc.idl.structs.RpcWatchedEvent
 
RpcWatchedEvent(RpcKeeperState, RpcEventType, String) - Constructor for class org.apache.curator.x.rpc.idl.structs.RpcWatchedEvent
 
RpcWatcher - Class in org.apache.curator.x.rpc.details
 
RpcWatcher(CuratorProjectionService, CuratorProjection) - Constructor for class org.apache.curator.x.rpc.details.RpcWatcher
 
runFromConfig(QuorumPeerConfig) - Method in class org.apache.curator.test.TestingZooKeeperMain
 
runFromConfig(QuorumPeerConfig) - Method in interface org.apache.curator.test.ZooKeeperMainFace
 

S

schedule(Reaper.PathHolder, int) - Method in class org.apache.curator.framework.recipes.locks.Reaper
Deprecated.
 
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.
Schema - Class in org.apache.curator.framework.schema
Represents and documents operations allowed for a given path pattern
Schema.Allowance - Enum in org.apache.curator.framework.schema
 
SchemaBuilder - Class in org.apache.curator.framework.schema
 
schemaSet(SchemaSet) - Method in class org.apache.curator.framework.CuratorFrameworkFactory.Builder
Add an enforced schema set
SchemaSet - Class in org.apache.curator.framework.schema
Collection of all schemas for a Curator instance
SchemaSet(List<Schema>, boolean) - Constructor for class org.apache.curator.framework.schema.SchemaSet
Define a schema set.
SchemaSetLoader - Class in org.apache.curator.framework.schema
Utility to load schems set from a JSON stream/file.
SchemaSetLoader(String, SchemaSetLoader.SchemaValidatorMapper) - Constructor for class org.apache.curator.framework.schema.SchemaSetLoader
 
SchemaSetLoader(Reader, SchemaSetLoader.SchemaValidatorMapper) - Constructor for class org.apache.curator.framework.schema.SchemaSetLoader
 
SchemaSetLoader(JsonNode, SchemaSetLoader.SchemaValidatorMapper) - Constructor for class org.apache.curator.framework.schema.SchemaSetLoader
 
SchemaSetLoader.SchemaValidatorMapper - Interface in org.apache.curator.framework.schema
Called to map a schema validator name in the JSON stream to an actual data validator
SchemaValidator - Interface in org.apache.curator.framework.schema
 
SchemaViolation - Exception in org.apache.curator.framework.schema
Thrown by the various validation methods in a Schema
SchemaViolation(String) - Constructor for exception org.apache.curator.framework.schema.SchemaViolation
SchemaViolation(Schema, String) - Constructor for exception org.apache.curator.framework.schema.SchemaViolation
SchemaViolation(Schema, SchemaViolation.ViolatorData, String) - Constructor for exception org.apache.curator.framework.schema.SchemaViolation
 
SchemaViolation.ViolatorData - Class in org.apache.curator.framework.schema
Data about the calling API that violated the schema
scheme - Variable in class org.apache.curator.x.rpc.idl.structs.RpcId
 
seconds() - Method in class org.apache.curator.test.Timing
Return the base time in seconds
sequential(Schema.Allowance) - Method in class org.apache.curator.framework.schema.SchemaBuilder
 
serialize(T) - Method in interface org.apache.curator.framework.recipes.queue.QueueSerializer
Turn a queue item into bytes
serialize(ServiceInstance<T>) - Method in interface org.apache.curator.x.discovery.details.InstanceSerializer
Serialize an instance into bytes
serialize(ServiceInstance<T>) - Method in class org.apache.curator.x.discovery.details.JsonInstanceSerializer
 
serializer(InstanceSerializer<T>) - Method in class org.apache.curator.x.discovery.ServiceDiscoveryBuilder
optional - change the serializer used (the default is JsonInstanceSerializer
server - Variable in class org.apache.curator.test.BaseClassForTests
 
ServiceCache<T> - Interface in org.apache.curator.x.discovery
 
serviceCacheBuilder() - Method in class org.apache.curator.x.discovery.details.ServiceDiscoveryImpl
Allocate a new service cache builder.
ServiceCacheBuilder<T> - Interface in org.apache.curator.x.discovery
 
serviceCacheBuilder() - Method in interface org.apache.curator.x.discovery.ServiceDiscovery
Allocate a new service cache builder.
ServiceCacheImpl<T> - Class in org.apache.curator.x.discovery.details
 
ServiceCacheListener - Interface in org.apache.curator.x.discovery.details
Listener for changes to a service cache
ServiceDiscovery<T> - Interface in org.apache.curator.x.discovery
 
ServiceDiscoveryBuilder<T> - Class in org.apache.curator.x.discovery
 
ServiceDiscoveryImpl<T> - Class in org.apache.curator.x.discovery.details
A mechanism to register and query service instances using ZooKeeper
ServiceDiscoveryImpl(CuratorFramework, String, InstanceSerializer<T>, ServiceInstance<T>, boolean) - Constructor for class org.apache.curator.x.discovery.details.ServiceDiscoveryImpl
 
ServiceInstance<T> - Class in org.apache.curator.x.discovery
POJO that represents a service instance
ServiceInstance(String, String, String, Integer, Integer, T, long, ServiceType, UriSpec) - Constructor for class org.apache.curator.x.discovery.ServiceInstance
 
ServiceInstance(String, String, String, Integer, Integer, T, long, ServiceType, UriSpec, boolean) - Constructor for class org.apache.curator.x.discovery.ServiceInstance
 
ServiceInstanceBuilder<T> - Class in org.apache.curator.x.discovery
Builder for service instances
ServiceInstances<T> - Class in org.apache.curator.x.discovery.server.entity
Raw generic lists don't work well in JAX-RS.
ServiceInstances() - Constructor for class org.apache.curator.x.discovery.server.entity.ServiceInstances
 
ServiceInstances(Collection<? extends ServiceInstance<T>>) - Constructor for class org.apache.curator.x.discovery.server.entity.ServiceInstances
 
serviceName(String) - Method in interface org.apache.curator.x.discovery.ServiceProviderBuilder
required - set the name of the service to be provided
ServiceNames - Class in org.apache.curator.x.discovery.server.entity
Raw generic lists don't work well in JAX-RS.
ServiceNames() - Constructor for class org.apache.curator.x.discovery.server.entity.ServiceNames
 
ServiceNames(Collection<? extends String>) - Constructor for class org.apache.curator.x.discovery.server.entity.ServiceNames
 
ServiceProvider<T> - Interface in org.apache.curator.x.discovery
The main API for Discovery.
serviceProviderBuilder() - Method in class org.apache.curator.x.discovery.details.ServiceDiscoveryImpl
Allocate a new builder.
serviceProviderBuilder() - Method in interface org.apache.curator.x.discovery.ServiceDiscovery
Allocate a new builder.
ServiceProviderBuilder<T> - Interface in org.apache.curator.x.discovery
 
ServiceProviderImpl<T> - Class in org.apache.curator.x.discovery.details
The main interface for Service Discovery.
ServiceProviderImpl(ServiceDiscoveryImpl<T>, String, ProviderStrategy<T>, ThreadFactory, List<InstanceFilter<T>>, DownInstancePolicy) - Constructor for class org.apache.curator.x.discovery.details.ServiceProviderImpl
 
serviceType(ServiceType) - Method in class org.apache.curator.x.discovery.ServiceInstanceBuilder
 
ServiceType - Enum in org.apache.curator.x.discovery
 
serviceType - Variable in class org.apache.curator.x.rpc.idl.discovery.DiscoveryInstance
 
session() - Method in class org.apache.curator.test.Timing
Return the value to use for ZK session timeout
SessionConnectionStateErrorPolicy - Class in org.apache.curator.framework.state
This policy treats only ConnectionState.LOST as an error
SessionConnectionStateErrorPolicy() - Constructor for class org.apache.curator.framework.state.SessionConnectionStateErrorPolicy
 
SessionFailedException() - Constructor for exception org.apache.curator.SessionFailRetryLoop.SessionFailedException
 
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
 
sessionTimeoutMs(int) - Method in class org.apache.curator.framework.CuratorFrameworkFactory.Builder
 
setACL() - Method in interface org.apache.curator.framework.CuratorFramework
Start a set ACL builder
setACL() - Method in class org.apache.curator.framework.imps.CuratorFrameworkImpl
 
setACL() - Method in interface org.apache.curator.x.async.api.AsyncCuratorFrameworkDsl
Start a set ACL builder
setACL() - Method in class org.apache.curator.x.async.details.AsyncCuratorFrameworkImpl
 
SetACLBuilder - Interface in org.apache.curator.framework.api
 
SetACLBuilderImpl - Class in org.apache.curator.framework.imps
 
SetACLBuilderImpl(CuratorFrameworkImpl, Backgrounding, List<ACL>, int) - Constructor for class org.apache.curator.framework.imps.SetACLBuilderImpl
 
setAuth(String) - Method in class org.apache.curator.x.rpc.configuration.AuthorizationConfiguration
 
setAuthorization(AuthorizationConfiguration) - Method in class org.apache.curator.x.rpc.configuration.ConnectionConfiguration
 
setBarrier() - Method in class org.apache.curator.framework.recipes.barriers.DistributedBarrier
Utility to set the barrier node
setBaseSleepTime(Duration) - Method in class org.apache.curator.x.rpc.configuration.BoundedExponentialBackoffRetryConfiguration
 
setBaseSleepTime(Duration) - Method in class org.apache.curator.x.rpc.configuration.ExponentialBackoffRetryConfiguration
 
setCacheData(boolean) - Method in class org.apache.curator.framework.recipes.cache.TreeCache.Builder
Sets whether or not to cache byte data per node; default true.
setConnections(List<ConnectionConfiguration>) - Method in class org.apache.curator.x.rpc.configuration.Configuration
 
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.exhibitor.ExhibitorEnsembleProvider
 
setConnectionString(String) - Method in class org.apache.curator.ensemble.fixed.FixedEnsembleProvider
 
setConnectionString(String) - Method in class org.apache.curator.x.rpc.configuration.ConnectionConfiguration
 
setConnectionTimeout(Duration) - Method in class org.apache.curator.x.rpc.configuration.ConnectionConfiguration
 
setCount(int) - Method in class org.apache.curator.framework.recipes.shared.SharedCount
Change the shared count value irrespective of its previous state
setCreateParentNodes(boolean) - Method in class org.apache.curator.framework.recipes.cache.TreeCache.Builder
By default, TreeCache does not auto-create parent nodes for the cached path.
setData(CuratorFramework, String, byte[]) - Static method in class framework.CrudExamples
 
setData() - Method in interface org.apache.curator.framework.api.transaction.CuratorTransaction
Deprecated.
Start a setData builder in the transaction
setData() - Method in interface org.apache.curator.framework.api.transaction.TransactionOp
Start a setData builder in the transaction
setData() - Method in interface org.apache.curator.framework.CuratorFramework
Start a set data builder
setData() - Method in class org.apache.curator.framework.imps.CuratorFrameworkImpl
 
setData() - Method in class org.apache.curator.framework.imps.TransactionOpImpl
 
setData(byte[]) - Method in class org.apache.curator.framework.recipes.nodes.PersistentNode
Set data that node should set in ZK also writes the data to the node.
setData() - Method in interface org.apache.curator.x.async.api.AsyncCuratorFrameworkDsl
Start a set data builder
setData() - Method in interface org.apache.curator.x.async.api.AsyncTransactionOp
Start a setData builder in the transaction
setData() - Method in class org.apache.curator.x.async.details.AsyncCuratorFrameworkImpl
 
setData(CuratorProjection, SetDataSpec) - Method in class org.apache.curator.x.rpc.idl.services.CuratorProjectionService
 
setDataAsync(CuratorFramework, String, byte[]) - Static method in class framework.CrudExamples
 
setDataAsyncWithCallback(CuratorFramework, BackgroundCallback, String, byte[]) - Static method in class framework.CrudExamples
 
SetDataBackgroundVersionable - Interface in org.apache.curator.framework.api
 
SetDataBuilder - Interface in org.apache.curator.framework.api
 
SetDataBuilderImpl - Class in org.apache.curator.framework.imps
 
SetDataBuilderImpl(CuratorFrameworkImpl, Backgrounding, int, boolean) - Constructor for class org.apache.curator.framework.imps.SetDataBuilderImpl
 
setDataIsCompressed(boolean) - Method in class org.apache.curator.framework.recipes.cache.TreeCache.Builder
Sets whether or to decompress node data; default false.
SetDataSpec - Class in org.apache.curator.x.rpc.idl.structs
 
SetDataSpec() - Constructor for class org.apache.curator.x.rpc.idl.structs.SetDataSpec
 
SetDataSpec(String, boolean, String, boolean, Version, byte[]) - Constructor for class org.apache.curator.x.rpc.idl.structs.SetDataSpec
 
setDescription(String) - Method in class discovery.InstanceDetails
 
setErrorMode(ErrorMode) - Method in class org.apache.curator.framework.recipes.queue.DistributedDelayQueue
 
setErrorMode(ErrorMode) - Method in class org.apache.curator.framework.recipes.queue.DistributedIdQueue
 
setErrorMode(ErrorMode) - Method in class org.apache.curator.framework.recipes.queue.DistributedPriorityQueue
 
setErrorMode(ErrorMode) - Method in class org.apache.curator.framework.recipes.queue.DistributedQueue
Used when the queue is created with a QueueBuilder.lockPath(String).
setErrorMode(ErrorMode) - Method in interface org.apache.curator.framework.recipes.queue.QueueBase
Used when the queue is created with a QueueBuilder.lockPath(String).
setExecuteCalled(boolean) - Method in class org.apache.curator.test.ExecuteCalledWatchingExecutorService
 
setExecutor(ThreadFactory) - Method in class org.apache.curator.framework.recipes.cache.TreeCache.Builder
Sets the executor to publish events; a default executor will be created if not specified.
setExecutor(ExecutorService) - Method in class org.apache.curator.framework.recipes.cache.TreeCache.Builder
Sets the executor to publish events; a default executor will be created if not specified.
setExhibitors(Exhibitors) - Method in class org.apache.curator.ensemble.exhibitor.ExhibitorEnsembleProvider
Change the set of exhibitors to poll
setId(String) - Method in class org.apache.curator.framework.recipes.leader.LeaderSelector
Sets the ID to store for this leader.
setLocalIpFilter(LocalIpFilter) - Static method in class org.apache.curator.x.discovery.ServiceInstanceBuilder
Replace the default local ip filter used by ServiceInstanceBuilder.getAllLocalIPs()
setLogging(LoggingFactory) - Method in class org.apache.curator.x.rpc.configuration.Configuration
 
setMaxChildren(int) - Method in class org.apache.curator.framework.recipes.locks.ChildReaper
Deprecated.
If a node has so many children that CuratorFramework.getChildren() will fail (due to jute.maxbuffer) it can cause connection instability.
setMaxDepth(int) - Method in class org.apache.curator.framework.recipes.cache.TreeCache.Builder
Sets the maximum depth to explore/watch.
setMaxRetries(int) - Method in class org.apache.curator.x.rpc.configuration.BoundedExponentialBackoffRetryConfiguration
 
setMaxRetries(int) - Method in class org.apache.curator.x.rpc.configuration.ExponentialBackoffRetryConfiguration
 
setMaxSleepTime(Duration) - Method in class org.apache.curator.x.rpc.configuration.BoundedExponentialBackoffRetryConfiguration
 
setN(int) - Method in class org.apache.curator.x.rpc.configuration.RetryNTimesConfiguration
 
setName(String) - Method in class org.apache.curator.x.rpc.configuration.ConnectionConfiguration
 
setNamespace(String) - Method in class org.apache.curator.x.rpc.configuration.ConnectionConfiguration
 
setNodeData(byte[]) - Method in class org.apache.curator.framework.recipes.locks.InterProcessSemaphoreV2
Set the data to put for the node created by this semaphore.
setPath(String) - Method in class org.apache.curator.drivers.OperationTrace
 
setPingTime(Duration) - Method in class org.apache.curator.x.rpc.configuration.Configuration
 
setProjectionExpiration(Duration) - Method in class org.apache.curator.x.rpc.configuration.Configuration
 
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
 
setRetry(RetryPolicyConfiguration) - Method in class org.apache.curator.x.rpc.configuration.ConnectionConfiguration
 
setRetryPolicy(RetryPolicy) - Method in class org.apache.curator.CuratorZookeeperClient
Change the retry policy
setReturnCode(int) - Method in class org.apache.curator.drivers.OperationTrace
 
setScheme(String) - Method in class org.apache.curator.x.rpc.configuration.AuthorizationConfiguration
 
setSelector(TreeCacheSelector) - Method in class org.apache.curator.framework.recipes.cache.TreeCache.Builder
By default, DefaultTreeCacheSelector is used.
setSessionLength(Duration) - Method in class org.apache.curator.x.rpc.configuration.ConnectionConfiguration
 
setSleepBetweenRetries(Duration) - Method in class org.apache.curator.x.rpc.configuration.RetryNTimesConfiguration
 
setStat(Stat) - Method in class org.apache.curator.drivers.OperationTrace
 
setThisData(byte[]) - Method in class org.apache.curator.framework.recipes.nodes.GroupMember
Change the data stored in this instance's node
setThrift(ThriftServerConfig) - Method in class org.apache.curator.x.rpc.configuration.Configuration
 
setToSuspended() - Method in class org.apache.curator.framework.state.ConnectionStateManager
Change to ConnectionState.SUSPENDED only if not already suspended and not lost
setTracerDriver(TracerDriver) - Method in class org.apache.curator.CuratorZookeeperClient
Change the tracing driver
setup() - Method in class org.apache.curator.test.BaseClassForTests
 
setValue(byte[]) - Method in class org.apache.curator.framework.recipes.shared.SharedValue
Change the shared value value irrespective of its previous state
setWithWatcher(boolean) - Method in class org.apache.curator.drivers.OperationTrace
 
SharedCount - Class in org.apache.curator.framework.recipes.shared
Manages a shared integer.
SharedCount(CuratorFramework, String, int) - Constructor for class org.apache.curator.framework.recipes.shared.SharedCount
 
SharedCountListener - Interface in org.apache.curator.framework.recipes.shared
Listener for changes to a shared count
SharedCountReader - Interface in org.apache.curator.framework.recipes.shared
Abstracts a shared integer and allows listening for changes to its value
SharedValue - Class in org.apache.curator.framework.recipes.shared
Manages a shared value.
SharedValue(CuratorFramework, String, byte[]) - Constructor for class org.apache.curator.framework.recipes.shared.SharedValue
 
SharedValueListener - Interface in org.apache.curator.framework.recipes.shared
Listener for changes to a shared value
SharedValueReader - Interface in org.apache.curator.framework.recipes.shared
Abstracts a shared value and allows listening for changes to the value
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
shouldRetry(int) - Static method in class org.apache.curator.RetryLoop
Utility - return true if the given Zookeeper result code is retry-able
shutdown() - Method in class org.apache.curator.test.DelegatingExecutorService
 
shutdownNow() - Method in class org.apache.curator.test.DelegatingExecutorService
 
SimpleDistributedQueue - Class in org.apache.curator.framework.recipes.queue
Drop in replacement for: org.apache.zookeeper.recipes.queue.DistributedQueue that is part of the ZooKeeper distribution
SimpleDistributedQueue(CuratorFramework, String) - Constructor for class org.apache.curator.framework.recipes.queue.SimpleDistributedQueue
 
size() - Method in class org.apache.curator.framework.listen.ListenerContainer
Return the number of listeners
size() - Method in class org.apache.curator.framework.recipes.queue.BlockingQueueConsumer
Returns the number of currently queue items
size() - Method in class org.apache.curator.test.QuorumConfigBuilder
 
sleep() - Method in class org.apache.curator.test.Timing
Sleep for a the full amount of time
sleepABit() - Method in class org.apache.curator.test.Timing
Sleep for a small amount of time
sleepFor(long, TimeUnit) - Method in interface org.apache.curator.RetrySleeper
Sleep for the given time
sortChildren(List<String>) - Method in class org.apache.curator.framework.recipes.queue.DistributedQueue
 
split(String) - Static method in class org.apache.curator.utils.ZKPaths
Given a full path, return the the individual parts, without slashes.
sslPort(int) - Method in class org.apache.curator.x.discovery.ServiceInstanceBuilder
 
sslPort - Variable in class org.apache.curator.x.rpc.idl.discovery.DiscoveryInstance
 
StandardConnectionHandlingPolicy - Class in org.apache.curator.connection
Curator's standard connection handling since 3.0.0
StandardConnectionHandlingPolicy() - Constructor for class org.apache.curator.connection.StandardConnectionHandlingPolicy
 
StandardConnectionHandlingPolicy(int) - Constructor for class org.apache.curator.connection.StandardConnectionHandlingPolicy
 
StandardConnectionStateErrorPolicy - Class in org.apache.curator.framework.state
This policy treats ConnectionState.SUSPENDED and ConnectionState.LOST as errors
StandardConnectionStateErrorPolicy() - Constructor for class org.apache.curator.framework.state.StandardConnectionStateErrorPolicy
 
standardFixForSorting(String, String) - Static method in class org.apache.curator.framework.recipes.locks.StandardLockInternalsDriver
 
StandardLockInternalsDriver - Class in org.apache.curator.framework.recipes.locks
 
StandardLockInternalsDriver() - Constructor for class org.apache.curator.framework.recipes.locks.StandardLockInternalsDriver
 
start() - Method in class discovery.ExampleServer
 
start() - Method in class leader.ExampleClient
 
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.exhibitor.ExhibitorEnsembleProvider
 
start() - Method in class org.apache.curator.ensemble.fixed.FixedEnsembleProvider
 
start() - Method in interface org.apache.curator.framework.CuratorFramework
Start the client.
start() - Method in class org.apache.curator.framework.imps.CuratorFrameworkImpl
 
start() - Method in class org.apache.curator.framework.imps.EnsembleTracker
 
start() - Method in class org.apache.curator.framework.recipes.cache.NodeCache
Start the cache.
start(boolean) - Method in class org.apache.curator.framework.recipes.cache.NodeCache
Same as NodeCache.start() but gives the option of doing an initial build
start() - Method in class org.apache.curator.framework.recipes.cache.PathChildrenCache
Start the cache.
start(boolean) - Method in class org.apache.curator.framework.recipes.cache.PathChildrenCache
start(PathChildrenCache.StartMode) - Method in class org.apache.curator.framework.recipes.cache.PathChildrenCache
Start the cache.
start() - Method in class org.apache.curator.framework.recipes.cache.TreeCache
Start the cache.
start() - Method in class org.apache.curator.framework.recipes.leader.LeaderLatch
Add this instance to the leadership election and attempt to acquire leadership.
start() - Method in class org.apache.curator.framework.recipes.leader.LeaderSelector
Attempt leadership.
start() - Method in class org.apache.curator.framework.recipes.locks.ChildReaper
Deprecated.
The reaper must be started
start() - Method in class org.apache.curator.framework.recipes.locks.Reaper
Deprecated.
The reaper must be started
start() - Method in class org.apache.curator.framework.recipes.nodes.GroupMember
Start the group membership.
start() - Method in class org.apache.curator.framework.recipes.nodes.PersistentNode
You must call start() to initiate the persistent node.
start() - Method in class org.apache.curator.framework.recipes.queue.DistributedDelayQueue
Start the queue.
start() - Method in class org.apache.curator.framework.recipes.queue.DistributedIdQueue
 
start() - Method in class org.apache.curator.framework.recipes.queue.DistributedPriorityQueue
Start the queue.
start() - Method in class org.apache.curator.framework.recipes.queue.DistributedQueue
Start the queue.
start() - Method in interface org.apache.curator.framework.recipes.queue.QueueBase
Start the queue.
start() - Method in class org.apache.curator.framework.recipes.queue.QueueSharder
The sharder must be started
start() - Method in class org.apache.curator.framework.recipes.shared.SharedCount
The shared count must be started before it can be used.
start() - Method in class org.apache.curator.framework.recipes.shared.SharedValue
The shared value must be started before it can be used.
start() - Method in class org.apache.curator.framework.state.ConnectionStateManager
Start the manager
start() - Method in class org.apache.curator.SessionFailRetryLoop
SessionFailRetryLoop must be started
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() - Method in class org.apache.curator.test.TestingZooKeeperServer
 
start() - Method in class org.apache.curator.x.discovery.details.ServiceCacheImpl
 
start() - Method in class org.apache.curator.x.discovery.details.ServiceDiscoveryImpl
The discovery must be started before use
start() - Method in class org.apache.curator.x.discovery.details.ServiceProviderImpl
The provider must be started before use
start() - Method in class org.apache.curator.x.discovery.server.rest.InstanceCleanup
Start the task
start() - Method in interface org.apache.curator.x.discovery.ServiceCache
The cache must be started before use
start() - Method in interface org.apache.curator.x.discovery.ServiceDiscovery
The discovery must be started before use
start() - Method in interface org.apache.curator.x.discovery.ServiceProvider
The provider must be started before use
start() - Method in class org.apache.curator.x.rpc.connections.ConnectionManager
 
start() - Method in class org.apache.curator.x.rpc.CuratorProjectionServer
 
startAdvancedTracer(String) - Method in class org.apache.curator.CuratorZookeeperClient
Start a new advanced tracer with more metrics being recorded
startDiscovery(CuratorProjection, String, DiscoveryInstance) - Method in class org.apache.curator.x.rpc.idl.discovery.DiscoveryService
 
startLeaderSelector(CuratorProjection, String, String, int) - Method in class org.apache.curator.x.rpc.idl.services.CuratorProjectionService
 
startNodeCache(CuratorProjection, String, boolean, boolean) - Method in class org.apache.curator.x.rpc.idl.services.CuratorProjectionService
 
startPathChildrenCache(CuratorProjection, String, boolean, boolean, PathChildrenCacheStartMode) - Method in class org.apache.curator.x.rpc.idl.services.CuratorProjectionService
 
startPersistentEphemeralNode(CuratorProjection, String, byte[], RpcPersistentEphemeralNodeMode) - Method in class org.apache.curator.x.rpc.idl.services.CuratorProjectionService
 
startProvider(CuratorProjection, DiscoveryProjection, String, ProviderStrategyType, int, int) - Method in class org.apache.curator.x.rpc.idl.discovery.DiscoveryService
 
startServer(String) - Static method in class org.apache.curator.x.rpc.CuratorProjectionServer
 
startTracer(String) - Method in class org.apache.curator.CuratorZookeeperClient
Start a new tracer
stat - Variable in class org.apache.curator.x.rpc.idl.structs.OptionalRpcStat
 
stat - Variable in class org.apache.curator.x.rpc.idl.structs.RpcChildData
 
stat - Variable in class org.apache.curator.x.rpc.idl.structs.RpcCuratorEvent
 
Statable<T> - Interface in org.apache.curator.framework.api
 
StatConfigureEnsembleable - Interface in org.apache.curator.framework.api
 
stateChanged(CuratorFramework, ConnectionState) - Method in class org.apache.curator.framework.recipes.leader.LeaderSelectorListenerAdapter
 
stateChanged(CuratorFramework, ConnectionState) - Method in class org.apache.curator.framework.recipes.queue.BlockingQueueConsumer
 
stateChanged(CuratorFramework, ConnectionState) - Method in interface org.apache.curator.framework.state.ConnectionStateListener
Called when there is a state change in the connection
StatPathable<T> - Interface in org.apache.curator.framework.api
 
StickyStrategy<T> - Class in org.apache.curator.x.discovery.strategies
This strategy uses a master strategy to pick the initial instance.
StickyStrategy(ProviderStrategy<T>) - Constructor for class org.apache.curator.x.discovery.strategies.StickyStrategy
 
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
 
stop() - Method in class org.apache.curator.x.rpc.CuratorProjectionServer
 
storingStatIn(Stat) - Method in interface org.apache.curator.framework.api.Statable
Have the operation fill the provided stat object
storingStatIn(Stat) - Method in class org.apache.curator.framework.imps.CreateBuilderImpl
 
storingStatIn(Stat) - Method in class org.apache.curator.framework.imps.GetACLBuilderImpl
 
storingStatIn(Stat) - Method in class org.apache.curator.framework.imps.GetChildrenBuilderImpl
 
storingStatIn(Stat) - Method in class org.apache.curator.framework.imps.GetConfigBuilderImpl
 
storingStatIn(Stat) - Method in class org.apache.curator.framework.imps.GetDataBuilderImpl
 
storingStatIn(Stat) - Method in interface org.apache.curator.x.async.api.AsyncCreateBuilder
Have the operation fill the provided stat object
storingStatIn(Stat) - Method in interface org.apache.curator.x.async.api.AsyncGetACLBuilder
Have the operation fill the provided stat object
storingStatIn(Stat) - Method in interface org.apache.curator.x.async.api.AsyncGetChildrenBuilder
Have the operation fill the provided stat object
storingStatIn(Stat) - Method in interface org.apache.curator.x.async.api.AsyncGetConfigBuilder
Have the operation fill the provided stat object
storingStatIn(Stat) - Method in interface org.apache.curator.x.async.api.AsyncGetDataBuilder
Have the operation fill the provided stat object
StringDiscoveryContext - Class in org.apache.curator.x.discovery.server.contexts
For convenience, a version of DiscoveryContext that uses a string as the payload
StringDiscoveryContext(ServiceDiscovery<String>, ProviderStrategy<String>, int) - Constructor for class org.apache.curator.x.discovery.server.contexts.StringDiscoveryContext
 
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
 
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.
subtract(Integer) - Method in class org.apache.curator.framework.recipes.atomic.DistributedAtomicInteger
Subtract delta from the current value and return the new value information.
subtract(Long) - Method in class org.apache.curator.framework.recipes.atomic.DistributedAtomicLong
Subtract delta from the current value and return the new value information.
subtract(T) - Method in interface org.apache.curator.framework.recipes.atomic.DistributedAtomicNumber
Subtract delta from the current value and return the new value information.
succeeded() - Method in interface org.apache.curator.framework.recipes.atomic.AtomicValue
MUST be checked. Returns true if the operation succeeded.
sync(String, Object) - Method in interface org.apache.curator.framework.CuratorFramework
Deprecated.
sync() - Method in interface org.apache.curator.framework.CuratorFramework
Start a sync builder.
sync(String, Object) - Method in class org.apache.curator.framework.imps.CuratorFrameworkImpl
 
sync() - Method in class org.apache.curator.framework.imps.CuratorFrameworkImpl
 
sync() - Method in interface org.apache.curator.x.async.api.AsyncCuratorFrameworkDsl
Start a sync builder
sync() - Method in class org.apache.curator.x.async.details.AsyncCuratorFrameworkImpl
 
sync(CuratorProjection, String, String) - Method in class org.apache.curator.x.rpc.idl.services.CuratorProjectionService
 
SyncBuilder - Interface in org.apache.curator.framework.api
 
SyncBuilderImpl - Class in org.apache.curator.framework.imps
 
SyncBuilderImpl(CuratorFrameworkImpl) - Constructor for class org.apache.curator.framework.imps.SyncBuilderImpl
 
SyncBuilderImpl(CuratorFrameworkImpl, Backgrounding) - Constructor for class org.apache.curator.framework.imps.SyncBuilderImpl
 

T

take() - Method in class org.apache.curator.framework.recipes.queue.BlockingQueueConsumer
Take the next item from the queue, blocking until there is an item available
take(int, TimeUnit) - Method in class org.apache.curator.framework.recipes.queue.BlockingQueueConsumer
Take the next item from the queue, waiting up to the specified time for an available item.
take() - Method in class org.apache.curator.framework.recipes.queue.SimpleDistributedQueue
Removes the head of the queue and returns it, blocks until it succeeds.
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
takeLeadership(CuratorFramework) - Method in class leader.ExampleClient
 
takeLeadership(CuratorFramework) - Method in interface org.apache.curator.framework.recipes.leader.LeaderSelectorListener
Called when your instance has been granted leadership.
teardown() - Method in class org.apache.curator.test.BaseClassForTests
 
TempGetDataBuilder - Interface in org.apache.curator.framework.api
 
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
 
thisInstance(ServiceInstance<T>) - Method in class org.apache.curator.x.discovery.ServiceDiscoveryBuilder
Optional - instance that represents the service that is running.
threadFactory(ThreadFactory) - Method in class org.apache.curator.framework.CuratorFrameworkFactory.Builder
 
threadFactory(ThreadFactory) - Method in class org.apache.curator.framework.recipes.queue.QueueBuilder
Change the thread factory used.
threadFactory(ThreadFactory) - Method in class org.apache.curator.framework.recipes.queue.QueueSharderPolicies.Builder
Change the thread factory that's used to create the sharder's thread
threadFactory(ThreadFactory) - Method in interface org.apache.curator.x.discovery.ServiceCacheBuilder
Optional thread factory to use for the cache's internal thread.
threadFactory(ThreadFactory) - Method in interface org.apache.curator.x.discovery.ServiceProviderBuilder
optional - the thread factory to use for creating internal threads
ThreadUtils - Class in org.apache.curator.utils
 
ThreadUtils() - Constructor for class org.apache.curator.utils.ThreadUtils
 
thresholdCheckMs(int) - Method in class org.apache.curator.framework.recipes.queue.QueueSharderPolicies.Builder
Change the threshold check.
timeout(long, TimeUnit) - Method in class org.apache.curator.framework.recipes.atomic.PromotedToLock.Builder
Set the timeout to use when locking (optional)
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
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
 
toDocumentation() - Method in class org.apache.curator.framework.schema.Schema
 
toDocumentation() - Method in class org.apache.curator.framework.schema.SchemaSet
Build a user displayable documentation string for the schemas in this set
toReal() - Method in class org.apache.curator.x.rpc.idl.discovery.DiscoveryInstance
 
toRpcStat(Stat) - Static method in class org.apache.curator.x.rpc.idl.structs.RpcCuratorEvent
 
toSchemaSet(boolean) - Method in class org.apache.curator.framework.schema.SchemaSetLoader
 
toString() - Method in class org.apache.curator.framework.AuthInfo
 
toString() - Method in class org.apache.curator.framework.recipes.cache.ChildData
 
toString() - Method in class org.apache.curator.framework.recipes.cache.PathChildrenCacheEvent
 
toString() - Method in class org.apache.curator.framework.recipes.cache.TreeCacheEvent
 
toString() - Method in class org.apache.curator.framework.recipes.leader.Participant
 
toString() - Method in class org.apache.curator.framework.schema.Schema
 
toString() - Method in exception org.apache.curator.framework.schema.SchemaViolation
 
toString() - Method in class org.apache.curator.framework.schema.SchemaViolation.ViolatorData
 
toString() - Method in class org.apache.curator.test.InstanceSpec
 
toString() - Method in class org.apache.curator.x.async.details.AsyncResultImpl
 
toString() - Method in class org.apache.curator.x.discovery.ServiceInstance
 
TracerDriver - Interface in org.apache.curator.drivers
Mechanism for timing methods and recording counters
transaction(CuratorFramework) - Static method in class framework.TransactionExamples
 
transaction() - Method in interface org.apache.curator.framework.CuratorFramework
Start a transaction builder
transaction() - Method in class org.apache.curator.framework.imps.CuratorFrameworkImpl
 
transaction() - Method in interface org.apache.curator.x.async.api.AsyncCuratorFrameworkDsl
Start a transaction builder
transaction() - Method in class org.apache.curator.x.async.details.AsyncCuratorFrameworkImpl
 
TransactionCheckBuilder<T> - Interface in org.apache.curator.framework.api.transaction
 
TransactionCreateBuilder<T> - Interface in org.apache.curator.framework.api.transaction
 
TransactionDeleteBuilder<T> - Interface in org.apache.curator.framework.api.transaction
 
TransactionExamples - Class in framework
 
TransactionExamples() - Constructor for class framework.TransactionExamples
 
TransactionOp - Interface in org.apache.curator.framework.api.transaction
Builds operations that can be committed as a transaction via CuratorFramework.transaction()
transactionOp() - Method in interface org.apache.curator.framework.CuratorFramework
Allocate an operation that can be used with CuratorFramework.transaction().
transactionOp() - Method in class org.apache.curator.framework.imps.CuratorFrameworkImpl
 
transactionOp() - Method in interface org.apache.curator.x.async.api.AsyncCuratorFrameworkDsl
Allocate an operation that can be used with AsyncCuratorFrameworkDsl.transaction().
transactionOp() - Method in class org.apache.curator.x.async.details.AsyncCuratorFrameworkImpl
 
TransactionOpImpl - Class in org.apache.curator.framework.imps
 
TransactionOpImpl(CuratorFrameworkImpl) - Constructor for class org.apache.curator.framework.imps.TransactionOpImpl
 
TransactionSetDataBuilder<T> - Interface in org.apache.curator.framework.api.transaction
 
traverseChildren(String) - Method in class org.apache.curator.framework.recipes.cache.DefaultTreeCacheSelector
 
traverseChildren(String) - Method in interface org.apache.curator.framework.recipes.cache.TreeCacheSelector
Return true if children of this path should be cached.
TreeCache - Class in org.apache.curator.framework.recipes.cache
A utility that attempts to keep all data from all children of a ZK path locally cached.
TreeCache(CuratorFramework, String) - Constructor for class org.apache.curator.framework.recipes.cache.TreeCache
Create a TreeCache for the given client and path with default options.
TreeCache.Builder - Class in org.apache.curator.framework.recipes.cache
 
TreeCacheEvent - Class in org.apache.curator.framework.recipes.cache
POJO that abstracts a change to a path
TreeCacheEvent(TreeCacheEvent.Type, ChildData) - Constructor for class org.apache.curator.framework.recipes.cache.TreeCacheEvent
 
TreeCacheEvent.Type - Enum in org.apache.curator.framework.recipes.cache
Type of change
TreeCacheListener - Interface in org.apache.curator.framework.recipes.cache
Listener for TreeCache changes
TreeCacheSelector - Interface in org.apache.curator.framework.recipes.cache
Controls which nodes a TreeCache processes.
tryRemove(String) - Method in class org.apache.curator.framework.recipes.queue.DistributedQueue
 
trySet(Integer) - Method in class org.apache.curator.framework.recipes.atomic.DistributedAtomicInteger
 
trySet(Long) - Method in class org.apache.curator.framework.recipes.atomic.DistributedAtomicLong
 
trySet(T) - Method in interface org.apache.curator.framework.recipes.atomic.DistributedAtomicNumber
Attempt to atomically set the value to the given value.
trySet(byte[]) - Method in class org.apache.curator.framework.recipes.atomic.DistributedAtomicValue
Attempt to atomically set the value to the given value.
trySetCount(int) - Method in class org.apache.curator.framework.recipes.shared.SharedCount
Deprecated.
use SharedCount.trySetCount(VersionedValue, int) for stronger atomicity guarantees. Even if this object's internal state is up-to-date, the caller has no way to ensure that they've read the most recently seen count.
trySetCount(VersionedValue<Integer>, int) - Method in class org.apache.curator.framework.recipes.shared.SharedCount
Changes the shared count only if its value has not changed since the version specified by newCount.
trySetValue(byte[]) - Method in class org.apache.curator.framework.recipes.shared.SharedValue
Deprecated.
use SharedValue.trySetValue(VersionedValue, byte[]) for stronger atomicity guarantees. Even if this object's internal state is up-to-date, the caller has no way to ensure that they've read the most recently seen value.
trySetValue(VersionedValue<byte[]>, byte[]) - Method in class org.apache.curator.framework.recipes.shared.SharedValue
Changes the shared value only if its value has not changed since the version specified by newValue.
type - Variable in exception org.apache.curator.x.rpc.idl.exceptions.RpcException
 
type - Variable in class org.apache.curator.x.rpc.idl.structs.RpcCuratorEvent
 
type - Variable in class org.apache.curator.x.rpc.idl.structs.RpcPathChildrenCacheEvent
 
TypeAndPath - Class in org.apache.curator.framework.api.transaction
 
TypeAndPath(OperationType, String) - Constructor for class org.apache.curator.framework.api.transaction.TypeAndPath
 

U

unhandledError(String, Throwable) - Method in interface org.apache.curator.framework.api.UnhandledErrorListener
Called when an exception is caught in a background thread, handler, etc.
UnhandledErrorListener - Interface in org.apache.curator.framework.api
 
unMarshallJson(JsonNode) - Method in class org.apache.curator.x.discovery.server.contexts.GenericDiscoveryContext
 
unMarshallJson(JsonNode) - Method in class org.apache.curator.x.discovery.server.contexts.IntegerDiscoveryContext
 
unMarshallJson(JsonNode) - Method in class org.apache.curator.x.discovery.server.contexts.StringDiscoveryContext
 
unMarshallJson(JsonNode) - Method in interface org.apache.curator.x.discovery.server.rest.DiscoveryContext
Deserialize your payload
unregisterInstance(CuratorProjection, DiscoveryProjection, DiscoveryInstance) - Method in class org.apache.curator.x.rpc.idl.discovery.DiscoveryServiceLowLevel
 
unregisterJMX() - Method in class org.apache.curator.test.TestingZooKeeperMain.TestZooKeeperServer
 
unregisterService(ServiceInstance<T>) - Method in class org.apache.curator.x.discovery.details.ServiceDiscoveryImpl
Unregister/remove a service instance
unregisterService(ServiceInstance<T>) - Method in interface org.apache.curator.x.discovery.ServiceDiscovery
Unregister/remove a service instance
unwrap() - Method in interface org.apache.curator.x.async.AsyncCuratorFramework
Returns the client that was originally passed to AsyncCuratorFramework.wrap(org.apache.curator.framework.CuratorFramework)
unwrap() - Method in class org.apache.curator.x.async.details.AsyncCuratorFrameworkImpl
 
updateInstance(CuratorProjection, DiscoveryProjection, DiscoveryInstance) - Method in class org.apache.curator.x.rpc.idl.discovery.DiscoveryServiceLowLevel
 
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.exhibitor.ExhibitorEnsembleProvider
 
updateServerListEnabled() - Method in class org.apache.curator.ensemble.fixed.FixedEnsembleProvider
 
updateService(ServiceInstance<T>) - Method in class org.apache.curator.x.discovery.details.ServiceDiscoveryImpl
 
updateService(ServiceInstance<T>) - Method in interface org.apache.curator.x.discovery.ServiceDiscovery
Update a service
uriSpec(UriSpec) - Method in class org.apache.curator.x.discovery.ServiceInstanceBuilder
 
UriSpec - Class in org.apache.curator.x.discovery
An abstraction for specifying a URI for an instance allowing for variable substitutions.
UriSpec() - Constructor for class org.apache.curator.x.discovery.UriSpec
 
UriSpec(String) - Constructor for class org.apache.curator.x.discovery.UriSpec
 
uriSpec - Variable in class org.apache.curator.x.rpc.idl.discovery.DiscoveryInstance
 
UriSpec.Part - Class in org.apache.curator.x.discovery
Represents one token in the Uri spec
use() - Method in class locking.FakeLimitedResource
 
use(NetworkInterface, InetAddress) - Method in interface org.apache.curator.x.discovery.LocalIpFilter
 
useContainerParentsIfAvailable() - Method in class org.apache.curator.framework.CuratorFrameworkFactory.Builder
 
usingDataCallback(AsyncCallback.DataCallback, Object) - Method in interface org.apache.curator.framework.api.DataCallbackable
Passes a callback and a context object to the config/reconfig command.
usingNamespace(String) - Method in interface org.apache.curator.framework.CuratorFramework
Returns a facade of the current instance that uses the specified namespace or no namespace if newNamespace is null.
usingNamespace(String) - Method in class org.apache.curator.framework.imps.CuratorFrameworkImpl
 
usingWatcher(Watcher) - Method in interface org.apache.curator.framework.api.Watchable
Set a watcher for the operation
usingWatcher(CuratorWatcher) - Method in interface org.apache.curator.framework.api.Watchable
Set a watcher for the operation
usingWatcher(Watcher) - Method in class org.apache.curator.framework.imps.ExistsBuilderImpl
 
usingWatcher(CuratorWatcher) - Method in class org.apache.curator.framework.imps.ExistsBuilderImpl
 
usingWatcher(Watcher) - Method in class org.apache.curator.framework.imps.GetChildrenBuilderImpl
 
usingWatcher(CuratorWatcher) - Method in class org.apache.curator.framework.imps.GetChildrenBuilderImpl
 
usingWatcher(Watcher) - Method in class org.apache.curator.framework.imps.GetConfigBuilderImpl
 
usingWatcher(CuratorWatcher) - Method in class org.apache.curator.framework.imps.GetConfigBuilderImpl
 
usingWatcher(Watcher) - Method in class org.apache.curator.framework.imps.GetDataBuilderImpl
 
usingWatcher(CuratorWatcher) - Method in class org.apache.curator.framework.imps.GetDataBuilderImpl
 

V

validateCreate(CreateMode, String, byte[], List<ACL>) - Method in class org.apache.curator.framework.schema.Schema
Validate that this schema's create mode setting matches and that the data is valid
validateDelete(String) - Method in class org.apache.curator.framework.schema.Schema
Validate that this schema allows znode deletion
validateGeneral(String, byte[], List<ACL>) - Method in class org.apache.curator.framework.schema.Schema
Validate that this schema validates the data
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
validateWatch(String, boolean) - Method in class org.apache.curator.framework.schema.Schema
Validate that this schema's watching setting matches
valueHasChanged(SharedValueReader, byte[]) - Method in interface org.apache.curator.framework.recipes.shared.SharedValueListener
Called when the shared value has changed
valueOf(String) - Static method in enum org.apache.curator.connection.ConnectionHandlingPolicy.CheckTimeoutsResult
Returns the enum constant of this type with the specified name.
valueOf(String) - Static method in enum org.apache.curator.framework.api.CuratorEventType
Returns the enum constant of this type with the specified name.
valueOf(String) - Static method in enum org.apache.curator.framework.api.transaction.OperationType
Returns the enum constant of this type with the specified name.
valueOf(String) - Static method in enum org.apache.curator.framework.imps.CuratorFrameworkState
Returns the enum constant of this type with the specified name.
valueOf(String) - Static method in enum org.apache.curator.framework.recipes.cache.PathChildrenCache.StartMode
Returns the enum constant of this type with the specified name.
valueOf(String) - Static method in enum org.apache.curator.framework.recipes.cache.PathChildrenCacheEvent.Type
Returns the enum constant of this type with the specified name.
valueOf(String) - Static method in enum org.apache.curator.framework.recipes.cache.PathChildrenCacheMode
Deprecated.
Returns the enum constant of this type with the specified name.
valueOf(String) - Static method in enum org.apache.curator.framework.recipes.cache.TreeCacheEvent.Type
Returns the enum constant of this type with the specified name.
valueOf(String) - Static method in enum org.apache.curator.framework.recipes.leader.LeaderLatch.CloseMode
Returns the enum constant of this type with the specified name.
valueOf(String) - Static method in enum org.apache.curator.framework.recipes.leader.LeaderLatch.State
Returns the enum constant of this type with the specified name.
valueOf(String) - Static method in enum org.apache.curator.framework.recipes.locks.Reaper.Mode
Deprecated.
Returns the enum constant of this type with the specified name.
valueOf(String) - Static method in enum org.apache.curator.framework.recipes.nodes.PersistentEphemeralNode.Mode
Deprecated.
Returns the enum constant of this type with the specified name.
valueOf(String) - Static method in enum org.apache.curator.framework.recipes.queue.DistributedQueue.ProcessType
Returns the enum constant of this type with the specified name.
valueOf(String) - Static method in enum org.apache.curator.framework.recipes.queue.ErrorMode
Returns the enum constant of this type with the specified name.
valueOf(String) - Static method in enum org.apache.curator.framework.schema.Schema.Allowance
Returns the enum constant of this type with the specified name.
valueOf(String) - Static method in enum org.apache.curator.framework.state.ConnectionState
Returns the enum constant of this type with the specified name.
valueOf(String) - Static method in enum org.apache.curator.SessionFailRetryLoop.Mode
Returns the enum constant of this type with the specified name.
valueOf(String) - Static method in enum org.apache.curator.x.async.api.CreateOption
Returns the enum constant of this type with the specified name.
valueOf(String) - Static method in enum org.apache.curator.x.async.api.DeleteOption
Returns the enum constant of this type with the specified name.
valueOf(String) - Static method in enum org.apache.curator.x.async.api.ExistsOption
Returns the enum constant of this type with the specified name.
valueOf(String) - Static method in enum org.apache.curator.x.async.api.RemoveWatcherOption
Returns the enum constant of this type with the specified name.
valueOf(String) - Static method in enum org.apache.curator.x.async.WatchMode
Returns the enum constant of this type with the specified name.
valueOf(String) - Static method in enum org.apache.curator.x.discovery.ServiceType
Returns the enum constant of this type with the specified name.
valueOf(String) - Static method in enum org.apache.curator.x.rpc.idl.discovery.DiscoveryInstanceType
Returns the enum constant of this type with the specified name.
valueOf(String) - Static method in enum org.apache.curator.x.rpc.idl.discovery.ProviderStrategyType
Returns the enum constant of this type with the specified name.
valueOf(String) - Static method in enum org.apache.curator.x.rpc.idl.exceptions.ExceptionType
Returns the enum constant of this type with the specified name.
valueOf(String) - Static method in enum org.apache.curator.x.rpc.idl.exceptions.NodeExceptionType
Returns the enum constant of this type with the specified name.
valueOf(String) - Static method in enum org.apache.curator.x.rpc.idl.exceptions.ZooKeeperExceptionType
Returns the enum constant of this type with the specified name.
valueOf(String) - Static method in enum org.apache.curator.x.rpc.idl.structs.PathChildrenCacheStartMode
Returns the enum constant of this type with the specified name.
valueOf(String) - Static method in enum org.apache.curator.x.rpc.idl.structs.RpcCreateMode
Returns the enum constant of this type with the specified name.
valueOf(String) - Static method in enum org.apache.curator.x.rpc.idl.structs.RpcCuratorEventType
Returns the enum constant of this type with the specified name.
valueOf(String) - Static method in enum org.apache.curator.x.rpc.idl.structs.RpcEventType
Returns the enum constant of this type with the specified name.
valueOf(String) - Static method in enum org.apache.curator.x.rpc.idl.structs.RpcKeeperState
Returns the enum constant of this type with the specified name.
valueOf(String) - Static method in enum org.apache.curator.x.rpc.idl.structs.RpcPathChildrenCacheEventType
Returns the enum constant of this type with the specified name.
valueOf(String) - Static method in enum org.apache.curator.x.rpc.idl.structs.RpcPersistentEphemeralNodeMode
Returns the enum constant of this type with the specified name.
values() - Static method in enum org.apache.curator.connection.ConnectionHandlingPolicy.CheckTimeoutsResult
Returns an array containing the constants of this enum type, in the order they are declared.
values() - Static method in enum org.apache.curator.framework.api.CuratorEventType
Returns an array containing the constants of this enum type, in the order they are declared.
values() - Static method in enum org.apache.curator.framework.api.transaction.OperationType
Returns an array containing the constants of this enum type, in the order they are declared.
values() - Static method in enum org.apache.curator.framework.imps.CuratorFrameworkState
Returns an array containing the constants of this enum type, in the order they are declared.
values() - Static method in enum org.apache.curator.framework.recipes.cache.PathChildrenCache.StartMode
Returns an array containing the constants of this enum type, in the order they are declared.
values() - Static method in enum org.apache.curator.framework.recipes.cache.PathChildrenCacheEvent.Type
Returns an array containing the constants of this enum type, in the order they are declared.
values() - Static method in enum org.apache.curator.framework.recipes.cache.PathChildrenCacheMode
Deprecated.
Returns an array containing the constants of this enum type, in the order they are declared.
values() - Static method in enum org.apache.curator.framework.recipes.cache.TreeCacheEvent.Type
Returns an array containing the constants of this enum type, in the order they are declared.
values() - Static method in enum org.apache.curator.framework.recipes.leader.LeaderLatch.CloseMode
Returns an array containing the constants of this enum type, in the order they are declared.
values() - Static method in enum org.apache.curator.framework.recipes.leader.LeaderLatch.State
Returns an array containing the constants of this enum type, in the order they are declared.
values() - Static method in enum org.apache.curator.framework.recipes.locks.Reaper.Mode
Deprecated.
Returns an array containing the constants of this enum type, in the order they are declared.
values() - Static method in enum org.apache.curator.framework.recipes.nodes.PersistentEphemeralNode.Mode
Deprecated.
Returns an array containing the constants of this enum type, in the order they are declared.
values() - Static method in enum org.apache.curator.framework.recipes.queue.DistributedQueue.ProcessType
Returns an array containing the constants of this enum type, in the order they are declared.
values() - Static method in enum org.apache.curator.framework.recipes.queue.ErrorMode
Returns an array containing the constants of this enum type, in the order they are declared.
values() - Static method in enum org.apache.curator.framework.schema.Schema.Allowance
Returns an array containing the constants of this enum type, in the order they are declared.
values() - Static method in enum org.apache.curator.framework.state.ConnectionState
Returns an array containing the constants of this enum type, in the order they are declared.
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.
values() - Static method in enum org.apache.curator.x.async.api.CreateOption
Returns an array containing the constants of this enum type, in the order they are declared.
values() - Static method in enum org.apache.curator.x.async.api.DeleteOption
Returns an array containing the constants of this enum type, in the order they are declared.
values() - Static method in enum org.apache.curator.x.async.api.ExistsOption
Returns an array containing the constants of this enum type, in the order they are declared.
values() - Static method in enum org.apache.curator.x.async.api.RemoveWatcherOption
Returns an array containing the constants of this enum type, in the order they are declared.
values() - Static method in enum org.apache.curator.x.async.WatchMode
Returns an array containing the constants of this enum type, in the order they are declared.
values() - Static method in enum org.apache.curator.x.discovery.ServiceType
Returns an array containing the constants of this enum type, in the order they are declared.
values() - Static method in enum org.apache.curator.x.rpc.idl.discovery.DiscoveryInstanceType
Returns an array containing the constants of this enum type, in the order they are declared.
values() - Static method in enum org.apache.curator.x.rpc.idl.discovery.ProviderStrategyType
Returns an array containing the constants of this enum type, in the order they are declared.
values() - Static method in enum org.apache.curator.x.rpc.idl.exceptions.ExceptionType
Returns an array containing the constants of this enum type, in the order they are declared.
values() - Static method in enum org.apache.curator.x.rpc.idl.exceptions.NodeExceptionType
Returns an array containing the constants of this enum type, in the order they are declared.
values() - Static method in enum org.apache.curator.x.rpc.idl.exceptions.ZooKeeperExceptionType
Returns an array containing the constants of this enum type, in the order they are declared.
values() - Static method in enum org.apache.curator.x.rpc.idl.structs.PathChildrenCacheStartMode
Returns an array containing the constants of this enum type, in the order they are declared.
values() - Static method in enum org.apache.curator.x.rpc.idl.structs.RpcCreateMode
Returns an array containing the constants of this enum type, in the order they are declared.
values() - Static method in enum org.apache.curator.x.rpc.idl.structs.RpcCuratorEventType
Returns an array containing the constants of this enum type, in the order they are declared.
values() - Static method in enum org.apache.curator.x.rpc.idl.structs.RpcEventType
Returns an array containing the constants of this enum type, in the order they are declared.
values() - Static method in enum org.apache.curator.x.rpc.idl.structs.RpcKeeperState
Returns an array containing the constants of this enum type, in the order they are declared.
values() - Static method in enum org.apache.curator.x.rpc.idl.structs.RpcPathChildrenCacheEventType
Returns an array containing the constants of this enum type, in the order they are declared.
values() - Static method in enum org.apache.curator.x.rpc.idl.structs.RpcPersistentEphemeralNodeMode
Returns an array containing the constants of this enum type, in the order they are declared.
version - Variable in class org.apache.curator.x.rpc.idl.structs.DeleteSpec
 
version - Variable in class org.apache.curator.x.rpc.idl.structs.RpcStat
 
version - Variable in class org.apache.curator.x.rpc.idl.structs.SetDataSpec
 
Version - Class in org.apache.curator.x.rpc.idl.structs
 
Version() - Constructor for class org.apache.curator.x.rpc.idl.structs.Version
 
Version(int) - Constructor for class org.apache.curator.x.rpc.idl.structs.Version
 
version - Variable in class org.apache.curator.x.rpc.idl.structs.Version
 
Versionable<T> - Interface in org.apache.curator.framework.api
 
VersionedValue<T> - Class in org.apache.curator.framework.recipes.shared
POJO for a version and a value
VersionPathAndBytesable<T> - Interface in org.apache.curator.framework.api
 
ViolatorData(String, byte[], List<ACL>) - Constructor for class org.apache.curator.framework.schema.SchemaViolation.ViolatorData
 

W

waitForInitialCreate(long, TimeUnit) - Method in class org.apache.curator.framework.recipes.nodes.PersistentNode
Block until the either initial node creation initiated by PersistentNode.start() succeeds or the timeout elapses.
waitOnBarrier() - Method in class org.apache.curator.framework.recipes.barriers.DistributedBarrier
Blocks until the barrier node comes into existence
waitOnBarrier(long, TimeUnit) - Method in class org.apache.curator.framework.recipes.barriers.DistributedBarrier
Blocks until the barrier no longer exists or the timeout elapses
warnMaxChildren(String, Stat) - Method in class org.apache.curator.framework.recipes.locks.ChildReaper
Deprecated.
 
Watchable<T> - Interface in org.apache.curator.framework.api
 
WatchableAsyncCuratorFramework - Interface in org.apache.curator.x.async.api
operations that support watching
WatchBackgroundEnsembleable<T> - Interface in org.apache.curator.framework.api
 
watched() - Method in interface org.apache.curator.framework.api.Watchable
Have the operation set a watch
watched() - Method in class org.apache.curator.framework.imps.ExistsBuilderImpl
 
watched() - Method in class org.apache.curator.framework.imps.GetChildrenBuilderImpl
 
watched() - Method in class org.apache.curator.framework.imps.GetConfigBuilderImpl
 
watched() - Method in class org.apache.curator.framework.imps.GetDataBuilderImpl
 
watched(Schema.Allowance) - Method in class org.apache.curator.framework.schema.SchemaBuilder
 
watched() - Method in interface org.apache.curator.x.async.api.AsyncCuratorFrameworkDsl
Returns a facade that adds watching to any of the subsequently created builders.
watched() - Method in class org.apache.curator.x.async.details.AsyncCuratorFrameworkImpl
 
watched - Variable in class org.apache.curator.x.rpc.idl.structs.ExistsSpec
 
watched - Variable in class org.apache.curator.x.rpc.idl.structs.GetChildrenSpec
 
watched - Variable in class org.apache.curator.x.rpc.idl.structs.GetDataSpec
 
watched - Variable in class org.apache.curator.x.rpc.idl.structs.SetDataSpec
 
watchedEvent - Variable in class org.apache.curator.x.rpc.idl.structs.RpcCuratorEvent
 
watchedGetChildren(CuratorFramework, String) - Static method in class framework.