org.apache.tephra.zookeeper

Class TephraZKClientService

java.lang.Object

com.google.common.util.concurrent.AbstractService

org.apache.tephra.zookeeper.TephraZKClientService

All Implemented Interfaces:

com.google.common.util.concurrent.Service, org.apache.twill.zookeeper.ZKClient, org.apache.twill.zookeeper.ZKClientService, org.apache.zookeeper.Watcher

public class TephraZKClientService
extends com.google.common.util.concurrent.AbstractService
implements org.apache.twill.zookeeper.ZKClientService, org.apache.zookeeper.Watcher

The implementation of ZKClientService.

Nested Class Summary

Nested classes/interfaces inherited from interface org.apache.twill.zookeeper.ZKClientService

org.apache.twill.zookeeper.ZKClientService.Builder

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

Nested classes/interfaces inherited from interface org.apache.zookeeper.Watcher

org.apache.zookeeper.Watcher.Event

Constructor Summary

Constructors

Constructor and Description
TephraZKClientService(String zkStr, int sessionTimeout, org.apache.zookeeper.Watcher connectionWatcher, com.google.common.collect.Multimap<String,byte[]> authInfos) Create a new instance.

Method Summary

Methods

Modifier and Type	Method and Description
org.apache.twill.common.Cancellable	addConnectionWatcher(org.apache.zookeeper.Watcher watcher)
org.apache.twill.zookeeper.OperationFuture<String>	create(String path, byte[] data, org.apache.zookeeper.CreateMode createMode)
org.apache.twill.zookeeper.OperationFuture<String>	create(String path, byte[] data, org.apache.zookeeper.CreateMode createMode, boolean createParent)
org.apache.twill.zookeeper.OperationFuture<String>	create(String path, byte[] data, org.apache.zookeeper.CreateMode createMode, boolean createParent, Iterable<org.apache.zookeeper.data.ACL> acl)
org.apache.twill.zookeeper.OperationFuture<String>	create(String path, byte[] data, org.apache.zookeeper.CreateMode createMode, Iterable<org.apache.zookeeper.data.ACL> acl)
org.apache.twill.zookeeper.OperationFuture<String>	delete(String path)
org.apache.twill.zookeeper.OperationFuture<String>	delete(String deletePath, int version)
protected void	doStart()
protected void	doStop()
org.apache.twill.zookeeper.OperationFuture<org.apache.zookeeper.data.Stat>	exists(String path)
org.apache.twill.zookeeper.OperationFuture<org.apache.zookeeper.data.Stat>	exists(String path, org.apache.zookeeper.Watcher watcher)
org.apache.twill.zookeeper.OperationFuture<org.apache.twill.zookeeper.ACLData>	getACL(String path)
org.apache.twill.zookeeper.OperationFuture<org.apache.twill.zookeeper.NodeChildren>	getChildren(String path)
org.apache.twill.zookeeper.OperationFuture<org.apache.twill.zookeeper.NodeChildren>	getChildren(String path, org.apache.zookeeper.Watcher watcher)
String	getConnectString()
org.apache.twill.zookeeper.OperationFuture<org.apache.twill.zookeeper.NodeData>	getData(String path)
org.apache.twill.zookeeper.OperationFuture<org.apache.twill.zookeeper.NodeData>	getData(String path, org.apache.zookeeper.Watcher watcher)
Long	getSessionId()
com.google.common.base.Supplier<org.apache.zookeeper.ZooKeeper>	getZooKeeperSupplier()
void	process(org.apache.zookeeper.WatchedEvent event)
org.apache.twill.zookeeper.OperationFuture<org.apache.zookeeper.data.Stat>	setACL(String path, Iterable<org.apache.zookeeper.data.ACL> acl)
org.apache.twill.zookeeper.OperationFuture<org.apache.zookeeper.data.Stat>	setACL(String path, Iterable<org.apache.zookeeper.data.ACL> acl, int version)
org.apache.twill.zookeeper.OperationFuture<org.apache.zookeeper.data.Stat>	setData(String path, byte[] data)
org.apache.twill.zookeeper.OperationFuture<org.apache.zookeeper.data.Stat>	setData(String dataPath, byte[] data, int version)

Methods inherited from class com.google.common.util.concurrent.AbstractService

addListener, isRunning, notifyFailed, notifyStarted, notifyStopped, start, startAndWait, state, stop, stopAndWait, toString

Methods inherited from class java.lang.Object

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

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

addListener, isRunning, start, startAndWait, state, stop, stopAndWait

Constructor Detail

TephraZKClientService

public TephraZKClientService(String zkStr,
                     int sessionTimeout,
                     org.apache.zookeeper.Watcher connectionWatcher,
                     com.google.common.collect.Multimap<String,byte[]> authInfos)

Create a new instance.

Parameters:

zkStr - zookeper connection string

sessionTimeout - timeout in milliseconds

connectionWatcher - watcher to set

authInfos - authorization bytes

Method Detail

getSessionId

public Long getSessionId()

Specified by:

getSessionId in interface org.apache.twill.zookeeper.ZKClient

getConnectString

public String getConnectString()

Specified by:

getConnectString in interface org.apache.twill.zookeeper.ZKClient

