Constructor and Description |
---|
ExampleServer(CuratorFramework client,
String path,
String serviceName,
String description) |
Modifier and Type | Method and Description |
---|---|
static CuratorFramework |
CreateClientExamples.createSimple(String connectionString) |
static CuratorFramework |
CreateClientExamples.createWithOptions(String connectionString,
RetryPolicy retryPolicy,
int connectionTimeoutMs,
int sessionTimeoutMs) |
Modifier and Type | Method and Description |
---|---|
static void |
CrudExamples.create(CuratorFramework client,
String path,
byte[] payload) |
static void |
CrudExamples.createEphemeral(CuratorFramework client,
String path,
byte[] payload) |
static String |
CrudExamples.createEphemeralSequential(CuratorFramework client,
String path,
byte[] payload) |
static void |
CrudExamples.delete(CuratorFramework client,
String path) |
static void |
CrudExamples.guaranteedDelete(CuratorFramework client,
String path) |
static void |
CrudExamples.setData(CuratorFramework client,
String path,
byte[] payload) |
static void |
CrudExamples.setDataAsync(CuratorFramework client,
String path,
byte[] payload) |
static void |
CrudExamples.setDataAsyncWithCallback(CuratorFramework client,
BackgroundCallback callback,
String path,
byte[] payload) |
static CuratorTransaction |
TransactionExamples.startTransaction(CuratorFramework client) |
static Collection<CuratorTransactionResult> |
TransactionExamples.transaction(CuratorFramework client) |
static List<String> |
CrudExamples.watchedGetChildren(CuratorFramework client,
String path) |
static List<String> |
CrudExamples.watchedGetChildren(CuratorFramework client,
String path,
org.apache.zookeeper.Watcher watcher) |
Modifier and Type | Method and Description |
---|---|
void |
ExampleClient.takeLeadership(CuratorFramework client) |
Constructor and Description |
---|
ExampleClient(CuratorFramework client,
String path,
String name) |
Constructor and Description |
---|
ExampleClientThatLocks(CuratorFramework client,
String lockPath,
FakeLimitedResource resource,
String clientName) |
Modifier and Type | Method and Description |
---|---|
CuratorFramework |
CuratorFrameworkFactory.Builder.build()
Apply the current values and build a new CuratorFramework
|
static CuratorFramework |
CuratorFrameworkFactory.newClient(String connectString,
int sessionTimeoutMs,
int connectionTimeoutMs,
RetryPolicy retryPolicy)
Create a new client
|
static CuratorFramework |
CuratorFrameworkFactory.newClient(String connectString,
RetryPolicy retryPolicy)
Create a new client with default session timeout and default connection timeout
|
CuratorFramework |
CuratorFramework.nonNamespaceView()
Deprecated.
Since 2.9.0 - use
usingNamespace(java.lang.String) passing null |
CuratorFramework |
CuratorFramework.usingNamespace(String newNamespace)
Returns a facade of the current instance that uses the specified namespace
or no namespace if
newNamespace is null . |
Constructor and Description |
---|
EnsureContainers(CuratorFramework client,
String path) |
Modifier and Type | Method and Description |
---|---|
void |
CuratorListener.eventReceived(CuratorFramework client,
CuratorEvent event)
Called when a background task has completed or a watch has triggered
|
void |
BackgroundCallback.processResult(CuratorFramework client,
CuratorEvent event)
Called when the async background operation completes
|
Modifier and Type | Class and Description |
---|---|
class |
CuratorFrameworkImpl |
Modifier and Type | Method and Description |
---|---|
CuratorFramework |
CuratorFrameworkImpl.nonNamespaceView()
Deprecated.
|
CuratorFramework |
CuratorFrameworkImpl.usingNamespace(String newNamespace) |
Modifier and Type | Method and Description |
---|---|
static Future<?> |
AfterConnectionEstablished.execute(CuratorFramework client,
Runnable runAfterConnection)
Spawns a new new background thread that will block until a connection is available and
then execute the 'runAfterConnection' logic
|
Constructor and Description |
---|
DistributedAtomicInteger(CuratorFramework client,
String counterPath,
RetryPolicy retryPolicy)
Creates in optimistic mode only - i.e.
|
DistributedAtomicInteger(CuratorFramework client,
String counterPath,
RetryPolicy retryPolicy,
PromotedToLock promotedToLock)
Creates in mutex promotion mode.
|
DistributedAtomicLong(CuratorFramework client,
String counterPath,
RetryPolicy retryPolicy)
Creates in optimistic mode only - i.e.
|
DistributedAtomicLong(CuratorFramework client,
String counterPath,
RetryPolicy retryPolicy,
PromotedToLock promotedToLock)
Creates in mutex promotion mode.
|
DistributedAtomicValue(CuratorFramework client,
String path,
RetryPolicy retryPolicy)
Creates in optimistic mode only - i.e.
|
DistributedAtomicValue(CuratorFramework client,
String path,
RetryPolicy retryPolicy,
PromotedToLock promotedToLock)
Creates in mutex promotion mode.
|
Constructor and Description |
---|
DistributedBarrier(CuratorFramework client,
String barrierPath) |
DistributedDoubleBarrier(CuratorFramework client,
String barrierPath,
int memberQty)
Creates the barrier abstraction.
|
Modifier and Type | Method and Description |
---|---|
void |
PathChildrenCacheListener.childEvent(CuratorFramework client,
PathChildrenCacheEvent event)
Called when a change has occurred
|
void |
TreeCacheListener.childEvent(CuratorFramework client,
TreeCacheEvent event)
Called when a change has occurred
|
static TreeCache.Builder |
TreeCache.newBuilder(CuratorFramework client,
String path)
Create a TreeCache builder for the given client and path to configure advanced options.
|
Constructor and Description |
---|
NodeCache(CuratorFramework client,
String path) |
NodeCache(CuratorFramework client,
String path,
boolean dataIsCompressed) |
PathChildrenCache(CuratorFramework client,
String path,
boolean cacheData) |
PathChildrenCache(CuratorFramework client,
String path,
boolean cacheData,
boolean dataIsCompressed,
CloseableExecutorService executorService) |
PathChildrenCache(CuratorFramework client,
String path,
boolean cacheData,
boolean dataIsCompressed,
ExecutorService executorService) |
PathChildrenCache(CuratorFramework client,
String path,
boolean cacheData,
boolean dataIsCompressed,
ThreadFactory threadFactory) |
PathChildrenCache(CuratorFramework client,
String path,
boolean cacheData,
ThreadFactory threadFactory) |
PathChildrenCache(CuratorFramework client,
String path,
PathChildrenCacheMode mode)
Deprecated.
|
PathChildrenCache(CuratorFramework client,
String path,
PathChildrenCacheMode mode,
ThreadFactory threadFactory)
Deprecated.
|
TreeCache(CuratorFramework client,
String path)
Create a TreeCache for the given client and path with default options.
|
Modifier and Type | Method and Description |
---|---|
void |
LeaderSelectorListenerAdapter.stateChanged(CuratorFramework client,
ConnectionState newState) |
void |
LeaderSelectorListener.takeLeadership(CuratorFramework client)
Called when your instance has been granted leadership.
|
Modifier and Type | Method and Description |
---|---|
static void |
Revoker.attemptRevoke(CuratorFramework client,
String path)
Utility to mark a lock for revocation.
|
String |
LockInternalsDriver.createsTheLock(CuratorFramework client,
String path,
byte[] lockNodeBytes) |
String |
StandardLockInternalsDriver.createsTheLock(CuratorFramework client,
String path,
byte[] lockNodeBytes) |
static Collection<String> |
LockInternals.getParticipantNodes(CuratorFramework client,
String basePath,
String lockName,
LockInternalsSorter sorter) |
static List<String> |
LockInternals.getSortedChildren(CuratorFramework client,
String basePath,
String lockName,
LockInternalsSorter sorter) |
PredicateResults |
LockInternalsDriver.getsTheLock(CuratorFramework client,
List<String> children,
String sequenceNodeName,
int maxLeases) |
PredicateResults |
StandardLockInternalsDriver.getsTheLock(CuratorFramework client,
List<String> children,
String sequenceNodeName,
int maxLeases) |
Constructor and Description |
---|
ChildReaper(CuratorFramework client,
String path,
Reaper.Mode mode)
Deprecated.
|
ChildReaper(CuratorFramework client,
String path,
Reaper.Mode mode,
int reapingThresholdMs)
Deprecated.
|
ChildReaper(CuratorFramework client,
String path,
Reaper.Mode mode,
ScheduledExecutorService executor,
int reapingThresholdMs)
Deprecated.
|
ChildReaper(CuratorFramework client,
String path,
Reaper.Mode mode,
ScheduledExecutorService executor,
int reapingThresholdMs,
String leaderPath)
Deprecated.
|
ChildReaper(CuratorFramework client,
String path,
Reaper.Mode mode,
ScheduledExecutorService executor,
int reapingThresholdMs,
String leaderPath,
Set<String> lockSchema)
Deprecated.
|
InterProcessMultiLock(CuratorFramework client,
List<String> paths)
Creates a multi lock of
InterProcessMutex s |
InterProcessMutex(CuratorFramework client,
String path) |
InterProcessMutex(CuratorFramework client,
String path,
LockInternalsDriver driver) |
InterProcessReadWriteLock(CuratorFramework client,
String basePath) |
InterProcessReadWriteLock(CuratorFramework client,
String basePath,
byte[] lockData) |
InterProcessSemaphore(CuratorFramework client,
String path,
int maxLeases)
Deprecated.
|
InterProcessSemaphore(CuratorFramework client,
String path,
SharedCountReader count)
Deprecated.
|
InterProcessSemaphoreMutex(CuratorFramework client,
String path) |
InterProcessSemaphoreV2(CuratorFramework client,
String path,
int maxLeases) |
InterProcessSemaphoreV2(CuratorFramework client,
String path,
SharedCountReader count) |
Reaper(CuratorFramework client)
Deprecated.
Uses the default reaping threshold of 5 minutes and creates an internal thread pool
|
Reaper(CuratorFramework client,
int reapingThresholdMs)
Deprecated.
Uses the given reaping threshold and creates an internal thread pool
|
Reaper(CuratorFramework client,
ScheduledExecutorService executor,
int reapingThresholdMs)
Deprecated.
|
Reaper(CuratorFramework client,
ScheduledExecutorService executor,
int reapingThresholdMs,
LeaderLatch leaderLatch)
Deprecated.
|
Reaper(CuratorFramework client,
ScheduledExecutorService executor,
int reapingThresholdMs,
String leaderPath)
Deprecated.
|
Modifier and Type | Method and Description |
---|---|
protected PathChildrenCache |
GroupMember.newPathChildrenCache(CuratorFramework client,
String membershipPath) |
protected PersistentEphemeralNode |
GroupMember.newPersistentEphemeralNode(CuratorFramework client,
String membershipPath,
String thisId,
byte[] payload) |
Constructor and Description |
---|
GroupMember(CuratorFramework client,
String membershipPath,
String thisId) |
GroupMember(CuratorFramework client,
String membershipPath,
String thisId,
byte[] payload) |
PersistentEphemeralNode(CuratorFramework client,
PersistentEphemeralNode.Mode mode,
String basePath,
byte[] initData)
Deprecated.
|
PersistentNode(CuratorFramework client,
org.apache.zookeeper.CreateMode mode,
boolean useProtection,
String basePath,
byte[] initData) |
Modifier and Type | Method and Description |
---|---|
T |
QueueAllocator.allocateQueue(CuratorFramework client,
String queuePath) |
static <T> QueueBuilder<T> |
QueueBuilder.builder(CuratorFramework client,
QueueConsumer<T> consumer,
QueueSerializer<T> serializer,
String queuePath)
Allocate a new builder
|
void |
BlockingQueueConsumer.stateChanged(CuratorFramework client,
ConnectionState newState) |
Constructor and Description |
---|
QueueSharder(CuratorFramework client,
QueueAllocator<U,T> queueAllocator,
String queuePath,
String leaderPath,
QueueSharderPolicies policies) |
SimpleDistributedQueue(CuratorFramework client,
String path) |
Constructor and Description |
---|
SharedCount(CuratorFramework client,
String path,
int seedValue) |
SharedValue(CuratorFramework client,
String path,
byte[] seedValue) |
Modifier and Type | Method and Description |
---|---|
void |
ConnectionStateListener.stateChanged(CuratorFramework client,
ConnectionState newState)
Called when there is a state change in the connection
|
Constructor and Description |
---|
ConnectionStateManager(CuratorFramework client,
ThreadFactory threadFactory) |
Modifier and Type | Method and Description |
---|---|
ServiceDiscoveryBuilder<T> |
ServiceDiscoveryBuilder.client(CuratorFramework client)
Required - set the client to use
|
Modifier and Type | Method and Description |
---|---|
void |
ServiceCacheImpl.childEvent(CuratorFramework client,
PathChildrenCacheEvent event) |
Constructor and Description |
---|
ServiceDiscoveryImpl(CuratorFramework client,
String basePath,
InstanceSerializer<T> serializer,
ServiceInstance<T> thisInstance,
boolean watchInstances) |
Copyright © 2011–2019 The Apache Software Foundation. All rights reserved.