@InterfaceAudience.Private public class ZKNamespaceManager extends ZooKeeperListener
Modifier and Type | Field and Description |
---|---|
private NavigableMap<String,NamespaceDescriptor> |
cache |
private static org.apache.commons.logging.Log |
LOG |
private String |
nsZNode |
watcher
Constructor and Description |
---|
ZKNamespaceManager(ZooKeeperWatcher zkw) |
Modifier and Type | Method and Description |
---|---|
private void |
deleteNamespace(String name) |
NamespaceDescriptor |
get(String name) |
NavigableSet<NamespaceDescriptor> |
list() |
void |
nodeChildrenChanged(String path)
Called when an existing node has a child node added or removed.
|
void |
nodeCreated(String path)
Called when a new node has been created.
|
void |
nodeDataChanged(String path)
Called when an existing node has changed data.
|
void |
nodeDeleted(String path)
Called when a node has been deleted
|
private void |
refreshNodes(List<ZKUtil.NodeAndData> nodes) |
void |
remove(String name) |
void |
start() |
void |
update(NamespaceDescriptor ns) |
private void |
writeNamespace(NamespaceDescriptor ns) |
getWatcher
private static final org.apache.commons.logging.Log LOG
private final String nsZNode
private volatile NavigableMap<String,NamespaceDescriptor> cache
public ZKNamespaceManager(ZooKeeperWatcher zkw) throws IOException
IOException
public void start() throws IOException
IOException
public NamespaceDescriptor get(String name)
public void update(NamespaceDescriptor ns) throws IOException
IOException
public void remove(String name) throws IOException
IOException
public NavigableSet<NamespaceDescriptor> list() throws IOException
IOException
public void nodeCreated(String path)
ZooKeeperListener
nodeCreated
in class ZooKeeperListener
path
- full path of the new nodepublic void nodeDeleted(String path)
ZooKeeperListener
nodeDeleted
in class ZooKeeperListener
path
- full path of the deleted nodepublic void nodeDataChanged(String path)
ZooKeeperListener
nodeDataChanged
in class ZooKeeperListener
path
- full path of the updated nodepublic void nodeChildrenChanged(String path)
ZooKeeperListener
nodeChildrenChanged
in class ZooKeeperListener
path
- full path of the node whose children have changedprivate void deleteNamespace(String name) throws IOException
IOException
private void writeNamespace(NamespaceDescriptor ns) throws IOException
IOException
private void refreshNodes(List<ZKUtil.NodeAndData> nodes) throws IOException
IOException
Copyright © 2007–2019 The Apache Software Foundation. All rights reserved.