com.netflix.curator.framework

Class CuratorFrameworkFactory.Builder

java.lang.Object

com.netflix.curator.framework.CuratorFrameworkFactory.Builder

Enclosing class:

CuratorFrameworkFactory

public static class CuratorFrameworkFactory.Builder
extends java.lang.Object

Method Summary

Methods

Modifier and Type	Method and Description
CuratorFrameworkFactory.Builder	aclProvider(ACLProvider aclProvider)
CuratorFrameworkFactory.Builder	authorization(java.lang.String scheme, byte[] auth) Add connection authorization
CuratorFramework	build() Apply the current values and build a new CuratorFramework
CuratorFrameworkFactory.Builder	compressionProvider(CompressionProvider compressionProvider)
CuratorFrameworkFactory.Builder	connectionTimeoutMs(int connectionTimeoutMs)
CuratorFrameworkFactory.Builder	connectString(java.lang.String connectString) Set the list of servers to connect to.
CuratorFrameworkFactory.Builder	defaultData(byte[] defaultData) Sets the data to use when PathAndBytesable.forPath(String) is used.
CuratorFrameworkFactory.Builder	ensembleProvider(EnsembleProvider ensembleProvider) Set the list ensemble provider.
ACLProvider	getAclProvider()
java.lang.String	getAuthScheme()
byte[]	getAuthValue()
CompressionProvider	getCompressionProvider()
int	getConnectionTimeoutMs()
byte[]	getDefaultData()
EnsembleProvider	getEnsembleProvider()
java.lang.String	getNamespace()
RetryPolicy	getRetryPolicy()
int	getSessionTimeoutMs()
java.util.concurrent.ThreadFactory	getThreadFactory()
ZookeeperFactory	getZookeeperFactory()
CuratorFrameworkFactory.Builder	namespace(java.lang.String namespace) As ZooKeeper is a shared space, users of a given cluster should stay within a pre-defined namespace.
CuratorFrameworkFactory.Builder	retryPolicy(RetryPolicy retryPolicy)
CuratorFrameworkFactory.Builder	sessionTimeoutMs(int sessionTimeoutMs)
CuratorFrameworkFactory.Builder	threadFactory(java.util.concurrent.ThreadFactory threadFactory)
CuratorFrameworkFactory.Builder	zookeeperFactory(ZookeeperFactory zookeeperFactory)

Methods inherited from class java.lang.Object

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

Method Detail

build

public CuratorFramework build()

Apply the current values and build a new CuratorFramework

Returns:

new CuratorFramework

authorization

public CuratorFrameworkFactory.Builder authorization(java.lang.String scheme,
                                            byte[] auth)

Add connection authorization

Parameters:

scheme - the scheme

auth - the auth bytes

Returns:

this

connectString

public CuratorFrameworkFactory.Builder connectString(java.lang.String connectString)

Set the list of servers to connect to. IMPORTANT: use either this or ensembleProvider(EnsembleProvider) but not both.

Parameters:

connectString - list of servers to connect to

Returns:

this

ensembleProvider

public CuratorFrameworkFactory.Builder ensembleProvider(EnsembleProvider ensembleProvider)

Set the list ensemble provider. IMPORTANT: use either this or connectString(String) but not both.

Parameters:

ensembleProvider - the ensemble provider to use

Returns:

this

defaultData

public CuratorFrameworkFactory.Builder defaultData(byte[] defaultData)

Sets the data to use when PathAndBytesable.forPath(String) is used. This is useful for debugging purposes. For example, you could set this to be the IP of the client.

Parameters:

defaultData - new default data to use

Returns:

this

namespace

public CuratorFrameworkFactory.Builder namespace(java.lang.String namespace)

As ZooKeeper is a shared space, users of a given cluster should stay within a pre-defined namespace. If a namespace is set here, all paths will get pre-pended with the namespace

Parameters:

namespace - the namespace

Returns:

this

sessionTimeoutMs

public CuratorFrameworkFactory.Builder sessionTimeoutMs(int sessionTimeoutMs)

Parameters:

sessionTimeoutMs - session timeout

Returns:

this

connectionTimeoutMs

public CuratorFrameworkFactory.Builder connectionTimeoutMs(int connectionTimeoutMs)

Parameters:

connectionTimeoutMs - connection timeout

Returns:

this

retryPolicy

public CuratorFrameworkFactory.Builder retryPolicy(RetryPolicy retryPolicy)

Parameters:

retryPolicy - retry policy to use

Returns:

this

threadFactory

public CuratorFrameworkFactory.Builder threadFactory(java.util.concurrent.ThreadFactory threadFactory)

Parameters:

threadFactory - thread factory used to create Executor Services

Returns:

this

compressionProvider

public CuratorFrameworkFactory.Builder compressionProvider(CompressionProvider compressionProvider)

Parameters:

compressionProvider - the compression provider

Returns:

this

zookeeperFactory

public CuratorFrameworkFactory.Builder zookeeperFactory(ZookeeperFactory zookeeperFactory)

Parameters:

zookeeperFactory - the zookeeper factory to use

Returns:

this

aclProvider

public CuratorFrameworkFactory.Builder aclProvider(ACLProvider aclProvider)

Parameters:

aclProvider - a provider for ACLs

Returns:

this

getAclProvider

public ACLProvider getAclProvider()

getZookeeperFactory

public ZookeeperFactory getZookeeperFactory()

getCompressionProvider

public CompressionProvider getCompressionProvider()

getThreadFactory

public java.util.concurrent.ThreadFactory getThreadFactory()

getEnsembleProvider

public EnsembleProvider getEnsembleProvider()

getSessionTimeoutMs

public int getSessionTimeoutMs()

getConnectionTimeoutMs

public int getConnectionTimeoutMs()

getRetryPolicy

public RetryPolicy getRetryPolicy()

getNamespace

public java.lang.String getNamespace()

getAuthScheme

public java.lang.String getAuthScheme()

getAuthValue

public byte[] getAuthValue()

getDefaultData

public byte[] getDefaultData()