addConnectionWatcher

public org.apache.twill.common.Cancellable addConnectionWatcher(org.apache.zookeeper.Watcher watcher)

Specified by:

addConnectionWatcher in interface org.apache.twill.zookeeper.ZKClient

create

public org.apache.twill.zookeeper.OperationFuture<String> create(String path,
                                                        @Nullable
                                                        byte[] data,
                                                        org.apache.zookeeper.CreateMode createMode)

Specified by:

create in interface org.apache.twill.zookeeper.ZKClient

create

public org.apache.twill.zookeeper.OperationFuture<String> create(String path,
                                                        @Nullable
                                                        byte[] data,
                                                        org.apache.zookeeper.CreateMode createMode,
                                                        boolean createParent)

Specified by:

create in interface org.apache.twill.zookeeper.ZKClient

create

public org.apache.twill.zookeeper.OperationFuture<String> create(String path,
                                                        @Nullable
                                                        byte[] data,
                                                        org.apache.zookeeper.CreateMode createMode,
                                                        Iterable<org.apache.zookeeper.data.ACL> acl)

Specified by:

create in interface org.apache.twill.zookeeper.ZKClient

exists

public org.apache.twill.zookeeper.OperationFuture<org.apache.zookeeper.data.Stat> exists(String path)

Specified by:

exists in interface org.apache.twill.zookeeper.ZKClient

getChildren

public org.apache.twill.zookeeper.OperationFuture<org.apache.twill.zookeeper.NodeChildren> getChildren(String path)

Specified by:

getChildren in interface org.apache.twill.zookeeper.ZKClient

getData

public org.apache.twill.zookeeper.OperationFuture<org.apache.twill.zookeeper.NodeData> getData(String path)

Specified by:

getData in interface org.apache.twill.zookeeper.ZKClient

setData

public org.apache.twill.zookeeper.OperationFuture<org.apache.zookeeper.data.Stat> setData(String path,
                                                                                 byte[] data)

Specified by:

setData in interface org.apache.twill.zookeeper.ZKClient

delete

public org.apache.twill.zookeeper.OperationFuture<String> delete(String path)

Specified by:

delete in interface org.apache.twill.zookeeper.ZKClient

setACL

public org.apache.twill.zookeeper.OperationFuture<org.apache.zookeeper.data.Stat> setACL(String path,
                                                                                Iterable<org.apache.zookeeper.data.ACL> acl)

Specified by:

setACL in interface org.apache.twill.zookeeper.ZKClient

create

public org.apache.twill.zookeeper.OperationFuture<String> create(String path,
                                                        @Nullable
                                                        byte[] data,
                                                        org.apache.zookeeper.CreateMode createMode,
                                                        boolean createParent,
                                                        Iterable<org.apache.zookeeper.data.ACL> acl)

Specified by:

create in interface org.apache.twill.zookeeper.ZKClient

exists

public org.apache.twill.zookeeper.OperationFuture<org.apache.zookeeper.data.Stat> exists(String path,
                                                                                org.apache.zookeeper.Watcher watcher)

Specified by:

exists in interface org.apache.twill.zookeeper.ZKClient

getChildren

public org.apache.twill.zookeeper.OperationFuture<org.apache.twill.zookeeper.NodeChildren> getChildren(String path,
                                                                                              org.apache.zookeeper.Watcher watcher)

Specified by:

getChildren in interface org.apache.twill.zookeeper.ZKClient

getData

public org.apache.twill.zookeeper.OperationFuture<org.apache.twill.zookeeper.NodeData> getData(String path,
                                                                                      org.apache.zookeeper.Watcher watcher)

Specified by:

getData in interface org.apache.twill.zookeeper.ZKClient

setData

public org.apache.twill.zookeeper.OperationFuture<org.apache.zookeeper.data.Stat> setData(String dataPath,
                                                                                 byte[] data,
                                                                                 int version)

Specified by:

setData in interface org.apache.twill.zookeeper.ZKClient

delete

public org.apache.twill.zookeeper.OperationFuture<String> delete(String deletePath,
                                                        int version)

Specified by:

delete in interface org.apache.twill.zookeeper.ZKClient

getACL

public org.apache.twill.zookeeper.OperationFuture<org.apache.twill.zookeeper.ACLData> getACL(String path)

Specified by:

getACL in interface org.apache.twill.zookeeper.ZKClient

setACL

public org.apache.twill.zookeeper.OperationFuture<org.apache.zookeeper.data.Stat> setACL(String path,
                                                                                Iterable<org.apache.zookeeper.data.ACL> acl,
                                                                                int version)

Specified by:

setACL in interface org.apache.twill.zookeeper.ZKClient

getZooKeeperSupplier

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

Specified by:

getZooKeeperSupplier in interface org.apache.twill.zookeeper.ZKClientService

doStart

protected void doStart()

Specified by:

doStart in class com.google.common.util.concurrent.AbstractService

doStop

protected void doStop()

Specified by:

doStop in class com.google.common.util.concurrent.AbstractService

process

public void process(org.apache.zookeeper.WatchedEvent event)

Specified by:

process in interface org.apache.zookeeper.Watcher