org.apache.reef.io.network.naming

Class NameLookupClient

java.lang.Object

org.apache.reef.io.network.naming.NameLookupClient

All Implemented Interfaces:

AutoCloseable, NamingLookup, Stage

public class NameLookupClient
extends Object
implements Stage, NamingLookup

Naming lookup client

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	NameLookupClient.RetryCount
static class	NameLookupClient.RetryTimeout

Constructor Summary

Constructors

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

Method Summary

Methods

Modifier and Type	Method and Description
void	close() Closes resources
InetSocketAddress	lookup(Identifier id) Finds an address for an identifier
InetSocketAddress	remoteLookup(Identifier id) Retrieves an address for an identifier remotely

Methods inherited from class java.lang.Object

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

Constructor Detail

NameLookupClient

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

Constructs a naming lookup client

Parameters:

serverAddr - a server address

serverPort - a server port number

factory - an identifier factory

cache - an cache

NameLookupClient

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

Constructs a naming lookup client

Parameters:

serverAddr - a server address

serverPort - a server port number

timeout - request timeout in ms

factory - an identifier factory

cache - an cache

Method Detail

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