alluxio.hub.agent.rpc

Class AgentRpcServer

java.lang.Object

alluxio.hub.agent.rpc.AgentRpcServer

All Implemented Interfaces:

AutoCloseable

public class AgentRpcServer
extends Object
implements AutoCloseable

A wrapper around a GrpcServer that utilizes the Hub Agent 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
AgentRpcServer(AlluxioConfiguration conf, AgentProcessContext 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	getConfiguredAddress(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

AgentRpcServer

public AgentRpcServer(AlluxioConfiguration conf,
                      AgentProcessContext ctx)
               throws IOException

Creates and starts a new GrpcServer.

Parameters:

conf - alluxio configuration

ctx - the context used to instantiate the rpc services

Throws:

IOException - if the server fails to start

Method Detail

getConfiguredAddress

public static InetSocketAddress getConfiguredAddress(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