org.apache.reef.io.network.naming

Class NameClient

java.lang.Object

org.apache.reef.io.network.naming.NameClient

All Implemented Interfaces:

AutoCloseable, Naming, NamingLookup, NamingRegistry, Stage

public class NameClient
extends Object
implements Stage, Naming

Naming client

Constructor Summary

Constructors

Constructor and Description
NameClient(String serverAddr, int serverPort, IdentifierFactory factory, int retryCount, int retryTimeout, Cache<Identifier,InetSocketAddress> cache) Constructs a naming client
NameClient(String serverAddr, int serverPort, long timeout, IdentifierFactory factory, int retryCount, int retryTimeout, Cache<Identifier,InetSocketAddress> cache) Constructs a naming client

Method Summary

Methods

Modifier and Type	Method and Description
void	close() Closes resources
InetSocketAddress	lookup(Identifier id) Finds an address for an identifier
void	register(Identifier id, InetSocketAddress addr) Registers an (identifier, address) mapping
InetSocketAddress	remoteLookup(Identifier id) Retrieves an address for an identifier remotely
void	unregister(Identifier id) Unregisters an identifier

Methods inherited from class java.lang.Object

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

Constructor Detail

NameClient

public NameClient(String serverAddr,
          int serverPort,
          IdentifierFactory factory,
          int retryCount,
          int retryTimeout,
          Cache<Identifier,InetSocketAddress> cache)

Constructs a naming client

Parameters:

serverAddr - a server address

serverPort - a server port number

factory - an identifier factory

cache - a cache

NameClient

public NameClient(String serverAddr,
          int serverPort,
          long timeout,
          IdentifierFactory factory,
          int retryCount,
          int retryTimeout,
          Cache<Identifier,InetSocketAddress> cache)

Constructs a naming client

Parameters:

serverAddr - a server address

serverPort - a server port number

timeout - timeout in ms

factory - an identifier factory

cache - a cache

Method Detail

register

public void register(Identifier id,
            InetSocketAddress addr)
              throws Exception

Registers an (identifier, address) mapping

Specified by:

register in interface NamingRegistry

Parameters:

id - an identifier

addr - an Internet socket address

Throws:

Exception

unregister

public void unregister(Identifier id)
                throws IOException

Unregisters an identifier

Specified by:

unregister in interface NamingRegistry

Parameters:

id - an identifier

Throws:

IOException

lookup

public InetSocketAddress lookup(Identifier id)
                         throws Exception

Finds an address for an identifier

Specified by:

lookup in interface NamingLookup

Parameters:

id - an identifier

Returns:

an Internet socket address

Throws:

IOException

Exception

remoteLookup

public InetSocketAddress remoteLookup(Identifier id)
                               throws Exception

Retrieves an address for an identifier remotely

Parameters:

id - an identifier

Returns:

an Internet socket address

Throws:

Exception

close

public void close()
           throws Exception

Closes resources

Specified by:

close in interface AutoCloseable

Throws:

Exception