Package | Description |
---|---|
org.apache.zookeeper | |
org.apache.zookeeper.admin | |
org.apache.zookeeper.cli | |
org.apache.zookeeper.server |
ZooKeeper server theory of operation
ZooKeeperServer is designed to work in standalone mode and also
be extensible so that it can be used to implement the quorum based
version of ZooKeeper.
|
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,
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–2020 The Apache Software Foundation. All rights reserved.