Package | Description |
---|---|
org.apache.zookeeper | |
org.apache.zookeeper.admin | |
org.apache.zookeeper.cli | |
org.apache.zookeeper.server |
ZooKeeper server theory of operation
|
org.apache.zookeeper.server.quorum |
Modifier and Type | Method and Description |
---|---|
static KeeperException |
KeeperException.create(int code)
Deprecated.
deprecated in 3.1.0, use
create(Code)
instead |
static KeeperException |
KeeperException.create(int code,
String path)
Deprecated.
deprecated in 3.1.0, use
create(Code, String)
instead |
static KeeperException |
KeeperException.create(KeeperException.Code code)
All non-specific keeper exceptions should be constructed via
this factory method in order to guarantee consistency in error
codes and such.
|
static KeeperException |
KeeperException.create(KeeperException.Code code,
String path)
All non-specific keeper exceptions should be constructed via
this factory method in order to guarantee consistency in error
codes and such.
|
Modifier and Type | Method and Description |
---|---|
void |
ZooKeeper.addWatch(String basePath,
AddWatchMode mode)
Add a watch to the given znode using the given mode.
|
void |
ZooKeeper.addWatch(String basePath,
Watcher watcher,
AddWatchMode mode)
Add a watch to the given znode using the given mode.
|
List<OpResult> |
Transaction.commit() |
String |
ZooKeeper.create(String path,
byte[] data,
List<ACL> acl,
CreateMode createMode)
Create a node with the given path.
|
String |
ZooKeeper.create(String path,
byte[] data,
List<ACL> acl,
CreateMode createMode,
Stat stat)
Create a node with the given path and returns the Stat of that node.
|
String |
ZooKeeper.create(String path,
byte[] data,
List<ACL> acl,
CreateMode createMode,
Stat stat,
long ttl)
same as
ZooKeeper.create(String, byte[], List, CreateMode, Stat) but
allows for specifying a TTL when mode is CreateMode.PERSISTENT_WITH_TTL
or CreateMode.PERSISTENT_SEQUENTIAL_WITH_TTL . |
void |
ZooKeeper.delete(String path,
int version)
Delete the node with the given path.
|
static void |
ZKUtil.deleteRecursive(ZooKeeper zk,
String pathRoot)
Same as {@link #deleteRecursive(org.apache.zookeeper.ZooKeeper, java.lang.String, int)
kept here for compatibility with 3.5 clients.
|
static void |
ZKUtil.deleteRecursive(ZooKeeper zk,
String pathRoot,
AsyncCallback.VoidCallback cb,
Object ctx)
Recursively delete the node with the given path.
|
static boolean |
ZKUtil.deleteRecursive(ZooKeeper zk,
String pathRoot,
int batchSize)
Recursively delete the node with the given path.
|
Stat |
ZooKeeper.exists(String path,
boolean watch)
Return the stat of the node of the given path.
|
Stat |
ZooKeeper.exists(String path,
Watcher watcher)
Return the stat of the node of the given path.
|
static CreateMode |
CreateMode.fromFlag(int flag)
Map an integer value to a CreateMode value
|
List<ACL> |
ZooKeeper.getACL(String path,
Stat stat)
Return the ACL and stat of the node of the given path.
|
int |
ZooKeeper.getAllChildrenNumber(String path)
Synchronously gets all numbers of children nodes under a specific path
|
List<String> |
ZooKeeper.getChildren(String path,
boolean watch)
Return the list of the children of the node of the given path.
|
List<String> |
ZooKeeper.getChildren(String path,
boolean watch,
Stat stat)
For the given znode path return the stat and children list.
|
List<String> |
ZooKeeper.getChildren(String path,
Watcher watcher)
Return the list of the children of the node of the given path.
|
List<String> |
ZooKeeper.getChildren(String path,
Watcher watcher,
Stat stat)
For the given znode path return the stat and children list.
|
byte[] |
ZooKeeper.getConfig(boolean watch,
Stat stat)
Return the last committed configuration (as known to the server to which the client is connected)
and the stat of the configuration.
|
byte[] |
ZooKeeper.getConfig(Watcher watcher,
Stat stat)
Return the last committed configuration (as known to the server to which the client is connected)
and the stat of the configuration.
|
byte[] |
ZooKeeper.getData(String path,
boolean watch,
Stat stat)
Return the data and the stat of the node of the given path.
|
byte[] |
ZooKeeper.getData(String path,
Watcher watcher,
Stat stat)
Return the data and the stat of the node of the given path.
|
List<String> |
ZooKeeper.getEphemerals()
Synchronously gets all the ephemeral nodes created by this session.
|
List<String> |
ZooKeeper.getEphemerals(String prefixPath)
Synchronously gets all the ephemeral nodes matching prefixPath
created by this session.
|
static List<String> |
ZKUtil.listSubTreeBFS(ZooKeeper zk,
String pathRoot)
BFS Traversal of the system under pathRoot, with the entries in the list, in the
same order as that of the traversal.
|
List<OpResult> |
ZooKeeper.multi(Iterable<Op> ops)
Executes multiple ZooKeeper operations.
|
protected List<OpResult> |
ZooKeeper.multiInternal(MultiOperationRecord request) |
void |
ZooKeeper.removeAllWatches(String path,
Watcher.WatcherType watcherType,
boolean local)
For the given znode path, removes all the registered watchers of given
watcherType.
|
void |
ZooKeeper.removeWatches(String path,
Watcher watcher,
Watcher.WatcherType watcherType,
boolean local)
For the given znode path, removes the specified watcher of given
watcherType.
|
Stat |
ZooKeeper.setACL(String path,
List<ACL> acl,
int aclVersion)
Set the ACL for the node of the given path if such a node exists and the
given aclVersion matches the acl version of the node.
|
Stat |
ZooKeeper.setData(String path,
byte[] data,
int version)
Set the data for the node of the given path if such a node exists and the
given version matches the version of the node (if the given version is
-1, it matches any node's versions).
|
Map<Watcher.Event.EventType,Set<Watcher>> |
WatchDeregistration.unregister(int rc)
Unregistering watcher that was added on path.
|
static void |
ZKUtil.visitSubTreeDFS(ZooKeeper zk,
String path,
boolean watch,
AsyncCallback.StringCallback cb)
Visits the subtree with root as given path and calls the passed callback with each znode
found during the search.
|
Modifier and Type | Method and Description |
---|---|
byte[] |
ZooKeeperAdmin.reconfigure(List<String> joiningServers,
List<String> leavingServers,
List<String> newMembers,
long fromConfig,
Stat stat)
Convenience wrapper around reconfig that takes Lists of strings instead of comma-separated servers.
|
byte[] |
ZooKeeperAdmin.reconfigure(String joiningServers,
String leavingServers,
String newMembers,
long fromConfig,
Stat stat)
Reconfigure - add/remove servers.
|
Modifier and Type | Method and Description |
---|---|
static boolean |
SetQuotaCommand.createQuota(ZooKeeper zk,
String path,
long bytes,
int numNodes) |
static boolean |
DelQuotaCommand.delQuota(ZooKeeper zk,
String path,
boolean bytes,
boolean numNodes)
this method deletes quota for a node.
|
Modifier and Type | Method and Description |
---|---|
KeeperException |
Request.getException() |
Modifier and Type | Method and Description |
---|---|
void |
Request.setException(KeeperException e) |
Modifier and Type | Method and Description |
---|---|
protected void |
PrepRequestProcessor.pRequest2Txn(int type,
long zxid,
Request request,
Record record,
boolean deserialize)
This method will be called inside the ProcessRequestThread, which is a
singleton, so there will be a single thread calling this code.
|
Modifier and Type | Method and Description |
---|---|
Request |
QuorumZooKeeperServer.checkUpgradeSession(Request request) |
Copyright © 2008–2021 The Apache Software Foundation. All rights reserved.