org.apache.zookeeper
Class ZooKeeperMain
java.lang.Object
org.apache.zookeeper.ZooKeeperMain
public class ZooKeeperMain
- extends java.lang.Object
The command line client to ZooKeeper.
Field Summary |
protected org.apache.zookeeper.ZooKeeperMain.MyCommandOptions |
cl
|
protected int |
commandCount
|
protected static java.util.Map<java.lang.String,java.lang.String> |
commandMap
|
protected java.util.HashMap<java.lang.Integer,java.lang.String> |
history
|
protected java.lang.String |
host
|
protected boolean |
printWatches
|
protected ZooKeeper |
zk
|
Method Summary |
protected void |
addToHistory(int i,
java.lang.String cmd)
Makes a list of possible completions, either for commands
or for zk nodes if the token to complete begins with / |
protected void |
connectToZK(java.lang.String newHost)
|
static boolean |
createQuota(ZooKeeper zk,
java.lang.String path,
long bytes,
int numNodes)
this method creates a quota node for the path |
static boolean |
delQuota(ZooKeeper zk,
java.lang.String path,
boolean bytes,
boolean numNodes)
this method deletes quota for a node. |
void |
executeLine(java.lang.String line)
|
static java.util.List<java.lang.String> |
getCommands()
|
boolean |
getPrintWatches()
|
protected java.lang.String |
getPrompt()
|
static void |
main(java.lang.String[] args)
|
static void |
printMessage(java.lang.String msg)
|
protected boolean |
processCmd(org.apache.zookeeper.ZooKeeperMain.MyCommandOptions co)
|
protected boolean |
processZKCmd(org.apache.zookeeper.ZooKeeperMain.MyCommandOptions co)
|
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
commandMap
protected static final java.util.Map<java.lang.String,java.lang.String> commandMap
cl
protected org.apache.zookeeper.ZooKeeperMain.MyCommandOptions cl
history
protected java.util.HashMap<java.lang.Integer,java.lang.String> history
commandCount
protected int commandCount
printWatches
protected boolean printWatches
zk
protected ZooKeeper zk
host
protected java.lang.String host
ZooKeeperMain
public ZooKeeperMain(java.lang.String[] args)
throws java.io.IOException,
java.lang.InterruptedException
- Throws:
java.io.IOException
java.lang.InterruptedException
ZooKeeperMain
public ZooKeeperMain(ZooKeeper zk)
getPrintWatches
public boolean getPrintWatches()
addToHistory
protected void addToHistory(int i,
java.lang.String cmd)
- Makes a list of possible completions, either for commands
or for zk nodes if the token to complete begins with /
getCommands
public static java.util.List<java.lang.String> getCommands()
getPrompt
protected java.lang.String getPrompt()
printMessage
public static void printMessage(java.lang.String msg)
connectToZK
protected void connectToZK(java.lang.String newHost)
throws java.lang.InterruptedException,
java.io.IOException
- Throws:
java.lang.InterruptedException
java.io.IOException
main
public static void main(java.lang.String[] args)
throws KeeperException,
java.io.IOException,
java.lang.InterruptedException
- Throws:
KeeperException
java.io.IOException
java.lang.InterruptedException
executeLine
public void executeLine(java.lang.String line)
throws java.lang.InterruptedException,
java.io.IOException,
KeeperException
- Throws:
java.lang.InterruptedException
java.io.IOException
KeeperException
delQuota
public static boolean delQuota(ZooKeeper zk,
java.lang.String path,
boolean bytes,
boolean numNodes)
throws KeeperException,
java.io.IOException,
java.lang.InterruptedException
- this method deletes quota for a node.
- Parameters:
zk
- the zookeeper clientpath
- the path to delete quota forbytes
- true if number of bytes needs to
be unsetnumNodes
- true if number of nodes needs
to be unset
- Returns:
- true if quota deletion is successful
- Throws:
KeeperException
java.io.IOException
java.lang.InterruptedException
createQuota
public static boolean createQuota(ZooKeeper zk,
java.lang.String path,
long bytes,
int numNodes)
throws KeeperException,
java.io.IOException,
java.lang.InterruptedException
- this method creates a quota node for the path
- Parameters:
zk
- the ZooKeeper clientpath
- the path for which quota needs to be createdbytes
- the limit of bytes on this pathnumNodes
- the limit of number of nodes on this path
- Returns:
- true if its successful and false if not.
- Throws:
KeeperException
java.io.IOException
java.lang.InterruptedException
processCmd
protected boolean processCmd(org.apache.zookeeper.ZooKeeperMain.MyCommandOptions co)
throws KeeperException,
java.io.IOException,
java.lang.InterruptedException
- Throws:
KeeperException
java.io.IOException
java.lang.InterruptedException
processZKCmd
protected boolean processZKCmd(org.apache.zookeeper.ZooKeeperMain.MyCommandOptions co)
throws KeeperException,
java.io.IOException,
java.lang.InterruptedException
- Throws:
KeeperException
java.io.IOException
java.lang.InterruptedException
Copyright © 2012 The Apache Software Foundation