Package org.apache.bookkeeper.zookeeper

Class ZooKeeperClient.ZkRetryRunnable

java.lang.Object

org.apache.bookkeeper.zookeeper.ZooKeeperClient.ZkRetryRunnable

All Implemented Interfaces:

Runnable

Enclosing class:

ZooKeeperClient

abstract static class ZooKeeperClient.ZkRetryRunnable
extends Object
implements Runnable

A runnable that retries zookeeper operations.

Field Summary

Fields

Modifier and Type	Field	Description
(package private) final com.google.common.util.concurrent.RateLimiter	rateLimiter
(package private) final Runnable	that
(package private) final ZooWorker	worker

Constructor Summary

Constructors

Constructor	Description
ZkRetryRunnable(RetryPolicy retryPolicy, com.google.common.util.concurrent.RateLimiter rateLimiter, OpStatsLogger statsLogger)

Method Summary

Modifier and Type	Method	Description
void	run()
(package private) abstract void	zkRun()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Details

worker

final ZooWorker worker

rateLimiter

final com.google.common.util.concurrent.RateLimiter rateLimiter

that

final Runnable that

Constructor Details

ZkRetryRunnable

ZkRetryRunnable(RetryPolicy retryPolicy,
 com.google.common.util.concurrent.RateLimiter rateLimiter,
 OpStatsLogger statsLogger)

Method Details

run

public void run()

Specified by:

run in interface Runnable

zkRun

abstract void zkRun()