alluxio.master.transport

Class GrpcMessagingServiceClientHandler

java.lang.Object

alluxio.grpc.MessagingServiceGrpc.MessagingServiceImplBase

alluxio.master.transport.GrpcMessagingServiceClientHandler

All Implemented Interfaces:

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(io.atomix.catalyst.transport.Address serverAddress, java.util.function.Consumer<io.atomix.catalyst.transport.Connection> listener, io.atomix.catalyst.concurrent.ThreadContext 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(io.atomix.catalyst.transport.Address serverAddress,
                                         java.util.function.Consumer<io.atomix.catalyst.transport.Connection> listener,
                                         io.atomix.catalyst.concurrent.ThreadContext 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.

Overrides:

connect in class MessagingServiceGrpc.MessagingServiceImplBase

Parameters:

responseObserver - client's stream observer

Returns:

server's stream observer