Uses of Interface
org.apache.bookkeeper.zookeeper.RetryPolicy

Packages that use RetryPolicy

Package	Description
org.apache.bookkeeper.meta.zk	ZooKeeper based metadata implementation.
org.apache.bookkeeper.zookeeper	A simple retryable zookeeper wrapper provided in bookkeeper.

Uses of RetryPolicy in org.apache.bookkeeper.meta.zk

Methods in org.apache.bookkeeper.meta.zk with parameters of type RetryPolicy

Modifier and Type	Method	Description
protected void	ZKMetadataDriverBase.initialize(AbstractConfiguration<?> conf, StatsLogger statsLogger, RetryPolicy zkRetryPolicy, Optional<Object> optionalCtx)

Uses of RetryPolicy in org.apache.bookkeeper.zookeeper

Classes in org.apache.bookkeeper.zookeeper that implement RetryPolicy

Modifier and Type	Class	Description
class	BoundExponentialBackoffRetryPolicy	Retry policy that retries a set number of times with an increasing (up to a maximum bound) backoff time between retries.
class	ExponentialBackoffRetryPolicy	A retry policy implementation that backoff retries exponentially.
class	ExponentialBackOffWithDeadlinePolicy	Backoff time determined based as a multiple of baseBackoffTime.

Fields in org.apache.bookkeeper.zookeeper declared as RetryPolicy

Modifier and Type	Field	Description
(package private) RetryPolicy	ZooKeeperClient.Builder.connectRetryPolicy
(package private) RetryPolicy	ZooKeeperClient.Builder.operationRetryPolicy
(package private) final RetryPolicy	ZooWorker.retryPolicy

Methods in org.apache.bookkeeper.zookeeper with parameters of type RetryPolicy

Modifier and Type	Method	Description
ZooKeeperClient.Builder	ZooKeeperClient.Builder.connectRetryPolicy(RetryPolicy retryPolicy)
(package private) static ZooKeeperClient	ZooKeeperClient.createConnectedZooKeeperClient(String connectString, int sessionTimeoutMs, Set<org.apache.zookeeper.Watcher> childWatchers, RetryPolicy operationRetryPolicy)
ZooKeeperClient.Builder	ZooKeeperClient.Builder.operationRetryPolicy(RetryPolicy retryPolicy)
static <T> T	ZooWorker.syncCallWithRetries(ZooKeeperClient client, ZooWorker.ZooCallable<T> proc, RetryPolicy retryPolicy, com.google.common.util.concurrent.RateLimiter rateLimiter, OpStatsLogger statsLogger)	Execute a sync zookeeper operation with a given retry policy.

Constructors in org.apache.bookkeeper.zookeeper with parameters of type RetryPolicy

Modifier	Constructor	Description
(package private)	ZkRetryRunnable(RetryPolicy retryPolicy, com.google.common.util.concurrent.RateLimiter rateLimiter, OpStatsLogger statsLogger)
protected	ZooKeeperClient(String connectString, int sessionTimeoutMs, ZooKeeperWatcherBase watcherManager, RetryPolicy connectRetryPolicy, RetryPolicy operationRetryPolicy, StatsLogger statsLogger, int retryExecThreadCount, double rate, boolean allowReadOnlyMode)
(package private)	ZooWorker(RetryPolicy retryPolicy, OpStatsLogger statsLogger)