alluxio.master.transport

Class GrpcMessagingServiceClientHandler

java.lang.Object

alluxio.grpc.MessagingServiceGrpc.MessagingServiceImplBase

alluxio.master.transport.GrpcMessagingServiceClientHandler

All Implemented Interfaces:

MessagingServiceGrpc.AsyncService, io.grpc.BindableService

public class GrpcMessagingServiceClientHandler
extends MessagingServiceGrpc.MessagingServiceImplBase

gRPC service handler for message exchange between messaging clients and servers that are created by GrpcMessagingTransport.

Constructor Summary

Constructors

Constructor and Description
GrpcMessagingServiceClientHandler(InetSocketAddress serverAddress, java.util.function.Consumer<GrpcMessagingConnection> listener, GrpcMessagingContext context, ExecutorService executor, long requestTimeoutMs)

Method Summary

Modifier and Type	Method and Description
io.grpc.stub.StreamObserver<TransportMessage>	connect(io.grpc.stub.StreamObserver<TransportMessage> responseObserver) RPC for establishing bi-di stream between client/server.

Methods inherited from class alluxio.grpc.MessagingServiceGrpc.MessagingServiceImplBase

bindService

Methods inherited from class java.lang.Object

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

Constructor Detail

GrpcMessagingServiceClientHandler

public GrpcMessagingServiceClientHandler(InetSocketAddress serverAddress,
                                         java.util.function.Consumer<GrpcMessagingConnection> listener,
                                         GrpcMessagingContext context,
                                         ExecutorService executor,
                                         long requestTimeoutMs)

Parameters:

serverAddress - server address

listener - listener for incoming connections

context - catalyst thread context

executor - transport executor

requestTimeoutMs - request timeout value for new connections

Method Detail

connect

public io.grpc.stub.StreamObserver<TransportMessage> connect(io.grpc.stub.StreamObserver<TransportMessage> responseObserver)

RPC for establishing bi-di stream between client/server.

Parameters:

responseObserver - client's stream observer

Returns:

server's stream observer