alluxio.master.transport

Class GrpcMessagingConnection

java.lang.Object

alluxio.master.transport.GrpcMessagingConnection

All Implemented Interfaces:

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

Direct Known Subclasses:

GrpcMessagingClientConnection, GrpcMessagingServerConnection

public abstract class GrpcMessagingConnection
extends Object
implements io.atomix.catalyst.transport.Connection, io.grpc.stub.StreamObserver<TransportMessage>

Abstract Connection implementation based on Alluxio gRPC messaging.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
protected static class	GrpcMessagingConnection.ConnectionOwner Defines the owner of connection.
protected static class	GrpcMessagingConnection.ContextualFuture<T> A future with catalyst thread context.
protected static class	GrpcMessagingConnection.HandlerHolder Holds message handler and catalyst thread context.

Constructor Summary

Constructors

Constructor and Description
GrpcMessagingConnection(GrpcMessagingConnection.ConnectionOwner connectionOwner, String transportId, io.atomix.catalyst.concurrent.ThreadContext context, ExecutorService executor, long requestTimeoutMs) Creates a connection object.

Method Summary

Modifier and Type	Method and Description
CompletableFuture<Void>	close()
<T,U> io.atomix.catalyst.transport.Connection	handler(Class<T> type, java.util.function.Consumer<T> handler)
<T,U> io.atomix.catalyst.transport.Connection	handler(Class<T> type, java.util.function.Function<T,CompletableFuture<U>> handler)
protected void	handleResponseMessage(TransportMessage response)
io.atomix.catalyst.concurrent.Listener<io.atomix.catalyst.transport.Connection>	onClose(java.util.function.Consumer<io.atomix.catalyst.transport.Connection> listener)
void	onCompleted()
void	onError(Throwable t)
io.atomix.catalyst.concurrent.Listener<Throwable>	onException(java.util.function.Consumer<Throwable> listener)
void	onNext(TransportMessage message)
CompletableFuture<Void>	send(Object request)
<T,U> CompletableFuture<U>	sendAndReceive(T request)
void	setTargetObserver(io.grpc.stub.StreamObserver<TransportMessage> targetObserver) Sets the stream observer for target.
String	toString()

Methods inherited from class java.lang.Object

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

Constructor Detail

GrpcMessagingConnection

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

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

Parameters:

connectionOwner - owner of connection

transportId - transport level Id

context - catalyst thread context

executor - transport executor

requestTimeoutMs - timeout in milliseconds for requests

Method Detail

setTargetObserver

public void setTargetObserver(io.grpc.stub.StreamObserver<TransportMessage> targetObserver)

Sets the stream observer for target.

Parameters:

targetObserver - target's stream observer

send

public CompletableFuture<Void> send(Object request)

Specified by:

send in interface io.atomix.catalyst.transport.Connection

sendAndReceive

public <T,U> CompletableFuture<U> sendAndReceive(T request)

Specified by:

sendAndReceive in interface io.atomix.catalyst.transport.Connection

handler

public <T,U> io.atomix.catalyst.transport.Connection handler(Class<T> type,
                                                             java.util.function.Consumer<T> handler)

Specified by:

handler in interface io.atomix.catalyst.transport.Connection

handler

public <T,U> io.atomix.catalyst.transport.Connection handler(Class<T> type,
                                                             java.util.function.Function<T,CompletableFuture<U>> handler)

Specified by:

handler in interface io.atomix.catalyst.transport.Connection

handleResponseMessage

protected void handleResponseMessage(TransportMessage response)

onException

public io.atomix.catalyst.concurrent.Listener<Throwable> onException(java.util.function.Consumer<Throwable> listener)

Specified by:

onException in interface io.atomix.catalyst.transport.Connection

onClose

public io.atomix.catalyst.concurrent.Listener<io.atomix.catalyst.transport.Connection> onClose(java.util.function.Consumer<io.atomix.catalyst.transport.Connection> listener)

Specified by:

onClose in interface io.atomix.catalyst.transport.Connection

close

public CompletableFuture<Void> close()

Specified by:

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

onNext

public void onNext(TransportMessage message)

Specified by:

onNext in interface io.grpc.stub.StreamObserver<TransportMessage>

onError

public void onError(Throwable t)

Specified by:

onError in interface io.grpc.stub.StreamObserver<TransportMessage>

onCompleted

public void onCompleted()

Specified by:

onCompleted in interface io.grpc.stub.StreamObserver<TransportMessage>

toString

public String toString()

Overrides:

toString in class Object