alluxio.master.transport

Class GrpcMessagingTransport

java.lang.Object

alluxio.master.transport.GrpcMessagingTransport

All Implemented Interfaces:

io.atomix.catalyst.transport.Transport, AutoCloseable

public class GrpcMessagingTransport
extends Object
implements io.atomix.catalyst.transport.Transport

Transport implementation based on Alluxio gRPC messaging.

Nested Class Summary

Nested classes/interfaces inherited from interface io.atomix.catalyst.transport.Transport

io.atomix.catalyst.transport.Transport.Builder

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method and Description
io.atomix.catalyst.transport.Client	client()
void	close()
io.atomix.catalyst.transport.Server	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 Transport 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 Transport 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 io.atomix.catalyst.transport.Client client()

Specified by:

client in interface io.atomix.catalyst.transport.Transport

server

public io.atomix.catalyst.transport.Server server()

Specified by:

server in interface io.atomix.catalyst.transport.Transport

close

public void close()

Specified by:

close in interface io.atomix.catalyst.transport.Transport

Specified by:

close in interface AutoCloseable