org.apache.zookeeper
Class ZooKeeperMain

java.lang.Object
  extended by 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
           
 
Constructor Summary
ZooKeeperMain(java.lang.String[] args)
           
ZooKeeperMain(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
 

Field Detail

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
Constructor Detail

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)
Method Detail

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 client
path - the path to delete quota for
bytes - true if number of bytes needs to be unset
numNodes - 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 client
path - the path for which quota needs to be created
bytes - the limit of bytes on this path
numNodes - 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 © 2010 The Apache Software Foundation