Uses of Interface
org.apache.curator.RetryPolicy
Packages that use RetryPolicy
Package
Description
-
Uses of RetryPolicy in framework
Methods in framework with parameters of type RetryPolicyModifier and TypeMethodDescriptionstatic CuratorFrameworkCreateClientExamples.createWithOptions(String connectionString, RetryPolicy retryPolicy, int connectionTimeoutMs, int sessionTimeoutMs) -
Uses of RetryPolicy in org.apache.curator
Classes in org.apache.curator that implement RetryPolicyModifier and TypeClassDescriptionclassRetryPolicyimplementation that failed on session expired.Methods in org.apache.curator that return RetryPolicyModifier and TypeMethodDescriptionCuratorZookeeperClient.getRetryPolicy()Return the current retry policyMethods in org.apache.curator with parameters of type RetryPolicyModifier and TypeMethodDescriptionvoidCuratorZookeeperClient.setRetryPolicy(RetryPolicy policy) Change the retry policyConstructors in org.apache.curator with parameters of type RetryPolicyModifierConstructorDescriptionCuratorZookeeperClient(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
Methods in org.apache.curator.framework that return RetryPolicyMethods in org.apache.curator.framework with parameters of type RetryPolicyModifier and TypeMethodDescriptionstatic CuratorFrameworkCuratorFrameworkFactory.newClient(String connectString, int sessionTimeoutMs, int connectionTimeoutMs, RetryPolicy retryPolicy) Create a new clientstatic CuratorFrameworkCuratorFrameworkFactory.newClient(String connectString, int sessionTimeoutMs, int connectionTimeoutMs, RetryPolicy retryPolicy, org.apache.zookeeper.client.ZKClientConfig zkClientConfig) Create a new clientstatic CuratorFrameworkCuratorFrameworkFactory.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
Methods in org.apache.curator.framework.recipes.atomic with parameters of type RetryPolicyModifier and TypeMethodDescriptionPromotedToLock.Builder.retryPolicy(RetryPolicy retryPolicy) Set the retry policy to use when an operation does not succeedConstructors in org.apache.curator.framework.recipes.atomic with parameters of type RetryPolicyModifierConstructorDescriptionDistributedAtomicInteger(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
Methods in org.apache.curator.framework.state with parameters of type RetryPolicyModifier and TypeMethodDescriptionConnectionStateListenerManagerFactory.circuitBreaking(RetryPolicy retryPolicy) Listeners set in this manager receive circuit breaking behavior usingCircuitBreakingConnectionStateListeneras 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 usingCircuitBreakingConnectionStateListeneras a master listener that proxies to any listener registered by client code (unless the listener returns true forConnectionStateListener.doNotProxy()).Constructors in org.apache.curator.framework.state with parameters of type RetryPolicyModifierConstructorDescriptionCircuitBreakingConnectionStateListener(CuratorFramework client, ConnectionStateListener listener, RetryPolicy retryPolicy) CircuitBreakingConnectionStateListener(CuratorFramework client, ConnectionStateListener listener, RetryPolicy retryPolicy, ScheduledExecutorService service) -
Uses of RetryPolicy in org.apache.curator.retry
Classes in org.apache.curator.retry that implement RetryPolicyModifier and TypeClassDescriptionclassRetry policy that retries a set number of times with an increasing (up to a maximum bound) sleep time between retriesclassRetry policy that retries a set number of times with increasing sleep time between retriesclassRetryPolicyimplementation that always allowsRetry.classRetry policy that retries a max number of timesclassA retry policy that retries only onceclassA retry policy that retries until a given amount of time elapses