Package pt.ulisboa.tecnico.sdis.zk

Class ZKNaming

java.lang.Object

pt.ulisboa.tecnico.sdis.zk.ZKNaming

public class ZKNaming
extends Object

This class defines simple methods to bind service names to URI addresses: list, lookup, unbind, bind, rebind.

Author:

Rui Claro

Constructor Summary

Constructors

Constructor	Description
ZKNaming(String zkUrl)
ZKNaming(String host, String port)

Method Summary

Modifier and Type	Method	Description
void	bind(String path, String URI)	Binds the specified path with a URI
void	bind(String path, String host, String port)	Binds the specified path with a host port pair
void	bind(ZKRecord record)	Binds the specified record containing a path and a URI pair
Collection<ZKRecord>	listRecords(String path)	Returns a collection of records representing the child nodes of a zNode.
ZKRecord	lookup(String path)	Returns the record associated with the specified path.
void	rebind(String path, String URI)	Rebinds the specified path with a URI
void	rebind(String path, String host, String port)	Rebinds the specified path with a host port pair
void	rebind(ZKRecord record)	Rebinds the specified record.
void	unbind(String path, String URI)	Destroys the binding for the specified path with a URI.
void	unbind(String path, String host, String port)	Destroys the binding for the specified path with a host port pair.
void	unbind(ZKRecord record)	Destroys the binding for the specified record.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

ZKNaming

public ZKNaming(String zkUrl)

Parameters:

zkUrl - ZooKeeper url in format host:port

ZKNaming

public ZKNaming(String host,
                String port)

Parameters:

host - ZooKeeper host

port - ZooKeeper port

Method Detail

bind

public void bind(ZKRecord record)
          throws ZKNamingException

Binds the specified record containing a path and a URI pair

Parameters:

record - record to register

Throws:

ZKNamingException - If bind fails

bind

public void bind(String path,
                 String host,
                 String port)
          throws ZKNamingException

Binds the specified path with a host port pair

Parameters:

path - Path to the zNode

host - service host

port - service port

Throws:

ZKNamingException - If bind fails

bind

public void bind(String path,
                 String URI)
          throws ZKNamingException

Binds the specified path with a URI

Parameters:

path - Path to the zNode

URI - URI in the format host:port

Throws:

ZKNamingException - If bind fails

rebind

public void rebind(ZKRecord record)
            throws ZKNamingException

Rebinds the specified record. Existing record is overridden.

Parameters:

record - record to register

Throws:

ZKNamingException - If rebind fails

rebind

public void rebind(String path,
                   String URI)
            throws ZKNamingException

Rebinds the specified path with a URI

Parameters:

path - Path to the zNode

URI - URI in the format host:port

Throws:

ZKNamingException - If rebind fails

rebind

public void rebind(String path,
                   String host,
                   String port)
            throws ZKNamingException

Rebinds the specified path with a host port pair

Parameters:

path - Path to the zNode

host - service host

port - service port

Throws:

ZKNamingException - If rebind fails

unbind

public void unbind(ZKRecord record)
            throws ZKNamingException

Destroys the binding for the specified record.

Parameters:

record - record to delete

Throws:

ZKNamingException - if unbind fails

unbind

public void unbind(String path,
                   String URI)
            throws ZKNamingException

Destroys the binding for the specified path with a URI.

Parameters:

path - Path to the zNode

URI - URI in the format host:port

Throws:

ZKNamingException - if unbind fails

unbind

public void unbind(String path,
                   String host,
                   String port)
            throws ZKNamingException

Destroys the binding for the specified path with a host port pair.

Parameters:

path - Path to the zNode

host - service host

port - service port

Throws:

ZKNamingException - If unbind fails

lookup

public ZKRecord lookup(String path)
                throws ZKNamingException

Returns the record associated with the specified path.

Parameters:

path - Path to the zNode

Returns:

Record object with associated path and URI

Throws:

ZKNamingException - if lookup fails

listRecords

public Collection<ZKRecord> listRecords(String path)
                                 throws ZKNamingException

Returns a collection of records representing the child nodes of a zNode.

Parameters:

path - Path to the parent zNode

Returns:

Collection of record matching the children of provided zNode

Throws:

ZKNamingException - if listRecords fails