alluxio.master.transport

Class GrpcMessagingServerConnection

java.lang.Object

alluxio.master.transport.GrpcMessagingConnection

alluxio.master.transport.GrpcMessagingServerConnection

All Implemented Interfaces:

io.atomix.catalyst.transport.Connection, io.grpc.stub.StreamObserver<TransportMessage>

public class GrpcMessagingServerConnection
extends GrpcMessagingConnection

GrpcMessagingConnection implementation for server.

Nested Class Summary

Nested classes/interfaces inherited from class alluxio.master.transport.GrpcMessagingConnection

GrpcMessagingConnection.ConnectionOwner, GrpcMessagingConnection.ContextualFuture<T>, GrpcMessagingConnection.HandlerHolder

Constructor Summary

Constructors

Constructor and Description
GrpcMessagingServerConnection(String transportId, io.atomix.catalyst.concurrent.ThreadContext context, ExecutorService executor, long requestTimeoutMs) Creates a messaging connection for server.

Method Summary

Methods inherited from class alluxio.master.transport.GrpcMessagingConnection

close, handler, handler, handleResponseMessage, onClose, onCompleted, onError, onException, onNext, send, sendAndReceive, setTargetObserver, toString

Methods inherited from class java.lang.Object

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

Constructor Detail

GrpcMessagingServerConnection

public GrpcMessagingServerConnection(String transportId,
                                     io.atomix.catalyst.concurrent.ThreadContext context,
                                     ExecutorService executor,
                                     long requestTimeoutMs)

Creates a messaging connection for server. Note: GrpcMessagingConnection.setTargetObserver(io.grpc.stub.StreamObserver<alluxio.grpc.TransportMessage>) should be called explicitly before using the connection.

Parameters:

transportId - transport Id for this connection

context - copycat thread context

executor - transport executor

requestTimeoutMs - timeout in milliseconds for requests