Field Detail

• DEFAULT_ROOT_NODE

  private static final String DEFAULT_ROOT_NODE

  See Also:

  Constant Field Values

• DEFAULT_KEYS_PARENT

  private static final String DEFAULT_KEYS_PARENT

  See Also:

  Constant Field Values

• LOG

  private static final org.apache.commons.logging.Log LOG

• secretManager

  private AuthenticationTokenSecretManager secretManager

• baseKeyZNode

  private String baseKeyZNode

• keysParentZNode

  private String keysParentZNode

Constructor Detail

• ZKSecretWatcher

  public ZKSecretWatcher(org.apache.hadoop.conf.Configuration conf,
                 ZooKeeperWatcher watcher,
                 AuthenticationTokenSecretManager secretManager)

Method Detail

• start

  public void start()
             throws org.apache.zookeeper.KeeperException

  Throws:

  org.apache.zookeeper.KeeperException

• nodeCreated

  public void nodeCreated(String path)

  Description copied from class: ZooKeeperListener
  Called when a new node has been created.

  Overrides:

  nodeCreated in class ZooKeeperListener

  Parameters:

  path - full path of the new node

• nodeDeleted

  public void nodeDeleted(String path)

  Description copied from class: ZooKeeperListener
  Called when a node has been deleted

  Overrides:

  nodeDeleted in class ZooKeeperListener

  Parameters:

  path - full path of the deleted node

• nodeDataChanged

  public void nodeDataChanged(String path)

  Description copied from class: ZooKeeperListener
  Called when an existing node has changed data.

  Overrides:

  nodeDataChanged in class ZooKeeperListener

  Parameters:

  path - full path of the updated node

• nodeChildrenChanged

  public void nodeChildrenChanged(String path)

  Description copied from class: ZooKeeperListener
  Called when an existing node has a child node added or removed.

  Overrides:

  nodeChildrenChanged in class ZooKeeperListener

  Parameters:

  path - full path of the node whose children have changed

• getRootKeyZNode

  public String getRootKeyZNode()

• refreshNodes

  private void refreshNodes(List<ZKUtil.NodeAndData> nodes)

• getKeyNode

  private String getKeyNode(int keyId)

• removeKeyFromZK

  public void removeKeyFromZK(AuthenticationKey key)

• addKeyToZK

  public void addKeyToZK(AuthenticationKey key)

• updateKeyInZK

  public void updateKeyInZK(AuthenticationKey key)

• refreshKeys

  void refreshKeys()

  refresh keys

• getKeysParentZNode

  String getKeysParentZNode()

  get token keys parent node

  Returns:

  token keys parent node