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.stateChanged(CuratorFramework client,
ConnectionState newState) |
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.
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 . |
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() |
CuratorFramework |
CuratorFrameworkImpl.usingNamespace(String newNamespace) |
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
|
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,
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.
|
Modifier and Type | Method and Description |
---|---|
void |
LeaderSelectorListener.takeLeadership(CuratorFramework client)
Called when your instance has been granted leadership.
|
Constructor and Description |
---|
LeaderLatch(CuratorFramework client,
String latchPath) |
LeaderLatch(CuratorFramework client,
String latchPath,
String id) |
LeaderSelector(CuratorFramework client,
String leaderPath,
LeaderSelectorListener listener) |
LeaderSelector(CuratorFramework client,
String leaderPath,
ThreadFactory threadFactory,
Executor executor,
LeaderSelectorListener listener) |
Modifier and Type | Method and Description |
---|---|
static void |
Revoker.attemptRevoke(CuratorFramework client,
String path)
Utility to mark a lock for revocation.
|
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) |
org.apache.curator.framework.recipes.locks.PredicateResults |
StandardLockInternalsDriver.getsTheLock(CuratorFramework client,
List<String> children,
String sequenceNodeName,
int maxLeases) |
Constructor and Description |
---|
PersistentEphemeralNode(CuratorFramework client,
PersistentEphemeralNode.Mode mode,
String basePath,
byte[] data) |
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) |
Copyright © 2011–2014 The Apache Software Foundation. All rights reserved.