org.apache.twill.zookeeper

Class ZKClientService.Builder

java.lang.Object

org.apache.twill.zookeeper.ZKClientService.Builder

Enclosing interface:

ZKClientService

public static final class ZKClientService.Builder
extends Object

Builder for creating an implementation of ZKClientService. The default client timeout is 10000ms.

Method Summary

Modifier and Type	Method and Description
ZKClientService.Builder	addAuthInfo(String schema, byte[] auth) Adds an authorization information.
ZKClientService	build() Creates an instance of ZKClientService with the settings of this builder.
static ZKClientService.Builder	of(String connectStr) Creates a ZKClientService.Builder with the given ZooKeeper connection string.
ZKClientService.Builder	setConnectionWatcher(org.apache.zookeeper.Watcher watcher) Sets a Watcher that will be called whenever connection state change.
ZKClientService.Builder	setSessionTimeout(int timeout) Sets the client timeout to the give milliseconds.

Methods inherited from class java.lang.Object

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

Method Detail

of

public static ZKClientService.Builder of(String connectStr)

Creates a ZKClientService.Builder with the given ZooKeeper connection string.

Parameters:

connectStr - The connection string.

Returns:

A new instance of Builder.

setSessionTimeout

public ZKClientService.Builder setSessionTimeout(int timeout)

Sets the client timeout to the give milliseconds.

Parameters:

timeout - timeout in milliseconds.

Returns:

This builder

setConnectionWatcher

public ZKClientService.Builder setConnectionWatcher(org.apache.zookeeper.Watcher watcher)

Sets a Watcher that will be called whenever connection state change.

Parameters:

watcher - The watcher to set.

Returns:

This builder.

addAuthInfo

public ZKClientService.Builder addAuthInfo(String schema,
                                           byte[] auth)

Adds an authorization information.

Parameters:

schema - The authorization schema.

auth - The authorization bytes.

Returns:

This builder.

build

public ZKClientService build()

Creates an instance of ZKClientService with the settings of this builder.

Returns:

A new instance of ZKClientService.