org.apache.twill.zookeeper

Interface ZKClientService

All Superinterfaces:

com.google.common.util.concurrent.Service, ZKClient

All Known Implementing Classes:

ForwardingZKClientService

public interface ZKClientService
extends ZKClient, com.google.common.util.concurrent.Service

A ZKClient that extends from Service to provide lifecycle management functions. The Service.start() method needed to be called before calling any other method on this interface. When the client is no longer needed, call Service.stop() to release any resources that it holds.

Nested Class Summary

Nested Classes

Modifier and Type	Interface and Description
static class	ZKClientService.Builder Builder for creating an implementation of ZKClientService.

Nested classes/interfaces inherited from interface com.google.common.util.concurrent.Service

com.google.common.util.concurrent.Service.Listener, com.google.common.util.concurrent.Service.State

Method Summary

Modifier and Type	Method and Description
com.google.common.base.Supplier<org.apache.zookeeper.ZooKeeper>	getZooKeeperSupplier() Returns a Supplier of ZooKeeper that gives the current ZooKeeper in use at the moment when Supplier.get() get called.

Methods inherited from interface org.apache.twill.zookeeper.ZKClient

addConnectionWatcher, create, create, create, create, delete, delete, exists, exists, getACL, getChildren, getChildren, getConnectString, getData, getData, getSessionId, setACL, setACL, setData, setData

Methods inherited from interface com.google.common.util.concurrent.Service

addListener, awaitRunning, awaitRunning, awaitTerminated, awaitTerminated, failureCause, isRunning, start, startAndWait, startAsync, state, stop, stopAndWait, stopAsync

Method Detail

getZooKeeperSupplier

com.google.common.base.Supplier<org.apache.zookeeper.ZooKeeper> getZooKeeperSupplier()

Returns a Supplier of ZooKeeper that gives the current ZooKeeper in use at the moment when Supplier.get() get called.

Returns:

A Supplier<ZooKeeper>