- ACLable<T> - Interface in com.netflix.curator.framework.api
-
- ACLBackgroundPathable<T> - Interface in com.netflix.curator.framework.api
-
- ACLBackgroundPathAndBytesable<T> - Interface in com.netflix.curator.framework.api
-
- ACLCreateModeBackgroundPathAndBytesable<T> - Interface in com.netflix.curator.framework.api
-
- ACLCreateModePathAndBytesable<T> - Interface in com.netflix.curator.framework.api
-
- ACLPathAndBytesable<T> - Interface in com.netflix.curator.framework.api
-
- ACLProvider - Interface in com.netflix.curator.framework.api
-
- aclProvider(ACLProvider) - Method in class com.netflix.curator.framework.CuratorFrameworkFactory.Builder
-
- ACLVersionBackgroundPathable<T> - Interface in com.netflix.curator.framework.api
-
- acquire() - Method in interface com.netflix.curator.framework.recipes.locks.InterProcessLock
-
Acquire the mutex - blocking until it's available.
- acquire(long, TimeUnit) - Method in interface com.netflix.curator.framework.recipes.locks.InterProcessLock
-
Acquire the mutex - blocks until it's available or the given time expires.
- acquire() - Method in class com.netflix.curator.framework.recipes.locks.InterProcessMultiLock
-
Acquire the mutex - blocking until it's available.
- acquire(long, TimeUnit) - Method in class com.netflix.curator.framework.recipes.locks.InterProcessMultiLock
-
Acquire the mutex - blocks until it's available or the given time expires.
- acquire() - Method in class com.netflix.curator.framework.recipes.locks.InterProcessMutex
-
Acquire the mutex - blocking until it's available.
- acquire(long, TimeUnit) - Method in class com.netflix.curator.framework.recipes.locks.InterProcessMutex
-
Acquire the mutex - blocks until it's available or the given time expires.
- acquire() - Method in class com.netflix.curator.framework.recipes.locks.InterProcessSemaphore
-
Deprecated.
Acquire a lease.
- acquire(int) - Method in class com.netflix.curator.framework.recipes.locks.InterProcessSemaphore
-
Deprecated.
Acquire qty
leases.
- acquire(long, TimeUnit) - Method in class com.netflix.curator.framework.recipes.locks.InterProcessSemaphore
-
Deprecated.
Acquire a lease.
- acquire(int, long, TimeUnit) - Method in class com.netflix.curator.framework.recipes.locks.InterProcessSemaphore
-
Deprecated.
Acquire qty
leases.
- acquire() - Method in class com.netflix.curator.framework.recipes.locks.InterProcessSemaphoreMutex
-
- acquire(long, TimeUnit) - Method in class com.netflix.curator.framework.recipes.locks.InterProcessSemaphoreMutex
-
- acquire() - Method in class com.netflix.curator.framework.recipes.locks.InterProcessSemaphoreV2
-
Acquire a lease.
- acquire(int) - Method in class com.netflix.curator.framework.recipes.locks.InterProcessSemaphoreV2
-
Acquire qty
leases.
- acquire(long, TimeUnit) - Method in class com.netflix.curator.framework.recipes.locks.InterProcessSemaphoreV2
-
Acquire a lease.
- acquire(int, long, TimeUnit) - Method in class com.netflix.curator.framework.recipes.locks.InterProcessSemaphoreV2
-
Acquire qty
leases.
- acquireSemaphore(Semaphore) - Method in class com.netflix.curator.test.Timing
-
Wait on the given semaphore
- acquireSemaphore(Semaphore, int) - Method in class com.netflix.curator.test.Timing
-
Wait on the given semaphore
- add(Integer) - Method in class com.netflix.curator.framework.recipes.atomic.DistributedAtomicInteger
-
Add delta to the current value and return the new value information.
- add(Long) - Method in class com.netflix.curator.framework.recipes.atomic.DistributedAtomicLong
-
Add delta to the current value and return the new value information.
- add(T) - Method in interface com.netflix.curator.framework.recipes.atomic.DistributedAtomicNumber
-
Add delta to the current value and return the new value information.
- add(UriSpec.Part) - Method in class com.netflix.curator.x.discovery.UriSpec
-
Add a part to the end of the list
- addCount(String, int) - Method in interface com.netflix.curator.drivers.TracerDriver
-
Add to a named counter
- addCount(String, int) - Method in class com.netflix.curator.utils.DefaultTracerDriver
-
- addListener(T) - Method in interface com.netflix.curator.framework.listen.Listenable
-
Add the given listener.
- addListener(T, Executor) - Method in interface com.netflix.curator.framework.listen.Listenable
-
Add the given listener.
- addListener(T) - Method in class com.netflix.curator.framework.listen.ListenerContainer
-
- addListener(T, Executor) - Method in class com.netflix.curator.framework.listen.ListenerContainer
-
- addListener(SharedCountListener) - Method in class com.netflix.curator.framework.recipes.shared.SharedCount
-
- addListener(SharedCountListener, Executor) - Method in class com.netflix.curator.framework.recipes.shared.SharedCount
-
- addListener(ServiceCacheListener) - Method in class com.netflix.curator.x.discovery.details.ServiceCacheImpl
-
- addListener(ServiceCacheListener, Executor) - Method in class com.netflix.curator.x.discovery.details.ServiceCacheImpl
-
- addPath(String) - Method in class com.netflix.curator.framework.recipes.locks.Reaper
-
Add a path (using Mode.REAP_INDEFINITELY) to be checked by the reaper.
- addPath(String, Reaper.Mode) - Method in class com.netflix.curator.framework.recipes.locks.Reaper
-
Add a path to be checked by the reaper.
- address(String) - Method in class com.netflix.curator.x.discovery.ServiceInstanceBuilder
-
- addStateChange(ConnectionState) - Method in class com.netflix.curator.framework.state.ConnectionStateManager
-
Post a state change.
- addTrace(String, long, TimeUnit) - Method in interface com.netflix.curator.drivers.TracerDriver
-
Record the given trace event
- addTrace(String, long, TimeUnit) - Method in class com.netflix.curator.utils.DefaultTracerDriver
-
- allocateQueue(CuratorFramework, String) - Method in interface com.netflix.curator.framework.recipes.queue.QueueAllocator
-
- allowRetry(int, long, RetrySleeper) - Method in class com.netflix.curator.retry.RetryUntilElapsed
-
- allowRetry(int, long, RetrySleeper) - Method in interface com.netflix.curator.RetryPolicy
-
Called when an operation has failed for some reason.
- and() - Method in interface com.netflix.curator.framework.api.transaction.CuratorTransactionBridge
-
Syntactic sugar to make the fluent interface more readable
- apply() - Static method in class com.netflix.curator.test.ByteCodeRewrite
-
- AtomicStats - Class in com.netflix.curator.framework.recipes.atomic
-
Debugging stats about operations
- AtomicStats() - Constructor for class com.netflix.curator.framework.recipes.atomic.AtomicStats
-
- AtomicValue<T> - Interface in com.netflix.curator.framework.recipes.atomic
-
Abstracts a value returned from one of the Atomics
- attemptRevoke(CuratorFramework, String) - Static method in class com.netflix.curator.framework.recipes.locks.Revoker
-
Utility to mark a lock for revocation.
- authorization(String, byte[]) - Method in class com.netflix.curator.framework.CuratorFrameworkFactory.Builder
-
Add connection authorization
- autoRequeue() - Method in class com.netflix.curator.framework.recipes.leader.LeaderSelector
-
- await() - Method in class com.netflix.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 com.netflix.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 com.netflix.curator.test.Timing
-
Wait on the given latch
- Backgroundable<T> - Interface in com.netflix.curator.framework.api
-
- BackgroundCallback - Interface in com.netflix.curator.framework.api
-
Functor for an async background operation
- BackgroundPathable<T> - Interface in com.netflix.curator.framework.api
-
- BackgroundPathAndBytesable<T> - Interface in com.netflix.curator.framework.api
-
- basePath(String) - Method in class com.netflix.curator.x.discovery.ServiceDiscoveryBuilder
-
Required - set the base path to store in ZK
- BlockingQueueConsumer<T> - Class in com.netflix.curator.framework.recipes.queue
-
Utility - a queue consumer that provides behavior similar to a BlockingQueue
- BlockingQueueConsumer(ConnectionStateListener) - Constructor for class com.netflix.curator.framework.recipes.queue.BlockingQueueConsumer
-
Creates with capacity of Integer.MAX_VALUE
- BlockingQueueConsumer(ConnectionStateListener, int) - Constructor for class com.netflix.curator.framework.recipes.queue.BlockingQueueConsumer
-
- BlockingQueueConsumer(ConnectionStateListener, BlockingQueue<T>) - Constructor for class com.netflix.curator.framework.recipes.queue.BlockingQueueConsumer
-
Wrap the given blocking queue
- blockUntilConnectedOrTimedOut() - Method in class com.netflix.curator.CuratorZookeeperClient
-
This method blocks until the connection to ZK succeeds.
- blockUntilStarted() - Method in class com.netflix.curator.test.TestingZooKeeperMain
-
- blockUntilStarted() - Method in interface com.netflix.curator.test.ZooKeeperMainFace
-
- BoundedExponentialBackoffRetry - Class in com.netflix.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 com.netflix.curator.retry.BoundedExponentialBackoffRetry
-
- build() - Method in class com.netflix.curator.framework.CuratorFrameworkFactory.Builder
-
Apply the current values and build a new CuratorFramework
- build() - Method in class com.netflix.curator.framework.recipes.atomic.PromotedToLock.Builder
-
Build the argument block
- build() - Method in class com.netflix.curator.framework.recipes.queue.QueueSharderPolicies.Builder
-
- build() - Method in interface com.netflix.curator.x.discovery.ServiceCacheBuilder
-
Return a new service cache with the current settings
- build() - Method in class com.netflix.curator.x.discovery.ServiceDiscoveryBuilder
-
Build a new service discovery with the currently set values
- build() - Method in class com.netflix.curator.x.discovery.ServiceInstanceBuilder
-
Return a new instance with the currently set values
- build() - Method in interface com.netflix.curator.x.discovery.ServiceProviderBuilder
-
Allocate a new service provider based on the current builder settings
- build() - Method in class com.netflix.curator.x.discovery.UriSpec
-
Build into a UriSpec string
- build(ServiceInstance<?>) - Method in class com.netflix.curator.x.discovery.UriSpec
-
Build into a UriSpec string
- build(Map<String, Object>) - Method in class com.netflix.curator.x.discovery.UriSpec
-
Build into a UriSpec string
- build(ServiceInstance<?>, Map<String, Object>) - Method in class com.netflix.curator.x.discovery.UriSpec
-
Build into a UriSpec string
- buildConfig() - Method in class com.netflix.curator.test.QuorumConfigBuilder
-
- buildConfig(int) - Method in class com.netflix.curator.test.QuorumConfigBuilder
-
- buildDelayQueue() - Method in class com.netflix.curator.framework.recipes.queue.QueueBuilder
-
- builder() - Static method in class com.netflix.curator.framework.CuratorFrameworkFactory
-
Return a new builder that builds a CuratorFramework
- builder() - Static method in class com.netflix.curator.framework.recipes.atomic.PromotedToLock
-
Allocate a new builder
- builder(CuratorFramework, QueueConsumer<T>, QueueSerializer<T>, String) - Static method in class com.netflix.curator.framework.recipes.queue.QueueBuilder
-
Allocate a new builder
- builder() - Static method in class com.netflix.curator.framework.recipes.queue.QueueSharderPolicies
-
Allocate a new builder
- builder(Class<T>) - Static method in class com.netflix.curator.x.discovery.ServiceDiscoveryBuilder
-
Return a new builder.
- builder() - Static method in class com.netflix.curator.x.discovery.ServiceInstance
-
Return a new builder.
- buildIdQueue() - Method in class com.netflix.curator.framework.recipes.queue.QueueBuilder
-
- buildPriorityQueue(int) - Method in class com.netflix.curator.framework.recipes.queue.QueueBuilder
-
- buildQueue() - Method in class com.netflix.curator.framework.recipes.queue.QueueBuilder
-
- buildUriSpec() - Method in class com.netflix.curator.x.discovery.ServiceInstance
-
- buildUriSpec(Map<String, Object>) - Method in class com.netflix.curator.x.discovery.ServiceInstance
-
- ByteCodeRewrite - Class in com.netflix.curator.test
-
- ByteCodeRewrite() - Constructor for class com.netflix.curator.test.ByteCodeRewrite
-
- cache - package cache
-
- cacheChanged() - Method in interface com.netflix.curator.x.discovery.details.ServiceCacheListener
-
Called when the cache has changed (instances added/deleted, etc.)
- CachedAtomicInteger - Class in com.netflix.curator.framework.recipes.atomic
-
- CachedAtomicInteger(DistributedAtomicInteger, int) - Constructor for class com.netflix.curator.framework.recipes.atomic.CachedAtomicInteger
-
- CachedAtomicLong - Class in com.netflix.curator.framework.recipes.atomic
-
- CachedAtomicLong(DistributedAtomicLong, int) - Constructor for class com.netflix.curator.framework.recipes.atomic.CachedAtomicLong
-
- callWithRetry(CuratorZookeeperClient, Callable<T>) - Static method in class com.netflix.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 com.netflix.curator.SessionFailRetryLoop
-
Convenience utility: creates a "session fail" retry loop calling the given proc
- check() - Method in interface com.netflix.curator.framework.api.transaction.CuratorTransaction
-
Start a check builder in the transaction
- checkExists() - Method in interface com.netflix.curator.framework.CuratorFramework
-
Start an exists builder
- checkExists() - Method in class com.netflix.curator.framework.imps.CuratorFrameworkImpl
-
- ChildData - Class in com.netflix.curator.framework.recipes.cache
-
- childEvent(CuratorFramework, PathChildrenCacheEvent) - Method in interface com.netflix.curator.framework.recipes.cache.PathChildrenCacheListener
-
Called when a change has occurred
- ChildReaper - Class in com.netflix.curator.framework.recipes.locks
-
Utility to reap empty child nodes of a parent node.
- ChildReaper(CuratorFramework, String, Reaper.Mode) - Constructor for class com.netflix.curator.framework.recipes.locks.ChildReaper
-
- ChildReaper(CuratorFramework, String, Reaper.Mode, int) - Constructor for class com.netflix.curator.framework.recipes.locks.ChildReaper
-
- ChildReaper(CuratorFramework, String, Reaper.Mode, ScheduledExecutorService, int) - Constructor for class com.netflix.curator.framework.recipes.locks.ChildReaper
-
- clean() - Method in class com.netflix.curator.framework.recipes.locks.LockInternals
-
Attempt to delete the lock node so that sequence numbers get reset
- clear() - Method in class com.netflix.curator.framework.listen.ListenerContainer
-
Remove all listeners
- clear() - Method in class com.netflix.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 com.netflix.curator.framework.recipes.cache.PathChildrenCache
-
Clear out current data and begin a new query on the path
- client(CuratorFramework) - Method in class com.netflix.curator.x.discovery.ServiceDiscoveryBuilder
-
Required - set the client to use
- close() - Method in class com.netflix.curator.CuratorZookeeperClient
-
Close the client
- close() - Method in interface com.netflix.curator.ensemble.EnsembleProvider
-
- close() - Method in class com.netflix.curator.ensemble.exhibitor.ExhibitorEnsembleProvider
-
- close() - Method in class com.netflix.curator.ensemble.fixed.FixedEnsembleProvider
-
- close() - Method in interface com.netflix.curator.framework.CuratorFramework
-
Stop the client
- close() - Method in class com.netflix.curator.framework.imps.CuratorFrameworkImpl
-
- close() - Method in class com.netflix.curator.framework.recipes.cache.PathChildrenCache
-
Close/end the cache
- close() - Method in class com.netflix.curator.framework.recipes.leader.LeaderLatch
-
Remove this instance from the leadership election.
- close() - Method in class com.netflix.curator.framework.recipes.leader.LeaderSelector
-
Shutdown this selector and remove yourself from the leadership group
- close() - Method in class com.netflix.curator.framework.recipes.locks.ChildReaper
-
- close() - Method in interface com.netflix.curator.framework.recipes.locks.Lease
-
Releases the lease so that other clients/processes can acquire it
- close() - Method in class com.netflix.curator.framework.recipes.locks.Reaper
-
- close() - Method in class com.netflix.curator.framework.recipes.queue.DistributedDelayQueue
-
- close() - Method in class com.netflix.curator.framework.recipes.queue.DistributedIdQueue
-
- close() - Method in class com.netflix.curator.framework.recipes.queue.DistributedPriorityQueue
-
- close() - Method in class com.netflix.curator.framework.recipes.queue.DistributedQueue
-
- close() - Method in class com.netflix.curator.framework.recipes.queue.QueueSharder
-
- close() - Method in class com.netflix.curator.framework.recipes.shared.SharedCount
-
- close() - Method in class com.netflix.curator.framework.recipes.shared.SharedValue
-
- close() - Method in class com.netflix.curator.framework.state.ConnectionStateManager
-
- close() - Method in class com.netflix.curator.SessionFailRetryLoop
-
Must be called in a finally handler when done with the loop
- close() - Method in class com.netflix.curator.test.TestingCluster
-
Shutdown the ensemble, free resources, etc.
- close() - Method in class com.netflix.curator.test.TestingServer
-
Close the server and any open clients and delete the temp directory
- close() - Method in class com.netflix.curator.test.TestingZooKeeperMain
-
- close() - Method in class com.netflix.curator.test.TestingZooKeeperServer
-
- close() - Method in class com.netflix.curator.x.discovery.details.ServiceCacheImpl
-
- close() - Method in class com.netflix.curator.x.discovery.details.ServiceDiscoveryImpl
-
- close() - Method in class com.netflix.curator.x.discovery.details.ServiceProviderImpl
- close() - Method in class com.netflix.curator.x.discovery.server.rest.InstanceCleanup
-
- close() - Method in class com.netflix.curator.x.zkclientbridge.CuratorZKClientBridge
-
- close() - Method in class discovery.ExampleServer
-
- close() - Method in class leader.ExampleClient
-
- com.netflix.curator - package com.netflix.curator
-
- com.netflix.curator.drivers - package com.netflix.curator.drivers
-
- com.netflix.curator.ensemble - package com.netflix.curator.ensemble
-
- com.netflix.curator.ensemble.exhibitor - package com.netflix.curator.ensemble.exhibitor
-
- com.netflix.curator.ensemble.fixed - package com.netflix.curator.ensemble.fixed
-
- com.netflix.curator.framework - package com.netflix.curator.framework
-
- com.netflix.curator.framework.api - package com.netflix.curator.framework.api
-
- com.netflix.curator.framework.api.transaction - package com.netflix.curator.framework.api.transaction
-
- com.netflix.curator.framework.imps - package com.netflix.curator.framework.imps
-
- com.netflix.curator.framework.listen - package com.netflix.curator.framework.listen
-
- com.netflix.curator.framework.recipes.atomic - package com.netflix.curator.framework.recipes.atomic
-
- com.netflix.curator.framework.recipes.barriers - package com.netflix.curator.framework.recipes.barriers
-
- com.netflix.curator.framework.recipes.cache - package com.netflix.curator.framework.recipes.cache
-
- com.netflix.curator.framework.recipes.leader - package com.netflix.curator.framework.recipes.leader
-
- com.netflix.curator.framework.recipes.locks - package com.netflix.curator.framework.recipes.locks
-
- com.netflix.curator.framework.recipes.queue - package com.netflix.curator.framework.recipes.queue
-
- com.netflix.curator.framework.recipes.shared - package com.netflix.curator.framework.recipes.shared
-
- com.netflix.curator.framework.state - package com.netflix.curator.framework.state
-
- com.netflix.curator.retry - package com.netflix.curator.retry
-
- com.netflix.curator.test - package com.netflix.curator.test
-
- com.netflix.curator.utils - package com.netflix.curator.utils
-
- com.netflix.curator.x.discovery - package com.netflix.curator.x.discovery
-
- com.netflix.curator.x.discovery.details - package com.netflix.curator.x.discovery.details
-
- com.netflix.curator.x.discovery.server.contexts - package com.netflix.curator.x.discovery.server.contexts
-
- com.netflix.curator.x.discovery.server.entity - package com.netflix.curator.x.discovery.server.entity
-
- com.netflix.curator.x.discovery.server.rest - package com.netflix.curator.x.discovery.server.rest
-
- com.netflix.curator.x.discovery.strategies - package com.netflix.curator.x.discovery.strategies
-
- com.netflix.curator.x.zkclientbridge - package com.netflix.curator.x.zkclientbridge
-
- commit() - Method in interface com.netflix.curator.framework.api.transaction.CuratorTransactionFinal
-
Commit all added operations as an atomic unit and return results
for the operations.
- commit() - Method in class com.netflix.curator.TimeTrace
-
Record the elapsed time
- compareAndSet(Integer, Integer) - Method in class com.netflix.curator.framework.recipes.atomic.DistributedAtomicInteger
-
- compareAndSet(Long, Long) - Method in class com.netflix.curator.framework.recipes.atomic.DistributedAtomicLong
-
- compareAndSet(T, T) - Method in interface com.netflix.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 com.netflix.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 com.netflix.curator.framework.recipes.cache.ChildData
-
- compress(String, byte[]) - Method in interface com.netflix.curator.framework.api.CompressionProvider
-
- compress(String, byte[]) - Method in class com.netflix.curator.framework.imps.GzipCompressionProvider
-
- compressed() - Method in interface com.netflix.curator.framework.api.Compressible
-
Cause the data to be compressed using the configured compression provider
- Compressible<T> - Interface in com.netflix.curator.framework.api
-
- CompressionProvider - Interface in com.netflix.curator.framework.api
-
- compressionProvider(CompressionProvider) - Method in class com.netflix.curator.framework.CuratorFrameworkFactory.Builder
-
- connect(Watcher) - Method in class com.netflix.curator.x.zkclientbridge.CuratorZKClientBridge
-
- connection() - Method in class com.netflix.curator.test.Timing
-
Return the value to use for ZK connection timeout
- ConnectionState - Enum in com.netflix.curator.framework.state
-
Represents state changes in the connection to ZK
- ConnectionStateListener - Interface in com.netflix.curator.framework.state
-
- ConnectionStateManager - Class in com.netflix.curator.framework.state
-
Used internally to manage connection state
- ConnectionStateManager(CuratorFramework, ThreadFactory) - Constructor for class com.netflix.curator.framework.state.ConnectionStateManager
-
- connectionTimeoutMs(int) - Method in class com.netflix.curator.framework.CuratorFrameworkFactory.Builder
-
- connectString(String) - Method in class com.netflix.curator.framework.CuratorFrameworkFactory.Builder
-
Set the list of servers to connect to.
- consumeMessage(T) - Method in class com.netflix.curator.framework.recipes.queue.BlockingQueueConsumer
-
- consumeMessage(T) - Method in interface com.netflix.curator.framework.recipes.queue.QueueConsumer
-
Process a message from the queue
- countHasChanged(SharedCountReader, int) - Method in interface com.netflix.curator.framework.recipes.shared.SharedCountListener
-
Called when the shared value has changed
- create() - Method in interface com.netflix.curator.framework.api.transaction.CuratorTransaction
-
Start a create builder in the transaction
- create() - Method in interface com.netflix.curator.framework.CuratorFramework
-
Start a create builder
- create() - Method in class com.netflix.curator.framework.imps.CuratorFrameworkImpl
-
- create(String, byte[], CreateMode) - Method in class com.netflix.curator.x.zkclientbridge.CuratorZKClientBridge
-
- create(CuratorFramework, String, byte[]) - Static method in class framework.CrudExamples
-
- CreateBackgroundModeACLable - Interface in com.netflix.curator.framework.api
-
- CreateBuilder - Interface in com.netflix.curator.framework.api
-
- CreateClientExamples - Class in framework
-
- CreateClientExamples() - Constructor for class framework.CreateClientExamples
-
- createEphemeral(CuratorFramework, String, byte[]) - Static method in class framework.CrudExamples
-
- createEphemeralSequential(CuratorFramework, String, byte[]) - Static method in class framework.CrudExamples
-
- CreateModable<T> - Interface in com.netflix.curator.framework.api
-
- CreateModalPathAndBytesable<T> - Interface in com.netflix.curator.framework.api
-
- createSimple(String) - Static method in class framework.CreateClientExamples
-
- createWithOptions(String, RetryPolicy, int, int) - Static method in class framework.CreateClientExamples
-
- creatingParentsIfNeeded() - Method in interface com.netflix.curator.framework.api.CreateBackgroundModeACLable
-
Causes any parent nodes to get created if they haven't already been
- creatingParentsIfNeeded() - Method in interface com.netflix.curator.framework.api.CreateBuilder
-
Causes any parent nodes to get created if they haven't already been
- CrudExamples - Class in framework
-
- CrudExamples() - Constructor for class framework.CrudExamples
-
- CuratorEvent - Interface in com.netflix.curator.framework.api
-
A super set of all the various Zookeeper events/background methods.
- CuratorEventType - Enum in com.netflix.curator.framework.api
-
- CuratorFramework - Interface in com.netflix.curator.framework
-
Zookeeper framework-style client
- CuratorFrameworkFactory - Class in com.netflix.curator.framework
-
Factory methods for creating framework-style clients
- CuratorFrameworkFactory.Builder - Class in com.netflix.curator.framework
-
- CuratorFrameworkImpl - Class in com.netflix.curator.framework.imps
-
- CuratorFrameworkImpl(CuratorFrameworkFactory.Builder) - Constructor for class com.netflix.curator.framework.imps.CuratorFrameworkImpl
-
- CuratorFrameworkImpl(CuratorFrameworkImpl) - Constructor for class com.netflix.curator.framework.imps.CuratorFrameworkImpl
-
- CuratorListener - Interface in com.netflix.curator.framework.api
-
Receives notifications about errors and background events
- CuratorTransaction - Interface in com.netflix.curator.framework.api.transaction
-
Transactional/atomic operations.
- CuratorTransactionBridge - Interface in com.netflix.curator.framework.api.transaction
-
- CuratorTransactionFinal - Interface in com.netflix.curator.framework.api.transaction
-
Adds commit to the transaction interface
- CuratorTransactionResult - Class in com.netflix.curator.framework.api.transaction
-
Holds the result of one transactional operation
- CuratorTransactionResult(OperationType, String, String, Stat) - Constructor for class com.netflix.curator.framework.api.transaction.CuratorTransactionResult
-
- CuratorWatcher - Interface in com.netflix.curator.framework.api
-
A version of Watcher
that can throw an exception
- CuratorZKClientBridge - Class in com.netflix.curator.x.zkclientbridge
-
Bridge between ZKClient and Curator.
- CuratorZKClientBridge(CuratorFramework) - Constructor for class com.netflix.curator.x.zkclientbridge.CuratorZKClientBridge
-
- CuratorZookeeperClient - Class in com.netflix.curator
-
A wrapper around Zookeeper that takes care of some low-level housekeeping
- CuratorZookeeperClient(String, int, int, Watcher, RetryPolicy) - Constructor for class com.netflix.curator.CuratorZookeeperClient
-
- CuratorZookeeperClient(EnsembleProvider, int, int, Watcher, RetryPolicy) - Constructor for class com.netflix.curator.CuratorZookeeperClient
-
- CuratorZookeeperClient(ZookeeperFactory, EnsembleProvider, int, int, Watcher, RetryPolicy) - Constructor for class com.netflix.curator.CuratorZookeeperClient
-
- DebugUtils - Class in com.netflix.curator.utils
-
- decompress(String, byte[]) - Method in interface com.netflix.curator.framework.api.CompressionProvider
-
- decompress(String, byte[]) - Method in class com.netflix.curator.framework.imps.GzipCompressionProvider
-
- decompressed() - Method in interface com.netflix.curator.framework.api.Decompressible
-
Cause the data to be de-compressed using the configured compression provider
- Decompressible<T> - Interface in com.netflix.curator.framework.api
-
- decrement() - Method in class com.netflix.curator.framework.recipes.atomic.DistributedAtomicInteger
-
Subtract 1 from the current value and return the new value information.
- decrement() - Method in class com.netflix.curator.framework.recipes.atomic.DistributedAtomicLong
-
Subtract 1 from the current value and return the new value information.
- decrement() - Method in interface com.netflix.curator.framework.recipes.atomic.DistributedAtomicNumber
-
Subtract 1 from the current value and return the new value information.
- DEFAULT_REFRESH_PADDING - Static variable in class com.netflix.curator.x.discovery.details.ServiceDiscoveryImpl
-
- DefaultACLProvider - Class in com.netflix.curator.framework.imps
-
- DefaultACLProvider() - Constructor for class com.netflix.curator.framework.imps.DefaultACLProvider
-
- defaultData(byte[]) - Method in class com.netflix.curator.framework.CuratorFrameworkFactory.Builder
-
- DefaultExhibitorRestClient - Class in com.netflix.curator.ensemble.exhibitor
-
- DefaultExhibitorRestClient() - Constructor for class com.netflix.curator.ensemble.exhibitor.DefaultExhibitorRestClient
-
- DefaultExhibitorRestClient(boolean) - Constructor for class com.netflix.curator.ensemble.exhibitor.DefaultExhibitorRestClient
-
- DefaultTracerDriver - Class in com.netflix.curator.utils
-
Default tracer driver
- DefaultTracerDriver() - Constructor for class com.netflix.curator.utils.DefaultTracerDriver
-
- DefaultZookeeperFactory - Class in com.netflix.curator.utils
-
- DefaultZookeeperFactory() - Constructor for class com.netflix.curator.utils.DefaultZookeeperFactory
-
- delete() - Method in interface com.netflix.curator.framework.api.transaction.CuratorTransaction
-
Start a delete builder in the transaction
- delete() - Method in interface com.netflix.curator.framework.CuratorFramework
-
Start a delete builder
- delete() - Method in class com.netflix.curator.framework.imps.CuratorFrameworkImpl
-
- delete(String) - Method in class com.netflix.curator.x.zkclientbridge.CuratorZKClientBridge
-
- delete(CuratorFramework, String) - Static method in class framework.CrudExamples
-
- DeleteBuilder - Interface in com.netflix.curator.framework.api
-
- DeleteBuilderBase - Interface in com.netflix.curator.framework.api
-
- deleteDataDirectoryOnClose() - Method in class com.netflix.curator.test.InstanceSpec
-
- deleteDirectoryContents(File) - Static method in class com.netflix.curator.test.DirectoryUtils
-
- deleteRecursively(File) - Static method in class com.netflix.curator.test.DirectoryUtils
-
- deserialize(byte[]) - Method in interface com.netflix.curator.framework.recipes.queue.QueueSerializer
-
Deserialize bytes into a queue item
- deserialize(byte[]) - Method in interface com.netflix.curator.x.discovery.details.InstanceSerializer
-
Deserialize a byte array into an instance
- deserialize(byte[]) - Method in class com.netflix.curator.x.discovery.details.JsonInstanceSerializer
-
- DirectoryUtils - Class in com.netflix.curator.test
-
- DirectoryUtils() - Constructor for class com.netflix.curator.test.DirectoryUtils
-
- discovery - package discovery
-
- DiscoveryContext<T> - Interface in com.netflix.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
-
- DiscoveryResource<T> - Class in com.netflix.curator.x.discovery.server.rest
-
The JAX-RS web service.
- DiscoveryResource(DiscoveryContext<T>) - Constructor for class com.netflix.curator.x.discovery.server.rest.DiscoveryResource
-
- DistributedAtomicInteger - Class in com.netflix.curator.framework.recipes.atomic
-
A counter that attempts atomic increments.
- DistributedAtomicInteger(CuratorFramework, String, RetryPolicy) - Constructor for class com.netflix.curator.framework.recipes.atomic.DistributedAtomicInteger
-
Creates in optimistic mode only - i.e.
- DistributedAtomicInteger(CuratorFramework, String, RetryPolicy, PromotedToLock) - Constructor for class com.netflix.curator.framework.recipes.atomic.DistributedAtomicInteger
-
Creates in mutex promotion mode.
- DistributedAtomicLong - Class in com.netflix.curator.framework.recipes.atomic
-
A counter that attempts atomic increments.
- DistributedAtomicLong(CuratorFramework, String, RetryPolicy) - Constructor for class com.netflix.curator.framework.recipes.atomic.DistributedAtomicLong
-
Creates in optimistic mode only - i.e.
- DistributedAtomicLong(CuratorFramework, String, RetryPolicy, PromotedToLock) - Constructor for class com.netflix.curator.framework.recipes.atomic.DistributedAtomicLong
-
Creates in mutex promotion mode.
- DistributedAtomicNumber<T> - Interface in com.netflix.curator.framework.recipes.atomic
-
- DistributedAtomicValue - Class in com.netflix.curator.framework.recipes.atomic
-
A distributed value that attempts atomic sets.
- DistributedAtomicValue(CuratorFramework, String, RetryPolicy) - Constructor for class com.netflix.curator.framework.recipes.atomic.DistributedAtomicValue
-
Creates in optimistic mode only - i.e.
- DistributedAtomicValue(CuratorFramework, String, RetryPolicy, PromotedToLock) - Constructor for class com.netflix.curator.framework.recipes.atomic.DistributedAtomicValue
-
Creates in mutex promotion mode.
- DistributedBarrier - Class in com.netflix.curator.framework.recipes.barriers
-
A barrier as described in the ZK recipes.
- DistributedBarrier(CuratorFramework, String) - Constructor for class com.netflix.curator.framework.recipes.barriers.DistributedBarrier
-
- DistributedDelayQueue<T> - Class in com.netflix.curator.framework.recipes.queue
-
A variation of the DistributedPriorityQueue that uses time as the priority.
- DistributedDoubleBarrier - Class in com.netflix.curator.framework.recipes.barriers
-
A double barrier as described in the ZK recipes.
- DistributedDoubleBarrier(CuratorFramework, String, int) - Constructor for class com.netflix.curator.framework.recipes.barriers.DistributedDoubleBarrier
-
Creates the barrier abstraction.
- DistributedIdQueue<T> - Class in com.netflix.curator.framework.recipes.queue
-
A version of
DistributedQueue
that allows IDs to be associated with queue items.
- DistributedPriorityQueue<T> - Class in com.netflix.curator.framework.recipes.queue
-
An implementation of the Distributed Priority Queue ZK recipe.
- DistributedQueue<T> - Class in com.netflix.curator.framework.recipes.queue
-
An implementation of the Distributed Queue ZK recipe.
- DistributedQueue.ProcessType - Enum in com.netflix.curator.framework.recipes.queue
-
- doWork(long, TimeUnit) - Method in class locking.ExampleClientThatLocks
-
- drainTo(Collection<? super T>) - Method in class com.netflix.curator.framework.recipes.queue.BlockingQueueConsumer
-
Removes all available elements from this queue and adds them
to the given collection.
- 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 com.netflix.curator.x.discovery.UriSpec
-
- FIELD_CLOSE_BRACE - Static variable in class com.netflix.curator.x.discovery.UriSpec
-
Always replaced with '}' - i.e.
- FIELD_ID - Static variable in class com.netflix.curator.x.discovery.UriSpec
-
- FIELD_NAME - Static variable in class com.netflix.curator.x.discovery.UriSpec
-
- FIELD_OPEN_BRACE - Static variable in class com.netflix.curator.x.discovery.UriSpec
-
Always replaced with '{' - i.e.
- FIELD_PORT - Static variable in class com.netflix.curator.x.discovery.UriSpec
-
- FIELD_REGISTRATION_TIME_UTC - Static variable in class com.netflix.curator.x.discovery.UriSpec
-
- FIELD_SCHEME - Static variable in class com.netflix.curator.x.discovery.UriSpec
-
This defaults to "http".
- FIELD_SERVICE_TYPE - Static variable in class com.netflix.curator.x.discovery.UriSpec
-
- FIELD_SSL_PORT - Static variable in class com.netflix.curator.x.discovery.UriSpec
-
- finalFlushTime(int, TimeUnit) - Method in class com.netflix.curator.framework.recipes.queue.QueueBuilder
-
- findConnectionInstance(ZooKeeper) - Method in class com.netflix.curator.test.TestingCluster
-
Given a ZooKeeper instance, returns which server it is connected to
- FixedEnsembleProvider - Class in com.netflix.curator.ensemble.fixed
-
Standard ensemble provider that wraps a fixed connection string
- FixedEnsembleProvider(String) - Constructor for class com.netflix.curator.ensemble.fixed.FixedEnsembleProvider
-
The connection string to use
- fixForNamespace(String, String) - Static method in class com.netflix.curator.utils.ZKPaths
-
Apply the namespace to the given path
- fixForSorting(String, String) - Method in interface com.netflix.curator.framework.recipes.locks.LockInternalsSorter
-
- fixForSorting(String, String) - Method in class com.netflix.curator.framework.recipes.locks.StandardLockInternalsDriver
-
- flushPuts(long, TimeUnit) - Method in class com.netflix.curator.framework.recipes.queue.DistributedDelayQueue
-
- flushPuts(long, TimeUnit) - Method in class com.netflix.curator.framework.recipes.queue.DistributedIdQueue
-
- flushPuts(long, TimeUnit) - Method in class com.netflix.curator.framework.recipes.queue.DistributedPriorityQueue
-
- flushPuts(long, TimeUnit) - Method in class com.netflix.curator.framework.recipes.queue.DistributedQueue
-
Wait until any pending puts are committed
- flushPuts(long, TimeUnit) - Method in interface com.netflix.curator.framework.recipes.queue.QueueBase
-
Wait until any pending puts are committed
- forceSet(Integer) - Method in class com.netflix.curator.framework.recipes.atomic.DistributedAtomicInteger
-
- forceSet(Long) - Method in class com.netflix.curator.framework.recipes.atomic.DistributedAtomicLong
-
- forceSet(T) - Method in interface com.netflix.curator.framework.recipes.atomic.DistributedAtomicNumber
-
Forcibly sets the value of the counter without any guarantees of atomicity.
- forceSet(byte[]) - Method in class com.netflix.curator.framework.recipes.atomic.DistributedAtomicValue
-
Forcibly sets the value any guarantees of atomicity.
- forEach(Function<T, Void>) - Method in class com.netflix.curator.framework.listen.ListenerContainer
-
Utility - apply the given function to each listener.
- forPath(String) - Method in interface com.netflix.curator.framework.api.Pathable
-
Commit the currently building operation using the given path
- forPath(String, byte[]) - Method in interface com.netflix.curator.framework.api.PathAndBytesable
-
Commit the currently building operation using the given path and data
- forPath(String) - Method in interface com.netflix.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[])
).
- forWaiting() - Method in class com.netflix.curator.test.Timing
-
Return a new timing with the standard multiple for waiting on latches, etc.
- framework - package framework
-
- get() - Method in class com.netflix.curator.framework.recipes.atomic.DistributedAtomicInteger
-
- get() - Method in class com.netflix.curator.framework.recipes.atomic.DistributedAtomicLong
-
- get() - Method in interface com.netflix.curator.framework.recipes.atomic.DistributedAtomicNumber
-
Returns the current value of the counter.
- get() - Method in class com.netflix.curator.framework.recipes.atomic.DistributedAtomicValue
-
Returns the current value of the counter.
- get(String, String) - Method in class com.netflix.curator.x.discovery.server.rest.DiscoveryResource
-
- getACL() - Method in interface com.netflix.curator.framework.CuratorFramework
-
Start a get ACL builder
- getACL() - Method in class com.netflix.curator.framework.imps.CuratorFrameworkImpl
-
- GetACLBuilder - Interface in com.netflix.curator.framework.api
-
- getAclForPath(String) - Method in interface com.netflix.curator.framework.api.ACLProvider
-
Return the ACL list to use for the given path
- getAclForPath(String) - Method in class com.netflix.curator.framework.imps.DefaultACLProvider
-
- getACLList() - Method in interface com.netflix.curator.framework.api.CuratorEvent
-
- getAclProvider() - Method in class com.netflix.curator.framework.CuratorFrameworkFactory.Builder
-
- getAddress() - Method in class com.netflix.curator.x.discovery.ServiceInstance
-
- getAll(String) - Method in class com.netflix.curator.x.discovery.server.rest.DiscoveryResource
-
- getAllLocalIPs() - Static method in class com.netflix.curator.x.discovery.ServiceInstanceBuilder
-
based on http://pastebin.com/5X073pUc
- getAllNames() - Method in class com.netflix.curator.x.discovery.server.rest.DiscoveryResource
-
- getAny(String) - Method in class com.netflix.curator.x.discovery.server.rest.DiscoveryResource
-
- getAuthScheme() - Method in class com.netflix.curator.framework.CuratorFrameworkFactory.Builder
-
- getAuthValue() - Method in class com.netflix.curator.framework.CuratorFrameworkFactory.Builder
-
- getBackupConnectionString() - Method in interface com.netflix.curator.ensemble.exhibitor.Exhibitors.BackupConnectionStringProvider
-
- getBackupConnectionString() - Method in class com.netflix.curator.ensemble.exhibitor.Exhibitors
-
- getBaseSleepTimeMs() - Method in class com.netflix.curator.retry.ExponentialBackoffRetry
-
- getChildren() - Method in interface com.netflix.curator.framework.api.CuratorEvent
-
- getChildren() - Method in interface com.netflix.curator.framework.CuratorFramework
-
Start a get children builder
- getChildren() - Method in class com.netflix.curator.framework.imps.CuratorFrameworkImpl
-
- getChildren() - Method in class com.netflix.curator.framework.recipes.queue.DistributedQueue
-
- getChildren(String, boolean) - Method in class com.netflix.curator.x.zkclientbridge.CuratorZKClientBridge
-
- GetChildrenBuilder - Interface in com.netflix.curator.framework.api
-
- getChildrenForEntering() - Method in class com.netflix.curator.framework.recipes.barriers.DistributedDoubleBarrier
-
- getCompressionProvider() - Method in class com.netflix.curator.framework.CuratorFrameworkFactory.Builder
-
- getConnectionStateListenable() - Method in interface com.netflix.curator.framework.CuratorFramework
-
Returns the listenable interface for the Connect State
- getConnectionStateListenable() - Method in class com.netflix.curator.framework.imps.CuratorFrameworkImpl
-
- getConnectionString() - Method in interface com.netflix.curator.ensemble.EnsembleProvider
-
Return the current connection string to use.
- getConnectionString() - Method in class com.netflix.curator.ensemble.exhibitor.ExhibitorEnsembleProvider
-
- getConnectionString() - Method in class com.netflix.curator.ensemble.fixed.FixedEnsembleProvider
-
- getConnectionTimeoutMs() - Method in class com.netflix.curator.framework.CuratorFrameworkFactory.Builder
-
- getConnectString() - Method in class com.netflix.curator.test.InstanceSpec
-
- getConnectString() - Method in class com.netflix.curator.test.TestingCluster
-
Returns the connection string to pass to the ZooKeeper constructor
- getConnectString() - Method in class com.netflix.curator.test.TestingServer
-
Returns the connection string to use
- getContext() - Method in interface com.netflix.curator.framework.api.CuratorEvent
-
- getContext(Class<?>) - Method in class com.netflix.curator.x.discovery.server.contexts.IntegerDiscoveryContext
-
- getContext(Class<?>) - Method in class com.netflix.curator.x.discovery.server.contexts.MapDiscoveryContext
-
- getContext(Class<?>) - Method in class com.netflix.curator.x.discovery.server.contexts.StringDiscoveryContext
-
- getCount() - Method in class com.netflix.curator.framework.recipes.shared.SharedCount
-
- getCount() - Method in interface com.netflix.curator.framework.recipes.shared.SharedCountReader
-
Return the current value of the count
- getCreateTime(String) - Method in class com.netflix.curator.x.zkclientbridge.CuratorZKClientBridge
-
- getCurator() - Method in class com.netflix.curator.x.zkclientbridge.CuratorZKClientBridge
-
Return the client
- getCuratorListenable() - Method in interface com.netflix.curator.framework.CuratorFramework
-
Returns the listenable interface for events
- getCuratorListenable() - Method in class com.netflix.curator.framework.imps.CuratorFrameworkImpl
-
- getCurrentConnectionString() - Method in class com.netflix.curator.CuratorZookeeperClient
-
Returns the current known connection string - not guaranteed to be correct
value at any point in the future.
- getCurrentData() - Method in class com.netflix.curator.framework.recipes.cache.PathChildrenCache
-
Return the current data.
- getCurrentData(String) - Method in class com.netflix.curator.framework.recipes.cache.PathChildrenCache
-
Return the current data for the given path.
- getData() - Method in interface com.netflix.curator.framework.api.CuratorEvent
-
- getData() - Method in interface com.netflix.curator.framework.CuratorFramework
-
Start a get data builder
- getData() - Method in class com.netflix.curator.framework.imps.CuratorFrameworkImpl
-
- getData() - Method in class com.netflix.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 com.netflix.curator.framework.recipes.cache.PathChildrenCacheEvent
-
- GetDataBuilder - Interface in com.netflix.curator.framework.api
-
- getDataDirectory() - Method in class com.netflix.curator.test.InstanceSpec
-
- GetDataWatchBackgroundStatable - Interface in com.netflix.curator.framework.api
-
- getDefaultAcl() - Method in interface com.netflix.curator.framework.api.ACLProvider
-
Return the ACL list to use by default (usually ZooDefs.Ids#OPEN_ACL_UNSAFE
).
- getDefaultAcl() - Method in class com.netflix.curator.framework.imps.DefaultACLProvider
-
- getDefaultData() - Method in class com.netflix.curator.framework.CuratorFrameworkFactory.Builder
-
- getDefaultRetrySleeper() - Static method in class com.netflix.curator.RetryLoop
-
Returns the default retry sleeper
- getDelay(String) - Method in class com.netflix.curator.framework.recipes.queue.DistributedQueue
-
- getDescription() - Method in class discovery.InstanceDetails
-
- getElectionPort() - Method in class com.netflix.curator.test.InstanceSpec
-
- getEnsembleProvider() - Method in class com.netflix.curator.framework.CuratorFrameworkFactory.Builder
-
- getForPath() - Method in class com.netflix.curator.framework.api.transaction.CuratorTransactionResult
-
Returns the path that was passed to the operation when added
- getHostnames() - Method in class com.netflix.curator.ensemble.exhibitor.Exhibitors
-
- getId() - Method in class com.netflix.curator.framework.recipes.leader.LeaderLatch
-
Return this instance's participant Id
- getId() - Method in class com.netflix.curator.framework.recipes.leader.LeaderSelector
-
- getId() - Method in class com.netflix.curator.framework.recipes.leader.Participant
-
- getId() - Method in class com.netflix.curator.x.discovery.ServiceInstance
-
- getInstance() - Method in class com.netflix.curator.x.discovery.details.ServiceProviderImpl
-
Return an instance for a single use.
- getInstance(InstanceProvider<T>) - Method in interface com.netflix.curator.x.discovery.ProviderStrategy
-
Given a source of instances, return one of them for a single use.
- getInstance() - Method in interface com.netflix.curator.x.discovery.ServiceProvider
-
Return an instance for a single use.
- getInstance(InstanceProvider<T>) - Method in class com.netflix.curator.x.discovery.strategies.RandomStrategy
-
- getInstance(InstanceProvider<T>) - Method in class com.netflix.curator.x.discovery.strategies.RoundRobinStrategy
-
- getInstance(InstanceProvider<T>) - Method in class com.netflix.curator.x.discovery.strategies.StickyStrategy
-
- getInstanceNumber() - Method in class com.netflix.curator.x.discovery.strategies.StickyStrategy
-
Each time a new instance is picked, an internal counter is incremented.
- getInstanceRefreshMs() - Method in class com.netflix.curator.x.discovery.server.contexts.IntegerDiscoveryContext
-
- getInstanceRefreshMs() - Method in class com.netflix.curator.x.discovery.server.contexts.MapDiscoveryContext
-
- getInstanceRefreshMs() - Method in class com.netflix.curator.x.discovery.server.contexts.StringDiscoveryContext
-
- getInstanceRefreshMs() - Method in interface com.netflix.curator.x.discovery.server.rest.DiscoveryContext
-
Return the threshold in milliseconds to consider a registration stale
- getInstances() - Method in class com.netflix.curator.test.TestingCluster
-
Returns the set of servers in the ensemble
- getInstances() - Method in interface com.netflix.curator.x.discovery.details.InstanceProvider
-
Return the current available set of instances
- getInstances() - Method in class com.netflix.curator.x.discovery.details.ServiceCacheImpl
-
- getInstances() - Method in interface com.netflix.curator.x.discovery.ServiceCache
-
Return the current list of instances.
- getInstanceSpec(int) - Method in class com.netflix.curator.test.QuorumConfigBuilder
-
- getInstanceSpec() - Method in class com.netflix.curator.test.TestingZooKeeperServer
-
- getInstanceSpecs() - Method in class com.netflix.curator.test.QuorumConfigBuilder
-
- getItems() - Method in class com.netflix.curator.framework.recipes.queue.BlockingQueueConsumer
-
Return any currently queued items without removing them from the queue
- getLastMessageCount() - Method in class com.netflix.curator.framework.recipes.queue.DistributedDelayQueue
-
Return the most recent message count from the queue.
- getLastMessageCount() - Method in class com.netflix.curator.framework.recipes.queue.DistributedIdQueue
-
- getLastMessageCount() - Method in class com.netflix.curator.framework.recipes.queue.DistributedPriorityQueue
-
Return the most recent message count from the queue.
- getLastMessageCount() - Method in class com.netflix.curator.framework.recipes.queue.DistributedQueue
-
Return the most recent message count from the queue.
- getLastMessageCount() - Method in interface com.netflix.curator.framework.recipes.queue.QueueBase
-
Return the most recent message count from the queue.
- getLeader() - Method in class com.netflix.curator.framework.recipes.leader.LeaderLatch
-
Return the id for the current leader.
- getLeader() - Method in class com.netflix.curator.framework.recipes.leader.LeaderSelector
-
Return the id for the current leader.
- getListenable() - Method in class com.netflix.curator.framework.recipes.cache.PathChildrenCache
-
Return the cache listenable
- getListenable() - Method in class com.netflix.curator.framework.recipes.shared.SharedValue
-
Returns the listenable
- getListenable() - Method in interface com.netflix.curator.framework.recipes.shared.SharedValueReader
-
Returns the listenable
- getListenable() - Method in class com.netflix.curator.framework.state.ConnectionStateManager
-
Return the listenable
- getLockNodeBytes() - Method in class com.netflix.curator.framework.recipes.locks.InterProcessMutex
-
- getMaxSleepTimeMs() - Method in class com.netflix.curator.retry.BoundedExponentialBackoffRetry
-
- getName() - Method in interface com.netflix.curator.framework.api.CuratorEvent
-
- getName() - Method in class com.netflix.curator.x.discovery.ServiceInstance
-
- getNames() - Method in class com.netflix.curator.x.discovery.server.entity.ServiceNames
-
- getNamespace() - Method in interface com.netflix.curator.framework.CuratorFramework
-
Return the current namespace or "" if none
- getNamespace() - Method in class com.netflix.curator.framework.CuratorFrameworkFactory.Builder
-
- getNamespace() - Method in class com.netflix.curator.framework.imps.CuratorFrameworkImpl
-
- getNode() - Method in class com.netflix.curator.utils.ZKPaths.PathAndNode
-
- getNodeFromPath(String) - Static method in class com.netflix.curator.utils.ZKPaths
-
Given a full path, return the node name.
- getOptimisticTimeMs() - Method in class com.netflix.curator.framework.recipes.atomic.AtomicStats
-
Returns the time spent trying the operation with optimistic locks
- getOptimisticTries() - Method in class com.netflix.curator.framework.recipes.atomic.AtomicStats
-
Returns the number of optimistic locks used to perform the operation
- getParticipantNodes() - Method in class com.netflix.curator.framework.recipes.locks.InterProcessMutex
-
Return a sorted list of all current nodes participating in the lock
- getParticipantNodes(CuratorFramework, String, String, LockInternalsSorter) - Static method in class com.netflix.curator.framework.recipes.locks.LockInternals
-
- getParticipants() - Method in class com.netflix.curator.framework.recipes.leader.LeaderLatch
-
Returns the set of current participants in the leader selection
- getParticipants() - Method in class com.netflix.curator.framework.recipes.leader.LeaderSelector
-
Returns the set of current participants in the leader selection
- getParts() - Method in class com.netflix.curator.x.discovery.UriSpec
-
- getPath() - Method in interface com.netflix.curator.framework.api.CuratorEvent
-
- getPath() - Method in class com.netflix.curator.framework.recipes.cache.ChildData
-
Returns the full path of the this child
- getPath() - Method in class com.netflix.curator.utils.ZKPaths.PathAndNode
-
- getPathAndNode(String) - Static method in class com.netflix.curator.utils.ZKPaths
-
Given a full path, return the node name and its path.
- getPayload() - Method in class com.netflix.curator.x.discovery.ServiceInstance
-
- getPort() - Method in class com.netflix.curator.test.InstanceSpec
-
- getPort() - Method in class com.netflix.curator.test.TestingServer
-
Return the port being used
- getPort() - Method in class com.netflix.curator.x.discovery.ServiceInstance
-
- getPromotedLockTries() - Method in class com.netflix.curator.framework.recipes.atomic.AtomicStats
-
Returns the number of mutex locks used to perform the operation
- getPromotedTimeMs() - Method in class com.netflix.curator.framework.recipes.atomic.AtomicStats
-
Returns the time spent trying the operation with mutex locks
- getProviderStrategy() - Method in class com.netflix.curator.x.discovery.server.contexts.IntegerDiscoveryContext
-
- getProviderStrategy() - Method in class com.netflix.curator.x.discovery.server.contexts.MapDiscoveryContext
-
- getProviderStrategy() - Method in class com.netflix.curator.x.discovery.server.contexts.StringDiscoveryContext
-
- getProviderStrategy() - Method in interface com.netflix.curator.x.discovery.server.rest.DiscoveryContext
-
- getPutListenerContainer() - Method in class com.netflix.curator.framework.recipes.queue.DistributedDelayQueue
-
Return the manager for put listeners
- getPutListenerContainer() - Method in class com.netflix.curator.framework.recipes.queue.DistributedIdQueue
-
- getPutListenerContainer() - Method in class com.netflix.curator.framework.recipes.queue.DistributedPriorityQueue
-
Return the manager for put listeners
- getPutListenerContainer() - Method in class com.netflix.curator.framework.recipes.queue.DistributedQueue
-
Return the manager for put listeners
- getPutListenerContainer() - Method in interface com.netflix.curator.framework.recipes.queue.QueueBase
-
Return the manager for put listeners
- getQueue() - Method in class com.netflix.curator.framework.recipes.queue.QueueSharder
-
Return one of the managed queues - the selection method cannot be relied on.
- getQueuePaths() - Method in class com.netflix.curator.framework.recipes.queue.QueueSharder
-
Return the current set of shard paths
- getQuorumPort() - Method in class com.netflix.curator.test.InstanceSpec
-
- getRandomPort() - Static method in class com.netflix.curator.test.InstanceSpec
-
- getRaw(String, int, String, String) - Method in class com.netflix.curator.ensemble.exhibitor.DefaultExhibitorRestClient
-
- getRaw(String, int, String, String) - Method in interface com.netflix.curator.ensemble.exhibitor.ExhibitorRestClient
-
Connect to the given Exhibitor and return the raw result
- getRegistrationTimeUTC() - Method in class com.netflix.curator.x.discovery.ServiceInstance
-
- getRestPort() - Method in class com.netflix.curator.ensemble.exhibitor.Exhibitors
-
- getResultCode() - Method in interface com.netflix.curator.framework.api.CuratorEvent
-
- getResultPath() - Method in class com.netflix.curator.framework.api.transaction.CuratorTransactionResult
-
Returns the operation generated path or null
.
- getResultStat() - Method in class com.netflix.curator.framework.api.transaction.CuratorTransactionResult
-
Returns the operation generated stat or null
.
- getRetryPolicy() - Method in class com.netflix.curator.CuratorZookeeperClient
-
Return the current retry policy
- getRetryPolicy() - Method in class com.netflix.curator.framework.CuratorFrameworkFactory.Builder
-
- getServerId() - Method in class com.netflix.curator.test.InstanceSpec
-
- getServers() - Method in class com.netflix.curator.x.zkclientbridge.CuratorZKClientBridge
-
- getServiceDiscovery() - Method in class com.netflix.curator.x.discovery.server.contexts.IntegerDiscoveryContext
-
- getServiceDiscovery() - Method in class com.netflix.curator.x.discovery.server.contexts.MapDiscoveryContext
-
- getServiceDiscovery() - Method in class com.netflix.curator.x.discovery.server.contexts.StringDiscoveryContext
-
- getServiceDiscovery() - Method in interface com.netflix.curator.x.discovery.server.rest.DiscoveryContext
-
Return the service singleton
- getServices() - Method in class com.netflix.curator.x.discovery.server.entity.ServiceInstances
-
- getServiceType() - Method in class com.netflix.curator.x.discovery.ServiceInstance
-
- getSessionTimeoutMs() - Method in class com.netflix.curator.framework.CuratorFrameworkFactory.Builder
-
- getShardQty() - Method in class com.netflix.curator.framework.recipes.queue.QueueSharder
-
Return the current number of mananged queues
- getSize(ServiceInstance<T>, Class<?>, Type, Annotation[], MediaType) - Method in class com.netflix.curator.x.discovery.server.entity.JsonServiceInstanceMarshaller
-
- getSize(ServiceInstances<T>, Class<?>, Type, Annotation[], MediaType) - Method in class com.netflix.curator.x.discovery.server.entity.JsonServiceInstancesMarshaller
-
- getSize(ServiceNames, Class<?>, Type, Annotation[], MediaType) - Method in class com.netflix.curator.x.discovery.server.entity.JsonServiceNamesMarshaller
-
- getSleepTimeMs(int, long) - Method in class com.netflix.curator.retry.BoundedExponentialBackoffRetry
-
- getSleepTimeMs(int, long) - Method in class com.netflix.curator.retry.ExponentialBackoffRetry
-
- getSleepTimeMs(int, long) - Method in class com.netflix.curator.retry.RetryNTimes
-
- getSleepTimeMs(int, long) - Method in class com.netflix.curator.retry.RetryUntilElapsed
-
- getSortedChildren(CuratorFramework, String, String, LockInternalsSorter) - Static method in class com.netflix.curator.framework.recipes.locks.LockInternals
-
- getSortedChildren(ZooKeeper, String) - Static method in class com.netflix.curator.utils.ZKPaths
-
Return the children of the given path sorted by sequence number
- getSslPort() - Method in class com.netflix.curator.x.discovery.ServiceInstance
-
- getStat() - Method in interface com.netflix.curator.framework.api.CuratorEvent
-
- getStat() - Method in class com.netflix.curator.framework.recipes.cache.ChildData
-
Returns the stat data for this child
- getStats() - Method in interface com.netflix.curator.framework.recipes.atomic.AtomicValue
-
Returns debugging stats about the operation
- getsTheLock(CuratorFramework, List<String>, String, int) - Method in class com.netflix.curator.framework.recipes.locks.StandardLockInternalsDriver
-
- getTempDirectory() - Method in class com.netflix.curator.test.TestingServer
-
Returns the temp directory being used
- getThisInstance() - Method in class discovery.ExampleServer
-
- getThreadFactory() - Method in class com.netflix.curator.framework.CuratorFrameworkFactory.Builder
-
- getTracerDriver() - Method in class com.netflix.curator.CuratorZookeeperClient
-
Return the current tracing driver
- getType() - Method in interface com.netflix.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 com.netflix.curator.framework.api.transaction.CuratorTransactionResult
-
Returns the operation type
- getType() - Method in class com.netflix.curator.framework.recipes.cache.PathChildrenCacheEvent
-
- getUnhandledErrorListenable() - Method in interface com.netflix.curator.framework.CuratorFramework
-
Returns the listenable interface for unhandled errors
- getUnhandledErrorListenable() - Method in class com.netflix.curator.framework.imps.CuratorFrameworkImpl
-
- getUriSpec() - Method in class com.netflix.curator.x.discovery.ServiceInstance
-
- getValue() - Method in class com.netflix.curator.framework.recipes.shared.SharedValue
-
- getValue() - Method in interface com.netflix.curator.framework.recipes.shared.SharedValueReader
-
Return the current value of the count
- getValue() - Method in class com.netflix.curator.x.discovery.UriSpec.Part
-
- getWatchedEvent() - Method in interface com.netflix.curator.framework.api.CuratorEvent
-
- getZooKeeper() - Method in class com.netflix.curator.CuratorZookeeperClient
-
Return the managed ZK instance.
- getZookeeperClient() - Method in interface com.netflix.curator.framework.CuratorFramework
-
Return the managed zookeeper client
- getZookeeperClient() - Method in class com.netflix.curator.framework.imps.CuratorFrameworkImpl
-
- getZookeeperFactory() - Method in class com.netflix.curator.framework.CuratorFrameworkFactory.Builder
-
- getZookeeperState() - Method in class com.netflix.curator.x.zkclientbridge.CuratorZKClientBridge
-
- guaranteed() - Method in interface com.netflix.curator.framework.api.DeleteBuilder
-
Solves this edge case: deleting a node can fail due to connection issues.
- guaranteedDelete(CuratorFramework, String) - Static method in class framework.CrudExamples
-
- GzipCompressionProvider - Class in com.netflix.curator.framework.imps
-
- GzipCompressionProvider() - Constructor for class com.netflix.curator.framework.imps.GzipCompressionProvider
-
- id(String) - Method in class com.netflix.curator.x.discovery.ServiceInstanceBuilder
-
- inBackground() - Method in interface com.netflix.curator.framework.api.Backgroundable
-
Perform the action in the background
- inBackground(Object) - Method in interface com.netflix.curator.framework.api.Backgroundable
-
Perform the action in the background
- inBackground(BackgroundCallback) - Method in interface com.netflix.curator.framework.api.Backgroundable
-
Perform the action in the background
- inBackground(BackgroundCallback, Object) - Method in interface com.netflix.curator.framework.api.Backgroundable
-
Perform the action in the background
- inBackground(BackgroundCallback, Executor) - Method in interface com.netflix.curator.framework.api.Backgroundable
-
Perform the action in the background
- inBackground(BackgroundCallback, Object, Executor) - Method in interface com.netflix.curator.framework.api.Backgroundable
-
Perform the action in the background
- increment() - Method in class com.netflix.curator.framework.recipes.atomic.DistributedAtomicInteger
-
Add 1 to the current value and return the new value information.
- increment() - Method in class com.netflix.curator.framework.recipes.atomic.DistributedAtomicLong
-
Add 1 to the current value and return the new value information.
- increment() - Method in interface com.netflix.curator.framework.recipes.atomic.DistributedAtomicNumber
-
Add 1 to the current value and return the new value information.
- InstanceCleanup - Class in com.netflix.curator.x.discovery.server.rest
-
A background task that purges stale registrations.
- InstanceCleanup(ServiceDiscovery<?>, int) - Constructor for class com.netflix.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
-
- InstanceProvider<T> - Interface in com.netflix.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 com.netflix.curator.x.discovery.details
-
Injectable serializer for service instances
- InstanceSpec - Class in com.netflix.curator.test
-
Abstracts one of the servers in the ensemble
- InstanceSpec(File, int, int, int, boolean, int) - Constructor for class com.netflix.curator.test.InstanceSpec
-
- IntegerDiscoveryContext - Class in com.netflix.curator.x.discovery.server.contexts
-
- IntegerDiscoveryContext(ServiceDiscovery<Integer>, ProviderStrategy<Integer>, int) - Constructor for class com.netflix.curator.x.discovery.server.contexts.IntegerDiscoveryContext
-
- internalSync(CuratorFrameworkImpl, String, Object) - Method in class com.netflix.curator.framework.imps.CuratorFrameworkImpl
-
- InterProcessLock - Interface in com.netflix.curator.framework.recipes.locks
-
- InterProcessMultiLock - Class in com.netflix.curator.framework.recipes.locks
-
A container that manages multiple locks as a single entity.
- InterProcessMultiLock(CuratorFramework, List<String>) - Constructor for class com.netflix.curator.framework.recipes.locks.InterProcessMultiLock
-
- InterProcessMultiLock(List<InterProcessLock>) - Constructor for class com.netflix.curator.framework.recipes.locks.InterProcessMultiLock
-
Creates a multi lock of any type of inter process lock
- InterProcessMutex - Class in com.netflix.curator.framework.recipes.locks
-
A re-entrant mutex that works across JVMs.
- InterProcessMutex(CuratorFramework, String) - Constructor for class com.netflix.curator.framework.recipes.locks.InterProcessMutex
-
- InterProcessReadWriteLock - Class in com.netflix.curator.framework.recipes.locks
-
A re-entrant read/write mutex that works across JVMs.
- InterProcessReadWriteLock(CuratorFramework, String) - Constructor for class com.netflix.curator.framework.recipes.locks.InterProcessReadWriteLock
-
- InterProcessSemaphore - Class in com.netflix.curator.framework.recipes.locks
-
- InterProcessSemaphore(CuratorFramework, String, int) - Constructor for class com.netflix.curator.framework.recipes.locks.InterProcessSemaphore
-
Deprecated.
- InterProcessSemaphore(CuratorFramework, String, SharedCountReader) - Constructor for class com.netflix.curator.framework.recipes.locks.InterProcessSemaphore
-
Deprecated.
- InterProcessSemaphoreMutex - Class in com.netflix.curator.framework.recipes.locks
-
A NON re-entrant mutex that works across JVMs.
- InterProcessSemaphoreMutex(CuratorFramework, String) - Constructor for class com.netflix.curator.framework.recipes.locks.InterProcessSemaphoreMutex
-
- InterProcessSemaphoreV2 - Class in com.netflix.curator.framework.recipes.locks
-
A counting semaphore that works across JVMs.
- InterProcessSemaphoreV2(CuratorFramework, String, int) - Constructor for class com.netflix.curator.framework.recipes.locks.InterProcessSemaphoreV2
-
- InterProcessSemaphoreV2(CuratorFramework, String, SharedCountReader) - Constructor for class com.netflix.curator.framework.recipes.locks.InterProcessSemaphoreV2
-
- inTransaction() - Method in interface com.netflix.curator.framework.CuratorFramework
-
Start a transaction builder
- inTransaction() - Method in class com.netflix.curator.framework.imps.CuratorFrameworkImpl
-
- isAcquiredInThisProcess() - Method in interface com.netflix.curator.framework.recipes.locks.InterProcessLock
-
Returns true if the mutex is acquired by a thread in this JVM
- isAcquiredInThisProcess() - Method in class com.netflix.curator.framework.recipes.locks.InterProcessMultiLock
-
- isAcquiredInThisProcess() - Method in class com.netflix.curator.framework.recipes.locks.InterProcessMutex
-
Returns true if the mutex is acquired by a thread in this JVM
- isAcquiredInThisProcess() - Method in class com.netflix.curator.framework.recipes.locks.InterProcessSemaphoreMutex
-
- isConnected() - Method in class com.netflix.curator.CuratorZookeeperClient
-
Returns true if the client is current connected
- isFromRandom() - Method in class com.netflix.curator.test.QuorumConfigBuilder
-
- isLeader() - Method in class com.netflix.curator.framework.recipes.leader.Participant
-
Returns true if this participant is the current leader
- isReadable(Class<?>, Type, Annotation[], MediaType) - Method in class com.netflix.curator.x.discovery.server.entity.JsonServiceInstanceMarshaller
-
- isReadable(Class<?>, Type, Annotation[], MediaType) - Method in class com.netflix.curator.x.discovery.server.entity.JsonServiceInstancesMarshaller
-
- isReadable(Class<?>, Type, Annotation[], MediaType) - Method in class com.netflix.curator.x.discovery.server.entity.JsonServiceNamesMarshaller
-
- isRetryException(Throwable) - Static method in class com.netflix.curator.RetryLoop
-
Utility - return true if the given exception is retry-able
- isStarted() - Method in interface com.netflix.curator.framework.CuratorFramework
-
Return true if the client is started, not closed, etc.
- isStarted() - Method in class com.netflix.curator.framework.imps.CuratorFrameworkImpl
-
- isVariable() - Method in class com.netflix.curator.x.discovery.UriSpec.Part
-
- isWriteable(Class<?>, Type, Annotation[], MediaType) - Method in class com.netflix.curator.x.discovery.server.entity.JsonServiceInstanceMarshaller
-
- isWriteable(Class<?>, Type, Annotation[], MediaType) - Method in class com.netflix.curator.x.discovery.server.entity.JsonServiceInstancesMarshaller
-
- isWriteable(Class<?>, Type, Annotation[], MediaType) - Method in class com.netflix.curator.x.discovery.server.entity.JsonServiceNamesMarshaller
-
- iterator() - Method in class com.netflix.curator.x.discovery.UriSpec
-
- Participant - Class in com.netflix.curator.framework.recipes.leader
-
Describes a participant in a leadership selection
- Participant(String, boolean) - Constructor for class com.netflix.curator.framework.recipes.leader.Participant
-
- Pathable<T> - Interface in com.netflix.curator.framework.api
-
- PathAndBytesable<T> - Interface in com.netflix.curator.framework.api
-
- PathCacheExample - Class in cache
-
An example of the PathChildrenCache.
- PathCacheExample() - Constructor for class cache.PathCacheExample
-
- PathChildrenCache - Class in com.netflix.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 com.netflix.curator.framework.recipes.cache.PathChildrenCache
-
- PathChildrenCache(CuratorFramework, String, PathChildrenCacheMode, ThreadFactory) - Constructor for class com.netflix.curator.framework.recipes.cache.PathChildrenCache
-
- PathChildrenCache(CuratorFramework, String, boolean) - Constructor for class com.netflix.curator.framework.recipes.cache.PathChildrenCache
-
- PathChildrenCache(CuratorFramework, String, boolean, ThreadFactory) - Constructor for class com.netflix.curator.framework.recipes.cache.PathChildrenCache
-
- PathChildrenCache(CuratorFramework, String, boolean, boolean, ThreadFactory) - Constructor for class com.netflix.curator.framework.recipes.cache.PathChildrenCache
-
- PathChildrenCacheEvent - Class in com.netflix.curator.framework.recipes.cache
-
POJO that abstracts a change to a path
- PathChildrenCacheEvent(PathChildrenCacheEvent.Type, ChildData) - Constructor for class com.netflix.curator.framework.recipes.cache.PathChildrenCacheEvent
-
- PathChildrenCacheEvent.Type - Enum in com.netflix.curator.framework.recipes.cache
-
Type of change
- PathChildrenCacheListener - Interface in com.netflix.curator.framework.recipes.cache
-
Listener for PathChildrenCache changes
- PathChildrenCacheMode - Enum in com.netflix.curator.framework.recipes.cache
-
- payload(T) - Method in class com.netflix.curator.x.discovery.ServiceInstanceBuilder
-
- peek() - Method in class com.netflix.curator.framework.recipes.queue.SimpleDistributedQueue
-
Returns the data at the first element of the queue, or null if the queue is empty.
- poll() - Method in class com.netflix.curator.ensemble.exhibitor.ExhibitorEnsembleProvider
-
- poll(long, TimeUnit) - Method in class com.netflix.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 com.netflix.curator.framework.recipes.queue.SimpleDistributedQueue
-
Attempts to remove the head of the queue and return it.
- pollForInitialEnsemble() - Method in class com.netflix.curator.ensemble.exhibitor.ExhibitorEnsembleProvider
-
Can be called prior to starting the Curator instance to set the current connection string
- port(int) - Method in class com.netflix.curator.x.discovery.ServiceInstanceBuilder
-
- postValue() - Method in interface com.netflix.curator.framework.recipes.atomic.AtomicValue
-
Returns the value of the counter after to the operation
- preValue() - Method in interface com.netflix.curator.framework.recipes.atomic.AtomicValue
-
Returns the value of the counter prior to the operation
- process(WatchedEvent) - Method in interface com.netflix.curator.framework.api.CuratorWatcher
-
Same as Watcher.process(WatchedEvent)
.
- processResult(CuratorFramework, CuratorEvent) - Method in interface com.netflix.curator.framework.api.BackgroundCallback
-
Called when the async background operation completes
- processWithLockSafety(String, DistributedQueue.ProcessType) - Method in class com.netflix.curator.framework.recipes.queue.DistributedQueue
-
- PromotedToLock - Class in com.netflix.curator.framework.recipes.atomic
-
Abstraction of arguments for mutex promotion.
- PromotedToLock.Builder - Class in com.netflix.curator.framework.recipes.atomic
-
- PROPERTY_DONT_LOG_CONNECTION_ISSUES - Static variable in class com.netflix.curator.utils.DebugUtils
-
- PROPERTY_LOG_EVENTS - Static variable in class com.netflix.curator.utils.DebugUtils
-
- ProtectACLCreateModePathAndBytesable<T> - Interface in com.netflix.curator.framework.api
-
- ProviderStrategy<T> - Interface in com.netflix.curator.x.discovery
-
A strategy for picking one from a set of instances
- providerStrategy(ProviderStrategy<T>) - Method in interface com.netflix.curator.x.discovery.ServiceProviderBuilder
-
optional - set the provider strategy.
- put(T, long) - Method in class com.netflix.curator.framework.recipes.queue.DistributedDelayQueue
-
Add an item into the queue.
- put(T, long, int, TimeUnit) - Method in class com.netflix.curator.framework.recipes.queue.DistributedDelayQueue
-
- put(T, String) - Method in class com.netflix.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 com.netflix.curator.framework.recipes.queue.DistributedIdQueue
-
- put(T, int) - Method in class com.netflix.curator.framework.recipes.queue.DistributedPriorityQueue
-
Add an item into the queue.
- put(T, int, int, TimeUnit) - Method in class com.netflix.curator.framework.recipes.queue.DistributedPriorityQueue
-
- put(T) - Method in class com.netflix.curator.framework.recipes.queue.DistributedQueue
-
Add an item into the queue.
- put(T, int, TimeUnit) - Method in class com.netflix.curator.framework.recipes.queue.DistributedQueue
-
- putCompleted(T) - Method in interface com.netflix.curator.framework.recipes.queue.QueuePutListener
-
Notification that a single item put has completed
- putInBackground(boolean) - Method in class com.netflix.curator.framework.recipes.queue.QueueBuilder
-
By default, messages are added in the background.
- putMulti(MultiItem<T>, long) - Method in class com.netflix.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 com.netflix.curator.framework.recipes.queue.DistributedDelayQueue
-
- putMulti(MultiItem<T>, int) - Method in class com.netflix.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 com.netflix.curator.framework.recipes.queue.DistributedPriorityQueue
-
- putMulti(MultiItem<T>) - Method in class com.netflix.curator.framework.recipes.queue.DistributedQueue
-
Add a set of items into the queue.
- putMulti(MultiItem<T>, int, TimeUnit) - Method in class com.netflix.curator.framework.recipes.queue.DistributedQueue
-
- putMultiCompleted(MultiItem<T>) - Method in interface com.netflix.curator.framework.recipes.queue.QueuePutListener
-
Notification that a multi item put has completed
- putService(ServiceInstance<T>, String, String) - Method in class com.netflix.curator.x.discovery.server.rest.DiscoveryResource
-
- RandomStrategy<T> - Class in com.netflix.curator.x.discovery.strategies
-
This strategy always picks a random instance from the list
- RandomStrategy() - Constructor for class com.netflix.curator.x.discovery.strategies.RandomStrategy
-
- readData(String, Stat, boolean) - Method in class com.netflix.curator.x.zkclientbridge.CuratorZKClientBridge
-
- readFrom(Class<ServiceInstance<T>>, Type, Annotation[], MediaType, MultivaluedMap<String, String>, InputStream) - Method in class com.netflix.curator.x.discovery.server.entity.JsonServiceInstanceMarshaller
-
- readFrom(Class<ServiceInstances<T>>, Type, Annotation[], MediaType, MultivaluedMap<String, String>, InputStream) - Method in class com.netflix.curator.x.discovery.server.entity.JsonServiceInstancesMarshaller
-
- readFrom(Class<ServiceNames>, Type, Annotation[], MediaType, MultivaluedMap<String, String>, InputStream) - Method in class com.netflix.curator.x.discovery.server.entity.JsonServiceNamesMarshaller
-
- readLock() - Method in class com.netflix.curator.framework.recipes.locks.InterProcessReadWriteLock
-
Returns the lock used for reading.
- Reaper - Class in com.netflix.curator.framework.recipes.locks
-
Utility to clean up parent lock nodes so that they don't stay around as garbage
- Reaper(CuratorFramework) - Constructor for class com.netflix.curator.framework.recipes.locks.Reaper
-
Uses the default reaping threshold of 5 minutes and creates an internal thread pool
- Reaper(CuratorFramework, int) - Constructor for class com.netflix.curator.framework.recipes.locks.Reaper
-
Uses the given reaping threshold and creates an internal thread pool
- Reaper(CuratorFramework, ScheduledExecutorService, int) - Constructor for class com.netflix.curator.framework.recipes.locks.Reaper
-
- Reaper.Mode - Enum in com.netflix.curator.framework.recipes.locks
-
- rebuild() - Method in class com.netflix.curator.framework.recipes.cache.PathChildrenCache
-
NOTE: this is a BLOCKING method.
- refreshPaddingMs(int) - Method in interface com.netflix.curator.x.discovery.ServiceCacheBuilder
-
To avoid herding in noisy scenarios, the cache should be padded to only update 1 per period.
- refreshPaddingMs(int) - Method in interface com.netflix.curator.x.discovery.ServiceProviderBuilder
-
optional To avoid herding in noisy scenarios, the cache should be padded to only update 1 per period.
- registerService(ServiceInstance<T>) - Method in class com.netflix.curator.x.discovery.details.ServiceDiscoveryImpl
-
Register/re-register/update a service instance
- registerService(ServiceInstance<T>) - Method in interface com.netflix.curator.x.discovery.ServiceDiscovery
-
Register/re-register/update a service instance
- registrationTimeUTC(long) - Method in class com.netflix.curator.x.discovery.ServiceInstanceBuilder
-
- release() - Method in interface com.netflix.curator.framework.recipes.locks.InterProcessLock
-
Perform one release of the mutex if the calling thread is the same thread that acquired it.
- release() - Method in class com.netflix.curator.framework.recipes.locks.InterProcessMultiLock
-
Perform one release of the mutex if the calling thread is the same thread that acquired it.
- release() - Method in class com.netflix.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 com.netflix.curator.framework.recipes.locks.InterProcessSemaphoreMutex
-
- remove(String) - Method in class com.netflix.curator.framework.recipes.queue.DistributedIdQueue
-
Remove any items with the given Id
- remove() - Method in class com.netflix.curator.framework.recipes.queue.SimpleDistributedQueue
-
Attempts to remove the head of the queue and return it.
- remove(UriSpec.Part) - Method in class com.netflix.curator.x.discovery.UriSpec
-
Remove the given part
- removeBarrier() - Method in class com.netflix.curator.framework.recipes.barriers.DistributedBarrier
-
Utility to remove the barrier node
- removeListener(T) - Method in interface com.netflix.curator.framework.listen.Listenable
-
Remove the given listener
- removeListener(T) - Method in class com.netflix.curator.framework.listen.ListenerContainer
-
- removeListener(SharedCountListener) - Method in class com.netflix.curator.framework.recipes.shared.SharedCount
-
- removeListener(ServiceCacheListener) - Method in class com.netflix.curator.x.discovery.details.ServiceCacheImpl
-
- removePath(String) - Method in class com.netflix.curator.framework.recipes.locks.Reaper
-
Stop reaping the given path
- removeService(String, String) - Method in class com.netflix.curator.x.discovery.server.rest.DiscoveryResource
-
- requeue() - Method in class com.netflix.curator.framework.recipes.leader.LeaderSelector
-
Re-queue an attempt for leadership.
- restart() - Method in class com.netflix.curator.test.TestingZooKeeperServer
-
- restartServer(InstanceSpec) - Method in class com.netflix.curator.test.TestingCluster
-
Restart the given server of the cluster
- RetryLoop - Class in com.netflix.curator
-
Mechanism to perform an operation on Zookeeper that is safe against
disconnections and "recoverable" errors.
- RetryNTimes - Class in com.netflix.curator.retry
-
Retry policy that retries a max number of times
- RetryNTimes(int, int) - Constructor for class com.netflix.curator.retry.RetryNTimes
-
- RetryOneTime - Class in com.netflix.curator.retry
-
A retry policy that retries only once
- RetryOneTime(int) - Constructor for class com.netflix.curator.retry.RetryOneTime
-
- retryPolicy(RetryPolicy) - Method in class com.netflix.curator.framework.CuratorFrameworkFactory.Builder
-
- retryPolicy(RetryPolicy) - Method in class com.netflix.curator.framework.recipes.atomic.PromotedToLock.Builder
-
Set the retry policy to use when an operation does not succeed
- RetryPolicy - Interface in com.netflix.curator
-
Abstracts the policy to use when retrying connections
- RetrySleeper - Interface in com.netflix.curator
-
Abstraction for retry policies to sleep
- RetryUntilElapsed - Class in com.netflix.curator.retry
-
A retry policy that retries until a given amount of time elapses
- RetryUntilElapsed(int, int) - Constructor for class com.netflix.curator.retry.RetryUntilElapsed
-
- returnAll(Collection<Lease>) - Method in class com.netflix.curator.framework.recipes.locks.InterProcessSemaphore
-
Deprecated.
Convenience method.
- returnAll(Collection<Lease>) - Method in class com.netflix.curator.framework.recipes.locks.InterProcessSemaphoreV2
-
Convenience method.
- returnLease(Lease) - Method in class com.netflix.curator.framework.recipes.locks.InterProcessSemaphore
-
Deprecated.
Convenience method.
- returnLease(Lease) - Method in class com.netflix.curator.framework.recipes.locks.InterProcessSemaphoreV2
-
Convenience method.
- Revocable<T> - Interface in com.netflix.curator.framework.recipes.locks
-
Specifies locks that can be revoked
- RevocationListener<T> - Interface in com.netflix.curator.framework.recipes.locks
-
- revocationRequested(T) - Method in interface com.netflix.curator.framework.recipes.locks.RevocationListener
-
Called when a revocation request has been received.
- Revoker - Class in com.netflix.curator.framework.recipes.locks
-
- RoundRobinStrategy<T> - Class in com.netflix.curator.x.discovery.strategies
-
This strategy rotates sequentially through the list of instances
- RoundRobinStrategy() - Constructor for class com.netflix.curator.x.discovery.strategies.RoundRobinStrategy
-
- runFromConfig(QuorumPeerConfig) - Method in class com.netflix.curator.test.TestingZooKeeperMain
-
- runFromConfig(QuorumPeerConfig) - Method in interface com.netflix.curator.test.ZooKeeperMainFace
-
- seconds() - Method in class com.netflix.curator.test.Timing
-
Return the base time in seconds
- serialize(T) - Method in interface com.netflix.curator.framework.recipes.queue.QueueSerializer
-
Turn a queue item into bytes
- serialize(ServiceInstance<T>) - Method in interface com.netflix.curator.x.discovery.details.InstanceSerializer
-
Serialize an instance into bytes
- serialize(ServiceInstance<T>) - Method in class com.netflix.curator.x.discovery.details.JsonInstanceSerializer
-
- serializer(InstanceSerializer<T>) - Method in class com.netflix.curator.x.discovery.ServiceDiscoveryBuilder
-
- ServiceCache<T> - Interface in com.netflix.curator.x.discovery
-
- serviceCacheBuilder() - Method in class com.netflix.curator.x.discovery.details.ServiceDiscoveryImpl
-
Allocate a new service cache builder.
- ServiceCacheBuilder<T> - Interface in com.netflix.curator.x.discovery
-
- serviceCacheBuilder() - Method in interface com.netflix.curator.x.discovery.ServiceDiscovery
-
Allocate a new service cache builder.
- ServiceCacheImpl<T> - Class in com.netflix.curator.x.discovery.details
-
- ServiceCacheListener - Interface in com.netflix.curator.x.discovery.details
-
Listener for changes to a service cache
- ServiceDiscovery<T> - Interface in com.netflix.curator.x.discovery
-
- ServiceDiscoveryBuilder<T> - Class in com.netflix.curator.x.discovery
-
- ServiceDiscoveryImpl<T> - Class in com.netflix.curator.x.discovery.details
-
A mechanism to register and query service instances using ZooKeeper
- ServiceDiscoveryImpl(CuratorFramework, String, InstanceSerializer<T>, ServiceInstance<T>) - Constructor for class com.netflix.curator.x.discovery.details.ServiceDiscoveryImpl
-
- ServiceInstance<T> - Class in com.netflix.curator.x.discovery
-
POJO that represents a service instance
- ServiceInstanceBuilder<T> - Class in com.netflix.curator.x.discovery
-
Builder for service instances
- ServiceInstances<T> - Class in com.netflix.curator.x.discovery.server.entity
-
Raw generic lists don't work well in JAX-RS.
- ServiceInstances() - Constructor for class com.netflix.curator.x.discovery.server.entity.ServiceInstances
-
- ServiceInstances(Collection<? extends ServiceInstance<T>>) - Constructor for class com.netflix.curator.x.discovery.server.entity.ServiceInstances
-
- serviceName(String) - Method in interface com.netflix.curator.x.discovery.ServiceProviderBuilder
-
required - set the name of the service to be provided
- ServiceNames - Class in com.netflix.curator.x.discovery.server.entity
-
Raw generic lists don't work well in JAX-RS.
- ServiceNames() - Constructor for class com.netflix.curator.x.discovery.server.entity.ServiceNames
-
- ServiceNames(Collection<? extends String>) - Constructor for class com.netflix.curator.x.discovery.server.entity.ServiceNames
-
- ServiceProvider<T> - Interface in com.netflix.curator.x.discovery
-
The main API for Discovery.
- serviceProviderBuilder() - Method in class com.netflix.curator.x.discovery.details.ServiceDiscoveryImpl
-
Allocate a new builder.
- serviceProviderBuilder() - Method in interface com.netflix.curator.x.discovery.ServiceDiscovery
-
Allocate a new builder.
- ServiceProviderBuilder<T> - Interface in com.netflix.curator.x.discovery
-
- ServiceProviderImpl<T> - Class in com.netflix.curator.x.discovery.details
-
The main interface for Service Discovery.
- ServiceProviderImpl(ServiceDiscoveryImpl<T>, String, ProviderStrategy<T>, ThreadFactory, int) - Constructor for class com.netflix.curator.x.discovery.details.ServiceProviderImpl
-
- serviceType(ServiceType) - Method in class com.netflix.curator.x.discovery.ServiceInstanceBuilder
-
- ServiceType - Enum in com.netflix.curator.x.discovery
-
- session() - Method in class com.netflix.curator.test.Timing
-
Return the value to use for ZK session timeout
- SessionFailRetryLoop - Class in com.netflix.curator
-
See
RetryLoop
for the main details on retry loops.
- SessionFailRetryLoop.Mode - Enum in com.netflix.curator
-
- SessionFailRetryLoop.SessionFailedException - Exception in com.netflix.curator
-
- SessionFailRetryLoop.SessionFailedException() - Constructor for exception com.netflix.curator.SessionFailRetryLoop.SessionFailedException
-
- sessionTimeoutMs(int) - Method in class com.netflix.curator.framework.CuratorFrameworkFactory.Builder
-
- setACL() - Method in interface com.netflix.curator.framework.CuratorFramework
-
Start a set ACL builder
- setACL() - Method in class com.netflix.curator.framework.imps.CuratorFrameworkImpl
-
- SetACLBuilder - Interface in com.netflix.curator.framework.api
-
- setBarrier() - Method in class com.netflix.curator.framework.recipes.barriers.DistributedBarrier
-
Utility to set the barrier node
- setCount(int) - Method in class com.netflix.curator.framework.recipes.shared.SharedCount
-
Change the shared count value irrespective of its previous state
- setData() - Method in interface com.netflix.curator.framework.api.transaction.CuratorTransaction
-
Start a setData builder in the transaction
- setData() - Method in interface com.netflix.curator.framework.CuratorFramework
-
Start a set data builder
- setData() - Method in class com.netflix.curator.framework.imps.CuratorFrameworkImpl
-
- setData(CuratorFramework, String, byte[]) - Static method in class framework.CrudExamples
-
- setDataAsync(CuratorFramework, String, byte[]) - Static method in class framework.CrudExamples
-
- setDataAsyncWithCallback(CuratorFramework, BackgroundCallback, String, byte[]) - Static method in class framework.CrudExamples
-
- SetDataBackgroundVersionable - Interface in com.netflix.curator.framework.api
-
- SetDataBuilder - Interface in com.netflix.curator.framework.api
-
- setDescription(String) - Method in class discovery.InstanceDetails
-
- setErrorMode(ErrorMode) - Method in class com.netflix.curator.framework.recipes.queue.DistributedDelayQueue
-
- setErrorMode(ErrorMode) - Method in class com.netflix.curator.framework.recipes.queue.DistributedIdQueue
-
- setErrorMode(ErrorMode) - Method in class com.netflix.curator.framework.recipes.queue.DistributedPriorityQueue
-
- setErrorMode(ErrorMode) - Method in class com.netflix.curator.framework.recipes.queue.DistributedQueue
-
- setErrorMode(ErrorMode) - Method in interface com.netflix.curator.framework.recipes.queue.QueueBase
-
- setExhibitors(Exhibitors) - Method in class com.netflix.curator.ensemble.exhibitor.ExhibitorEnsembleProvider
-
Change the set of exhibitors to poll
- setId(String) - Method in class com.netflix.curator.framework.recipes.leader.LeaderSelector
-
Sets the ID to store for this leader.
- setRetryPolicy(RetryPolicy) - Method in class com.netflix.curator.CuratorZookeeperClient
-
Change the retry policy
- setTracerDriver(TracerDriver) - Method in class com.netflix.curator.CuratorZookeeperClient
-
Change the tracing driver
- setValue(byte[]) - Method in class com.netflix.curator.framework.recipes.shared.SharedValue
-
Change the shared value value irrespective of its previous state
- SharedCount - Class in com.netflix.curator.framework.recipes.shared
-
Manages a shared integer.
- SharedCount(CuratorFramework, String, int) - Constructor for class com.netflix.curator.framework.recipes.shared.SharedCount
-
- SharedCountListener - Interface in com.netflix.curator.framework.recipes.shared
-
Listener for changes to a shared count
- SharedCountReader - Interface in com.netflix.curator.framework.recipes.shared
-
Abstracts a shared integer and allows listening for changes to its value
- SharedValue - Class in com.netflix.curator.framework.recipes.shared
-
Manages a shared value.
- SharedValue(CuratorFramework, String, byte[]) - Constructor for class com.netflix.curator.framework.recipes.shared.SharedValue
-
- SharedValueListener - Interface in com.netflix.curator.framework.recipes.shared
-
Listener for changes to a shared value
- SharedValueReader - Interface in com.netflix.curator.framework.recipes.shared
-
Abstracts a shared value and allows listening for changes to the value
- shouldContinue() - Method in class com.netflix.curator.RetryLoop
-
If true is returned, make an attempt at the operation
- shouldContinue() - Method in class com.netflix.curator.SessionFailRetryLoop
-
If true is returned, make an attempt at the set of operations
- shouldRetry(int) - Static method in class com.netflix.curator.RetryLoop
-
Utility - return true if the given Zookeeper result code is retry-able
- SimpleDistributedQueue - Class in com.netflix.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 com.netflix.curator.framework.recipes.queue.SimpleDistributedQueue
-
- size() - Method in class com.netflix.curator.framework.listen.ListenerContainer
-
Return the number of listeners
- size() - Method in class com.netflix.curator.framework.recipes.queue.BlockingQueueConsumer
-
Returns the number of currently queue items
- size() - Method in class com.netflix.curator.test.QuorumConfigBuilder
-
- sleepABit() - Method in class com.netflix.curator.test.Timing
-
Sleep for a small amount of time
- sleepFor(long, TimeUnit) - Method in interface com.netflix.curator.RetrySleeper
-
Sleep for the given time
- sortChildren(List<String>) - Method in class com.netflix.curator.framework.recipes.queue.DistributedQueue
-
- sslPort(int) - Method in class com.netflix.curator.x.discovery.ServiceInstanceBuilder
-
- standardFixForSorting(String, String) - Static method in class com.netflix.curator.framework.recipes.locks.StandardLockInternalsDriver
-
- StandardLockInternalsDriver - Class in com.netflix.curator.framework.recipes.locks
-
- StandardLockInternalsDriver() - Constructor for class com.netflix.curator.framework.recipes.locks.StandardLockInternalsDriver
-
- start() - Method in class com.netflix.curator.CuratorZookeeperClient
-
Must be called after construction
- start() - Method in interface com.netflix.curator.ensemble.EnsembleProvider
-
- start() - Method in class com.netflix.curator.ensemble.exhibitor.ExhibitorEnsembleProvider
-
- start() - Method in class com.netflix.curator.ensemble.fixed.FixedEnsembleProvider
-
- start() - Method in interface com.netflix.curator.framework.CuratorFramework
-
Start the client.
- start() - Method in class com.netflix.curator.framework.imps.CuratorFrameworkImpl
-
- start() - Method in class com.netflix.curator.framework.recipes.cache.PathChildrenCache
-
Start the cache.
- start(boolean) - Method in class com.netflix.curator.framework.recipes.cache.PathChildrenCache
-
- start() - Method in class com.netflix.curator.framework.recipes.leader.LeaderLatch
-
Add this instance to the leadership election and attempt to acquire leadership.
- start() - Method in class com.netflix.curator.framework.recipes.leader.LeaderSelector
-
Attempt leadership.
- start() - Method in class com.netflix.curator.framework.recipes.locks.ChildReaper
-
The reaper must be started
- start() - Method in class com.netflix.curator.framework.recipes.locks.Reaper
-
The reaper must be started
- start() - Method in class com.netflix.curator.framework.recipes.queue.DistributedDelayQueue
-
Start the queue.
- start() - Method in class com.netflix.curator.framework.recipes.queue.DistributedIdQueue
-
- start() - Method in class com.netflix.curator.framework.recipes.queue.DistributedPriorityQueue
-
Start the queue.
- start() - Method in class com.netflix.curator.framework.recipes.queue.DistributedQueue
-
Start the queue.
- start() - Method in interface com.netflix.curator.framework.recipes.queue.QueueBase
-
Start the queue.
- start() - Method in class com.netflix.curator.framework.recipes.queue.QueueSharder
-
The sharder must be started
- start() - Method in class com.netflix.curator.framework.recipes.shared.SharedCount
-
The shared count must be started before it can be used.
- start() - Method in class com.netflix.curator.framework.recipes.shared.SharedValue
-
The shared value must be started before it can be used.
- start() - Method in class com.netflix.curator.framework.state.ConnectionStateManager
-
Start the manager
- start() - Method in class com.netflix.curator.SessionFailRetryLoop
-
SessionFailRetryLoop must be started
- start() - Method in class com.netflix.curator.test.TestingCluster
-
Start the ensemble.
- start() - Method in class com.netflix.curator.test.TestingZooKeeperServer
-
- start() - Method in class com.netflix.curator.x.discovery.details.ServiceCacheImpl
-
- start() - Method in class com.netflix.curator.x.discovery.details.ServiceDiscoveryImpl
-
The discovery must be started before use
- start() - Method in class com.netflix.curator.x.discovery.details.ServiceProviderImpl
-
The provider must be started before use
- start() - Method in class com.netflix.curator.x.discovery.server.rest.InstanceCleanup
-
Start the task
- start() - Method in interface com.netflix.curator.x.discovery.ServiceCache
-
The cache must be started before use
- start() - Method in interface com.netflix.curator.x.discovery.ServiceDiscovery
-
The discovery must be started before use
- start() - Method in interface com.netflix.curator.x.discovery.ServiceProvider
-
The provider must be started before use
- start() - Method in class discovery.ExampleServer
-
- start() - Method in class leader.ExampleClient
-
- startTracer(String) - Method in class com.netflix.curator.CuratorZookeeperClient
-
Start a new tracer
- Statable<T> - Interface in com.netflix.curator.framework.api
-
- stateChanged(CuratorFramework, ConnectionState) - Method in class com.netflix.curator.framework.recipes.queue.BlockingQueueConsumer
-
- stateChanged(CuratorFramework, ConnectionState) - Method in interface com.netflix.curator.framework.state.ConnectionStateListener
-
Called when there is a state change in the connection
- stateChanged(CuratorFramework, ConnectionState) - Method in class leader.ExampleClient
-
- StickyStrategy<T> - Class in com.netflix.curator.x.discovery.strategies
-
This strategy uses a master strategy to pick the initial instance.
- StickyStrategy(ProviderStrategy<T>) - Constructor for class com.netflix.curator.x.discovery.strategies.StickyStrategy
-
- stop() - Method in class com.netflix.curator.test.TestingCluster
-
Shutdown the ensemble WITHOUT freeing resources, etc.
- stop() - Method in class com.netflix.curator.test.TestingServer
-
Stop the server without deleting the temp directory
- stop() - Method in class com.netflix.curator.test.TestingZooKeeperServer
-
- storingStatIn(Stat) - Method in interface com.netflix.curator.framework.api.Statable
-
Have the operation fill the provided stat object
- StringDiscoveryContext - Class in com.netflix.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 com.netflix.curator.x.discovery.server.contexts.StringDiscoveryContext
-
- subtract(Integer) - Method in class com.netflix.curator.framework.recipes.atomic.DistributedAtomicInteger
-
Subtract delta from the current value and return the new value information.
- subtract(Long) - Method in class com.netflix.curator.framework.recipes.atomic.DistributedAtomicLong
-
Subtract delta from the current value and return the new value information.
- subtract(T) - Method in interface com.netflix.curator.framework.recipes.atomic.DistributedAtomicNumber
-
Subtract delta from the current value and return the new value information.
- succeeded() - Method in interface com.netflix.curator.framework.recipes.atomic.AtomicValue
-
MUST be checked. Returns true if the operation succeeded.
- sync(String, Object) - Method in interface com.netflix.curator.framework.CuratorFramework
-
Perform a sync on the given path - syncs are always in the background
- sync(String, Object) - Method in class com.netflix.curator.framework.imps.CuratorFrameworkImpl
-
- take() - Method in class com.netflix.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 com.netflix.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 com.netflix.curator.framework.recipes.queue.SimpleDistributedQueue
-
Removes the head of the queue and returns it, blocks until it succeeds.
- takeException(Exception) - Method in class com.netflix.curator.RetryLoop
-
Pass any caught exceptions here
- takeException(Exception) - Method in class com.netflix.curator.SessionFailRetryLoop
-
Pass any caught exceptions here
- takeLeadership(CuratorFramework) - Method in interface com.netflix.curator.framework.recipes.leader.LeaderSelectorListener
-
Called when your instance has been granted leadership.
- takeLeadership(CuratorFramework) - Method in class leader.ExampleClient
-
- TestingCluster - Class in com.netflix.curator.test
-
manages an internally running ensemble of ZooKeeper servers.
- TestingCluster(int) - Constructor for class com.netflix.curator.test.TestingCluster
-
Creates an ensemble comprised of n
servers.
- TestingCluster(InstanceSpec...) - Constructor for class com.netflix.curator.test.TestingCluster
-
Creates an ensemble using the given server specs
- TestingCluster(Collection<InstanceSpec>) - Constructor for class com.netflix.curator.test.TestingCluster
-
Creates an ensemble using the given server specs
- TestingServer - Class in com.netflix.curator.test
-
manages an internally running ZooKeeper server.
- TestingServer() - Constructor for class com.netflix.curator.test.TestingServer
-
Create the server using a random port
- TestingServer(int) - Constructor for class com.netflix.curator.test.TestingServer
-
Create the server using the given port
- TestingServer(int, File) - Constructor for class com.netflix.curator.test.TestingServer
-
Create the server using the given port
- TestingServer(InstanceSpec) - Constructor for class com.netflix.curator.test.TestingServer
-
- TestingZooKeeperMain - Class in com.netflix.curator.test
-
- TestingZooKeeperMain() - Constructor for class com.netflix.curator.test.TestingZooKeeperMain
-
- TestingZooKeeperServer - Class in com.netflix.curator.test
-
Thanks to Jeremie BORDIER (ahfeel) for this code
- TestingZooKeeperServer(QuorumConfigBuilder) - Constructor for class com.netflix.curator.test.TestingZooKeeperServer
-
- TestingZooKeeperServer(QuorumConfigBuilder, int) - Constructor for class com.netflix.curator.test.TestingZooKeeperServer
-
- thisInstance(ServiceInstance<T>) - Method in class com.netflix.curator.x.discovery.ServiceDiscoveryBuilder
-
Optional - instance that represents the service that is running.
- threadFactory(ThreadFactory) - Method in class com.netflix.curator.framework.CuratorFrameworkFactory.Builder
-
- threadFactory(ThreadFactory) - Method in class com.netflix.curator.framework.recipes.queue.QueueBuilder
-
Change the thread factory used.
- threadFactory(ThreadFactory) - Method in class com.netflix.curator.framework.recipes.queue.QueueSharderPolicies.Builder
-
Change the thread factory that's used to create the sharder's thread
- threadFactory(ThreadFactory) - Method in interface com.netflix.curator.x.discovery.ServiceCacheBuilder
-
Optional thread factory to use for the cache's internal thread
- threadFactory(ThreadFactory) - Method in interface com.netflix.curator.x.discovery.ServiceProviderBuilder
-
optional - the thread factory to use for creating internal threads
- ThreadUtils - Class in com.netflix.curator.utils
-
- ThreadUtils() - Constructor for class com.netflix.curator.utils.ThreadUtils
-
- thresholdCheckMs(int) - Method in class com.netflix.curator.framework.recipes.queue.QueueSharderPolicies.Builder
-
Change the threshold check.
- timeout(long, TimeUnit) - Method in class com.netflix.curator.framework.recipes.atomic.PromotedToLock.Builder
-
Set the timeout to use when locking (optional)
- TimeTrace - Class in com.netflix.curator
-
Utility to time a method or portion of code
- TimeTrace(String, TracerDriver) - Constructor for class com.netflix.curator.TimeTrace
-
Create and start a timer
- Timing - Class in com.netflix.curator.test
-
Utility to get various testing times
- Timing() - Constructor for class com.netflix.curator.test.Timing
-
Use the default base time
- Timing(double) - Constructor for class com.netflix.curator.test.Timing
-
Use a multiple of the default base time
- Timing(long, TimeUnit) - Constructor for class com.netflix.curator.test.Timing
-
- toString() - Method in class com.netflix.curator.framework.recipes.cache.ChildData
-
- toString() - Method in class com.netflix.curator.framework.recipes.cache.PathChildrenCacheEvent
-
- toString() - Method in class com.netflix.curator.framework.recipes.leader.Participant
-
- toString() - Method in class com.netflix.curator.test.InstanceSpec
-
- toString() - Method in class com.netflix.curator.x.discovery.ServiceInstance
-
- TracerDriver - Interface in com.netflix.curator.drivers
-
Mechanism for timing methods and recording counters
- transaction(CuratorFramework) - Static method in class framework.TransactionExamples
-
- TransactionCheckBuilder - Interface in com.netflix.curator.framework.api.transaction
-
- TransactionCreateBuilder - Interface in com.netflix.curator.framework.api.transaction
-
- TransactionDeleteBuilder - Interface in com.netflix.curator.framework.api.transaction
-
- TransactionExamples - Class in framework
-
- TransactionExamples() - Constructor for class framework.TransactionExamples
-
- TransactionSetDataBuilder - Interface in com.netflix.curator.framework.api.transaction
-
- tryRemove(String) - Method in class com.netflix.curator.framework.recipes.queue.DistributedQueue
-
- trySet(Integer) - Method in class com.netflix.curator.framework.recipes.atomic.DistributedAtomicInteger
-
- trySet(Long) - Method in class com.netflix.curator.framework.recipes.atomic.DistributedAtomicLong
-
- trySet(T) - Method in interface com.netflix.curator.framework.recipes.atomic.DistributedAtomicNumber
-
Attempt to atomically set the value to the given value.
- trySet(byte[]) - Method in class com.netflix.curator.framework.recipes.atomic.DistributedAtomicValue
-
Attempt to atomically set the value to the given value.
- trySetCount(int) - Method in class com.netflix.curator.framework.recipes.shared.SharedCount
-
Changes the shared count only if its value has not changed since this client last
read it.
- trySetValue(byte[]) - Method in class com.netflix.curator.framework.recipes.shared.SharedValue
-
Changes the shared value only if its value has not changed since this client last
read it.
- valueHasChanged(SharedValueReader, byte[]) - Method in interface com.netflix.curator.framework.recipes.shared.SharedValueListener
-
Called when the shared value has changed
- valueOf(String) - Static method in enum com.netflix.curator.framework.api.CuratorEventType
-
Returns the enum constant of this type with the specified name.
- valueOf(String) - Static method in enum com.netflix.curator.framework.api.transaction.OperationType
-
Returns the enum constant of this type with the specified name.
- valueOf(String) - Static method in enum com.netflix.curator.framework.recipes.cache.PathChildrenCacheEvent.Type
-
Returns the enum constant of this type with the specified name.
- valueOf(String) - Static method in enum com.netflix.curator.framework.recipes.cache.PathChildrenCacheMode
-
Deprecated.
Returns the enum constant of this type with the specified name.
- valueOf(String) - Static method in enum com.netflix.curator.framework.recipes.locks.Reaper.Mode
-
Returns the enum constant of this type with the specified name.
- valueOf(String) - Static method in enum com.netflix.curator.framework.recipes.queue.DistributedQueue.ProcessType
-
Returns the enum constant of this type with the specified name.
- valueOf(String) - Static method in enum com.netflix.curator.framework.recipes.queue.ErrorMode
-
Returns the enum constant of this type with the specified name.
- valueOf(String) - Static method in enum com.netflix.curator.framework.state.ConnectionState
-
Returns the enum constant of this type with the specified name.
- valueOf(String) - Static method in enum com.netflix.curator.SessionFailRetryLoop.Mode
-
Returns the enum constant of this type with the specified name.
- valueOf(String) - Static method in enum com.netflix.curator.x.discovery.ServiceType
-
Returns the enum constant of this type with the specified name.
- values() - Static method in enum com.netflix.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 com.netflix.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 com.netflix.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 com.netflix.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 com.netflix.curator.framework.recipes.locks.Reaper.Mode
-
Returns an array containing the constants of this enum type, in
the order they are declared.
- values() - Static method in enum com.netflix.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 com.netflix.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 com.netflix.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 com.netflix.curator.SessionFailRetryLoop.Mode
-
Returns an array containing the constants of this enum type, in
the order they are declared.
- values() - Static method in enum com.netflix.curator.x.discovery.ServiceType
-
Returns an array containing the constants of this enum type, in
the order they are declared.
- Versionable<T> - Interface in com.netflix.curator.framework.api
-