alluxio.master.transport

Class GrpcMessagingTransport

java.lang.Object

alluxio.master.transport.GrpcMessagingTransport

public class GrpcMessagingTransport
extends Object

Transport implementation based on Alluxio gRPC messaging.

Constructor Summary

Constructors

Constructor and Description
GrpcMessagingTransport(AlluxioConfiguration clientConf, AlluxioConfiguration serverConf, UserState clientUser, UserState serverUser, String clientType) Creates GrpcMessagingTransport based on Alluxio gRPC messaging.
GrpcMessagingTransport(AlluxioConfiguration conf, UserState user, String clientType) Creates GrpcMessagingTransport based on Alluxio gRPC messaging.

Method Summary

Modifier and Type	Method and Description
GrpcMessagingClient	client() Creates a new Grpc messaging client.
void	close() Closes the opened clients and servers.
GrpcMessagingServer	server() Creates a new Grpc messaging server.
GrpcMessagingTransport	withServerProxy(GrpcMessagingProxy proxy) Sets external proxy configuration for servers.

Methods inherited from class java.lang.Object

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

Constructor Detail

GrpcMessagingTransport

public GrpcMessagingTransport(AlluxioConfiguration conf,
                              UserState user,
                              String clientType)

Creates GrpcMessagingTransport based on Alluxio gRPC messaging.

Parameters:

conf - Alluxio configuration

user - Alluxio user

clientType - Transport client type

GrpcMessagingTransport

public GrpcMessagingTransport(AlluxioConfiguration clientConf,
                              AlluxioConfiguration serverConf,
                              UserState clientUser,
                              UserState serverUser,
                              String clientType)

Creates GrpcMessagingTransport based on Alluxio gRPC messaging.

Parameters:

clientConf - Alluxio configuration for clients

serverConf - Alluxio configuration for servers

clientUser - User for clients

serverUser - User for servers

clientType - Transport client type

Method Detail

withServerProxy

public GrpcMessagingTransport withServerProxy(GrpcMessagingProxy proxy)

Sets external proxy configuration for servers.

Parameters:

proxy - external proxy configuration

Returns:

the updated transport instance

client

public GrpcMessagingClient client()

Creates a new Grpc messaging client.

Returns:

the created client

server

public GrpcMessagingServer server()

Creates a new Grpc messaging server.

Returns:

the created server

close

public void close()

Closes the opened clients and servers.