Uses of Interface
org.apache.curator.RetryPolicy
Package
Description
-
Uses of RetryPolicy in framework
Modifier and TypeMethodDescriptionstatic CuratorFramework
CreateClientExamples.createWithOptions
(String connectionString, RetryPolicy retryPolicy, int connectionTimeoutMs, int sessionTimeoutMs) -
Uses of RetryPolicy in org.apache.curator
Modifier and TypeClassDescriptionclass
RetryPolicy
implementation that failed on session expired.Modifier and TypeMethodDescriptionCuratorZookeeperClient.getRetryPolicy()
Return the current retry policyModifier and TypeMethodDescriptionvoid
CuratorZookeeperClient.setRetryPolicy
(RetryPolicy policy) Change the retry policyModifierConstructorDescriptionCuratorZookeeperClient
(String connectString, int sessionTimeoutMs, int connectionTimeoutMs, org.apache.zookeeper.Watcher watcher, RetryPolicy retryPolicy) CuratorZookeeperClient
(EnsembleProvider ensembleProvider, 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) -
Uses of RetryPolicy in org.apache.curator.framework
Modifier and TypeMethodDescriptionstatic CuratorFramework
CuratorFrameworkFactory.newClient
(String connectString, int sessionTimeoutMs, int connectionTimeoutMs, RetryPolicy retryPolicy) Create a new clientstatic CuratorFramework
CuratorFrameworkFactory.newClient
(String connectString, int sessionTimeoutMs, int connectionTimeoutMs, RetryPolicy retryPolicy, org.apache.zookeeper.client.ZKClientConfig zkClientConfig) Create a new clientstatic CuratorFramework
CuratorFrameworkFactory.newClient
(String connectString, RetryPolicy retryPolicy) Create a new client with default session timeout and default connection timeoutCuratorFrameworkFactory.Builder.retryPolicy
(RetryPolicy retryPolicy) -
Uses of RetryPolicy in org.apache.curator.framework.recipes.atomic
Modifier and TypeMethodDescriptionPromotedToLock.Builder.retryPolicy
(RetryPolicy retryPolicy) Set the retry policy to use when an operation does not succeedModifierConstructorDescriptionDistributedAtomicInteger
(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. -
Uses of RetryPolicy in org.apache.curator.framework.state
Modifier and TypeMethodDescriptionConnectionStateListenerManagerFactory.circuitBreaking
(RetryPolicy retryPolicy) Listeners set in this manager receive circuit breaking behavior usingCircuitBreakingConnectionStateListener
as a master listener that proxies to any listener registered by client code (unless the listener returns true forConnectionStateListener.doNotProxy()
).ConnectionStateListenerManagerFactory.circuitBreaking
(RetryPolicy retryPolicy, ScheduledExecutorService service) Listeners set in this manager receive circuit breaking behavior usingCircuitBreakingConnectionStateListener
as a master listener that proxies to any listener registered by client code (unless the listener returns true forConnectionStateListener.doNotProxy()
).ModifierConstructorDescriptionCircuitBreakingConnectionStateListener
(CuratorFramework client, ConnectionStateListener listener, RetryPolicy retryPolicy) CircuitBreakingConnectionStateListener
(CuratorFramework client, ConnectionStateListener listener, RetryPolicy retryPolicy, ScheduledExecutorService service) -
Uses of RetryPolicy in org.apache.curator.retry
Modifier and TypeClassDescriptionclass
Retry policy that retries a set number of times with an increasing (up to a maximum bound) sleep time between retriesclass
Retry policy that retries a set number of times with increasing sleep time between retriesclass
RetryPolicy
implementation that always allowsRetry.class
Retry policy that retries a max number of timesclass
A retry policy that retries only onceclass
A retry policy that retries until a given amount of time elapses