public class TephraZKClientService
extends com.google.common.util.concurrent.AbstractService
implements org.apache.twill.zookeeper.ZKClientService, org.apache.zookeeper.Watcher
ZKClientService
.org.apache.twill.zookeeper.ZKClientService.Builder
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.
|
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) |
addListener, isRunning, notifyFailed, notifyStarted, notifyStopped, start, startAndWait, state, stop, stopAndWait, toString
public TephraZKClientService(String zkStr, int sessionTimeout, org.apache.zookeeper.Watcher connectionWatcher, com.google.common.collect.Multimap<String,byte[]> authInfos)
zkStr
- zookeper connection stringsessionTimeout
- timeout in millisecondsconnectionWatcher
- watcher to setauthInfos
- authorization bytespublic Long getSessionId()
getSessionId
in interface org.apache.twill.zookeeper.ZKClient
public String getConnectString()
getConnectString
in interface org.apache.twill.zookeeper.ZKClient
public org.apache.twill.common.Cancellable addConnectionWatcher(org.apache.zookeeper.Watcher watcher)
addConnectionWatcher
in interface org.apache.twill.zookeeper.ZKClient
public org.apache.twill.zookeeper.OperationFuture<String> create(String path, @Nullable byte[] data, org.apache.zookeeper.CreateMode createMode)
create
in interface org.apache.twill.zookeeper.ZKClient
public org.apache.twill.zookeeper.OperationFuture<String> create(String path, @Nullable byte[] data, org.apache.zookeeper.CreateMode createMode, boolean createParent)
create
in interface org.apache.twill.zookeeper.ZKClient
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)
create
in interface org.apache.twill.zookeeper.ZKClient
public org.apache.twill.zookeeper.OperationFuture<org.apache.zookeeper.data.Stat> exists(String path)
exists
in interface org.apache.twill.zookeeper.ZKClient
public org.apache.twill.zookeeper.OperationFuture<org.apache.twill.zookeeper.NodeChildren> getChildren(String path)
getChildren
in interface org.apache.twill.zookeeper.ZKClient
public org.apache.twill.zookeeper.OperationFuture<org.apache.twill.zookeeper.NodeData> getData(String path)
getData
in interface org.apache.twill.zookeeper.ZKClient
public org.apache.twill.zookeeper.OperationFuture<org.apache.zookeeper.data.Stat> setData(String path, byte[] data)
setData
in interface org.apache.twill.zookeeper.ZKClient
public org.apache.twill.zookeeper.OperationFuture<String> delete(String path)
delete
in interface org.apache.twill.zookeeper.ZKClient
public org.apache.twill.zookeeper.OperationFuture<org.apache.zookeeper.data.Stat> setACL(String path, Iterable<org.apache.zookeeper.data.ACL> acl)
setACL
in interface org.apache.twill.zookeeper.ZKClient
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)
create
in interface org.apache.twill.zookeeper.ZKClient
public org.apache.twill.zookeeper.OperationFuture<org.apache.zookeeper.data.Stat> exists(String path, org.apache.zookeeper.Watcher watcher)
exists
in interface org.apache.twill.zookeeper.ZKClient
public org.apache.twill.zookeeper.OperationFuture<org.apache.twill.zookeeper.NodeChildren> getChildren(String path, org.apache.zookeeper.Watcher watcher)
getChildren
in interface org.apache.twill.zookeeper.ZKClient
public org.apache.twill.zookeeper.OperationFuture<org.apache.twill.zookeeper.NodeData> getData(String path, org.apache.zookeeper.Watcher watcher)
getData
in interface org.apache.twill.zookeeper.ZKClient
public org.apache.twill.zookeeper.OperationFuture<org.apache.zookeeper.data.Stat> setData(String dataPath, byte[] data, int version)
setData
in interface org.apache.twill.zookeeper.ZKClient
public org.apache.twill.zookeeper.OperationFuture<String> delete(String deletePath, int version)
delete
in interface org.apache.twill.zookeeper.ZKClient
public org.apache.twill.zookeeper.OperationFuture<org.apache.twill.zookeeper.ACLData> getACL(String path)
getACL
in interface org.apache.twill.zookeeper.ZKClient
public org.apache.twill.zookeeper.OperationFuture<org.apache.zookeeper.data.Stat> setACL(String path, Iterable<org.apache.zookeeper.data.ACL> acl, int version)
setACL
in interface org.apache.twill.zookeeper.ZKClient
public com.google.common.base.Supplier<org.apache.zookeeper.ZooKeeper> getZooKeeperSupplier()
getZooKeeperSupplier
in interface org.apache.twill.zookeeper.ZKClientService
protected void doStart()
doStart
in class com.google.common.util.concurrent.AbstractService
protected void doStop()
doStop
in class com.google.common.util.concurrent.AbstractService
public void process(org.apache.zookeeper.WatchedEvent event)
process
in interface org.apache.zookeeper.Watcher
Copyright © 2016 The Apache Software Foundation. All rights reserved.