alluxio.hub.manager.rpc

Class ManagerRpcServer

java.lang.Object

alluxio.hub.manager.rpc.ManagerRpcServer

All Implemented Interfaces:

AutoCloseable

public class ManagerRpcServer
extends Object
implements AutoCloseable

A wrapper around a GrpcServer that utilizes the Hub Manager configuration. It will generate and utilize a self-signed certificate to encrypt the traffic between itself and clients. This requires all clients connecting to this server use an insecure client that trusts self-signed certificates. Its slightly better than plaintext, but still insecure as it can easily be MITMed. In the future, we may allow configuring certificates properly. The server starts serving after object creation. To stop the server call the close() method.

Constructor Summary

Constructors

Constructor and Description
ManagerRpcServer(AlluxioConfiguration conf, ManagerProcessContext ctx) Creates and starts a new GrpcServer.

Method Summary

Modifier and Type	Method and Description
void	awaitTermination() Blocks until the server is terminated.
void	close()
static InetSocketAddress	getBindAddress(AlluxioConfiguration conf)
static InetSocketAddress	getConnectAddress(AlluxioConfiguration conf)
int	getPort()
boolean	isServing()

Methods inherited from class java.lang.Object

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

Constructor Detail

ManagerRpcServer

public ManagerRpcServer(AlluxioConfiguration conf,
                        ManagerProcessContext ctx)
                 throws IOException

Creates and starts a new GrpcServer.

Parameters:

conf - alluxio configuration

ctx - the context of the process

Throws:

IOException - if the server fails to start

Method Detail

getBindAddress

public static InetSocketAddress getBindAddress(AlluxioConfiguration conf)

Parameters:

conf - alluxio configuration

Returns:

the address that this server will attempt to use based on the configuration

getConnectAddress

public static InetSocketAddress getConnectAddress(AlluxioConfiguration conf)

Parameters:

conf - alluxio configuration

Returns:

the address that this server will attempt to use based on the configuration

getPort

public int getPort()

Returns:

the port of the running server

isServing

public boolean isServing()

Returns:

whether the server is serving requests

awaitTermination

public void awaitTermination()

Blocks until the server is terminated.

close

public void close()

Specified by:

close in interface AutoCloseable