Package org.apache.bookkeeper.zookeeper
Class ZooKeeperClient.Builder
java.lang.Object
org.apache.bookkeeper.zookeeper.ZooKeeperClient.Builder
- Enclosing class:
- ZooKeeperClient
A builder to build retryable zookeeper client.
-
Field Summary
FieldsModifier and TypeFieldDescription(package private) boolean(package private) RetryPolicy(package private) String(package private) RetryPolicy(package private) double(package private) int(package private) int(package private) StatsLogger(package private) Set<org.apache.zookeeper.Watcher> -
Method Summary
Modifier and TypeMethodDescriptionallowReadOnlyMode(boolean allowReadOnlyMode) build()connectRetryPolicy(RetryPolicy retryPolicy) connectString(String connectString) operationRetryPolicy(RetryPolicy retryPolicy) requestRateLimit(double requestRateLimit) retryThreadCount(int numThreads) sessionTimeoutMs(int sessionTimeoutMs) statsLogger(StatsLogger statsLogger)
-
Field Details
-
connectString
String connectString -
sessionTimeoutMs
int sessionTimeoutMs -
watchers
Set<org.apache.zookeeper.Watcher> watchers -
connectRetryPolicy
RetryPolicy connectRetryPolicy -
operationRetryPolicy
RetryPolicy operationRetryPolicy -
statsLogger
StatsLogger statsLogger -
retryExecThreadCount
int retryExecThreadCount -
requestRateLimit
double requestRateLimit -
allowReadOnlyMode
boolean allowReadOnlyMode
-
-
Method Details
-
connectString
-
sessionTimeoutMs
-
watchers
-
connectRetryPolicy
-
operationRetryPolicy
-
statsLogger
-
requestRateLimit
-
retryThreadCount
-
allowReadOnlyMode
-
build
public ZooKeeperClient build() throws IOException, org.apache.zookeeper.KeeperException, InterruptedException- Throws:
IOExceptionorg.apache.zookeeper.KeeperExceptionInterruptedException
-