alluxio.master.transport

Class GrpcMessagingClient

java.lang.Object

alluxio.master.transport.GrpcMessagingClient

All Implemented Interfaces:

io.atomix.catalyst.transport.Client

public class GrpcMessagingClient
extends Object
implements io.atomix.catalyst.transport.Client

Client implementation based on Alluxio gRPC messaging. Listen should be called once for each distinct address. Pending futures should all be closed prior to calling close().

Constructor Summary

Constructors

Constructor and Description
GrpcMessagingClient(AlluxioConfiguration conf, UserState userState, ExecutorService executor, String clientType) Creates messaging client that can be used to connect to remote messaging servers.

Method Summary

Modifier and Type	Method and Description
CompletableFuture<Void>	close()
CompletableFuture<io.atomix.catalyst.transport.Connection>	connect(io.atomix.catalyst.transport.Address address)

Methods inherited from class java.lang.Object

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

Constructor Detail

GrpcMessagingClient

public GrpcMessagingClient(AlluxioConfiguration conf,
                           UserState userState,
                           ExecutorService executor,
                           String clientType)

Creates messaging client that can be used to connect to remote messaging servers.

Parameters:

conf - Alluxio configuration

userState - authentication user

executor - messaging executor

clientType - transport client type

Method Detail

connect

public CompletableFuture<io.atomix.catalyst.transport.Connection> connect(io.atomix.catalyst.transport.Address address)

Specified by:

connect in interface io.atomix.catalyst.transport.Client

close

public CompletableFuture<Void> close()

Specified by:

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