public class CuratorFrameworkFactory extends Object
Modifier and Type | Class and Description |
---|---|
static class |
CuratorFrameworkFactory.Builder |
Modifier and Type | Method and Description |
---|---|
static CuratorFrameworkFactory.Builder |
builder()
Return a new builder that builds a CuratorFramework
|
static byte[] |
getLocalAddress()
Return the local address as bytes that can be used as a node payload
|
static CuratorFramework |
newClient(String connectString,
int sessionTimeoutMs,
int connectionTimeoutMs,
RetryPolicy retryPolicy)
Create a new client
|
static CuratorFramework |
newClient(String connectString,
int sessionTimeoutMs,
int connectionTimeoutMs,
RetryPolicy retryPolicy,
org.apache.zookeeper.client.ZKClientConfig zkClientConfig)
Create a new client
|
static CuratorFramework |
newClient(String connectString,
RetryPolicy retryPolicy)
Create a new client with default session timeout and default connection timeout
|
public static CuratorFrameworkFactory.Builder builder()
public static CuratorFramework newClient(String connectString, RetryPolicy retryPolicy)
connectString
- list of servers to connect toretryPolicy
- retry policy to usepublic static CuratorFramework newClient(String connectString, int sessionTimeoutMs, int connectionTimeoutMs, RetryPolicy retryPolicy)
connectString
- list of servers to connect tosessionTimeoutMs
- session timeoutconnectionTimeoutMs
- connection timeoutretryPolicy
- retry policy to usepublic static CuratorFramework newClient(String connectString, int sessionTimeoutMs, int connectionTimeoutMs, RetryPolicy retryPolicy, org.apache.zookeeper.client.ZKClientConfig zkClientConfig)
connectString
- list of servers to connect tosessionTimeoutMs
- session timeoutconnectionTimeoutMs
- connection timeoutretryPolicy
- retry policy to usezkClientConfig
- ZKClientConfigpublic static byte[] getLocalAddress()
Copyright © 2011–2023 The Apache Software Foundation. All rights reserved.