Package | Description |
---|---|
framework | |
org.apache.curator | |
org.apache.curator.framework | |
org.apache.curator.framework.recipes.atomic | |
org.apache.curator.framework.state | |
org.apache.curator.retry |
Modifier and Type | Method and Description |
---|---|
static CuratorFramework |
CreateClientExamples.createWithOptions(String connectionString,
RetryPolicy retryPolicy,
int connectionTimeoutMs,
int sessionTimeoutMs) |
Modifier and Type | Class and Description |
---|---|
class |
SessionFailedRetryPolicy
RetryPolicy implementation that failed on session expired. |
Modifier and Type | Method and Description |
---|---|
RetryPolicy |
CuratorZookeeperClient.getRetryPolicy()
Return the current retry policy
|
Modifier and Type | Method and Description |
---|---|
void |
CuratorZookeeperClient.setRetryPolicy(RetryPolicy policy)
Change the retry policy
|
Constructor and Description |
---|
CuratorZookeeperClient(EnsembleProvider ensembleProvider,
int sessionTimeoutMs,
int connectionTimeoutMs,
org.apache.zookeeper.Watcher watcher,
RetryPolicy retryPolicy) |
CuratorZookeeperClient(String connectString,
int sessionTimeoutMs,
int connectionTimeoutMs,
org.apache.zookeeper.Watcher watcher,
RetryPolicy retryPolicy) |
CuratorZookeeperClient(ZookeeperFactory zookeeperFactory,
EnsembleProvider ensembleProvider,
int sessionTimeoutMs,
int connectionTimeoutMs,
int waitForShutdownTimeoutMs,
org.apache.zookeeper.Watcher watcher,
RetryPolicy retryPolicy,
boolean canBeReadOnly) |
CuratorZookeeperClient(ZookeeperFactory zookeeperFactory,
EnsembleProvider ensembleProvider,
int sessionTimeoutMs,
int connectionTimeoutMs,
org.apache.zookeeper.Watcher watcher,
RetryPolicy retryPolicy,
boolean canBeReadOnly) |
SessionFailedRetryPolicy(RetryPolicy delegatePolicy) |
Modifier and Type | Method and Description |
---|---|
RetryPolicy |
CuratorFrameworkFactory.Builder.getRetryPolicy() |
Modifier and Type | Method and Description |
---|---|
static CuratorFramework |
CuratorFrameworkFactory.newClient(String connectString,
int sessionTimeoutMs,
int connectionTimeoutMs,
RetryPolicy retryPolicy)
Create a new client
|
static CuratorFramework |
CuratorFrameworkFactory.newClient(String connectString,
int sessionTimeoutMs,
int connectionTimeoutMs,
RetryPolicy retryPolicy,
org.apache.zookeeper.client.ZKClientConfig zkClientConfig)
Create a new client
|
static CuratorFramework |
CuratorFrameworkFactory.newClient(String connectString,
RetryPolicy retryPolicy)
Create a new client with default session timeout and default connection timeout
|
CuratorFrameworkFactory.Builder |
CuratorFrameworkFactory.Builder.retryPolicy(RetryPolicy retryPolicy) |
Modifier and Type | Method and Description |
---|---|
PromotedToLock.Builder |
PromotedToLock.Builder.retryPolicy(RetryPolicy retryPolicy)
Set the retry policy to use when an operation does not succeed
|
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.
|
Modifier and Type | Method and Description |
---|---|
static ConnectionStateListenerManagerFactory |
ConnectionStateListenerManagerFactory.circuitBreaking(RetryPolicy retryPolicy)
Listeners set in this manager receive circuit breaking behavior using
CircuitBreakingConnectionStateListener
as a master listener that proxies to any listener registered by client code (unless the listener returns true
for ConnectionStateListener.doNotProxy() ). |
static ConnectionStateListenerManagerFactory |
ConnectionStateListenerManagerFactory.circuitBreaking(RetryPolicy retryPolicy,
ScheduledExecutorService service)
Listeners set in this manager receive circuit breaking behavior using
CircuitBreakingConnectionStateListener
as a master listener that proxies to any listener registered by client code (unless the listener returns true
for ConnectionStateListener.doNotProxy() ). |
Constructor and Description |
---|
CircuitBreakingConnectionStateListener(CuratorFramework client,
ConnectionStateListener listener,
RetryPolicy retryPolicy) |
CircuitBreakingConnectionStateListener(CuratorFramework client,
ConnectionStateListener listener,
RetryPolicy retryPolicy,
ScheduledExecutorService service) |
Modifier and Type | Class and Description |
---|---|
class |
BoundedExponentialBackoffRetry
Retry policy that retries a set number of times with an increasing (up to a maximum bound) sleep time between retries
|
class |
ExponentialBackoffRetry
Retry policy that retries a set number of times with increasing sleep time between retries
|
class |
RetryForever
RetryPolicy implementation that always allowsRetry. |
class |
RetryNTimes
Retry policy that retries a max number of times
|
class |
RetryOneTime
A retry policy that retries only once
|
class |
RetryUntilElapsed
A retry policy that retries until a given amount of time elapses
|
Copyright © 2011–2023 The Apache Software Foundation. All rights reserved.