alluxio.master.transport

Class GrpcMessagingClientConnection

java.lang.Object

alluxio.master.transport.GrpcMessagingConnection

alluxio.master.transport.GrpcMessagingClientConnection

All Implemented Interfaces:

io.grpc.stub.StreamObserver<TransportMessage>

public class GrpcMessagingClientConnection
extends GrpcMessagingConnection

GrpcMessagingConnection implementation for clients.

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
GrpcMessagingClientConnection(GrpcMessagingContext context, ExecutorService executor, GrpcChannel channel, long requestTimeoutMs) Creates a messaging connection for client.

Method Summary

Modifier and Type	Method and Description
CompletableFuture<Void>	close() Closes the connection.

Methods inherited from class alluxio.master.transport.GrpcMessagingConnection

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

GrpcMessagingClientConnection

public GrpcMessagingClientConnection(GrpcMessagingContext context,
                                     ExecutorService executor,
                                     GrpcChannel channel,
                                     long requestTimeoutMs)

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

Parameters:

context - catalyst thread context

executor - transport executor

channel - underlying gRPC channel

requestTimeoutMs - timeout in milliseconds for requests

Method Detail

close

public CompletableFuture<Void> close()

Description copied from class: GrpcMessagingConnection

Closes the connection.

Overrides:

close in class GrpcMessagingConnection

Returns:

future of close results