Uses of Interface
org.apache.bookkeeper.zookeeper.RetryPolicy
Packages that use RetryPolicy
Package
Description
ZooKeeper based metadata implementation.
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 RetryPolicyModifier and TypeMethodDescriptionprotected voidZKMetadataDriverBase.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 RetryPolicyModifier and TypeClassDescriptionclassRetry policy that retries a set number of times with an increasing (up to a maximum bound) backoff time between retries.classA retry policy implementation that backoff retries exponentially.classBackoff time determined based as a multiple of baseBackoffTime.Fields in org.apache.bookkeeper.zookeeper declared as RetryPolicyModifier and TypeFieldDescription(package private) RetryPolicyZooKeeperClient.Builder.connectRetryPolicy(package private) RetryPolicyZooKeeperClient.Builder.operationRetryPolicy(package private) final RetryPolicyZooWorker.retryPolicyMethods in org.apache.bookkeeper.zookeeper with parameters of type RetryPolicyModifier and TypeMethodDescriptionZooKeeperClient.Builder.connectRetryPolicy(RetryPolicy retryPolicy) (package private) static ZooKeeperClientZooKeeperClient.createConnectedZooKeeperClient(String connectString, int sessionTimeoutMs, Set<org.apache.zookeeper.Watcher> childWatchers, RetryPolicy operationRetryPolicy) ZooKeeperClient.Builder.operationRetryPolicy(RetryPolicy retryPolicy) static <T> TZooWorker.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 RetryPolicyModifierConstructorDescription(package private)ZkRetryRunnable(RetryPolicy retryPolicy, com.google.common.util.concurrent.RateLimiter rateLimiter, OpStatsLogger statsLogger) protectedZooKeeperClient(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)