alluxio.master.journal.raft.transport

Class CopycatGrpcConnection

java.lang.Object

alluxio.master.journal.raft.transport.CopycatGrpcConnection

All Implemented Interfaces:

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

Direct Known Subclasses:

CopycatGrpcClientConnection, CopycatGrpcServerConnection

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

Abstract copycat transport Connection implementation that uses Alluxio gRPC.

Nested Class Summary

Nested Classes

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

Constructor Summary

Constructors

Constructor and Description
CopycatGrpcConnection(CopycatGrpcConnection.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(CopycatMessage 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(CopycatMessage message)
CompletableFuture<Void>	send(Object request)
<T,U> CompletableFuture<U>	sendAndReceive(T request)
void	setTargetObserver(io.grpc.stub.StreamObserver<CopycatMessage> 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

CopycatGrpcConnection

public CopycatGrpcConnection(CopycatGrpcConnection.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.CopycatMessage>) should be called explicitly before using the connection.

Parameters:

connectionOwner - owner of connection

transportId - transport level Id

context - copycat thread context

executor - transport executor

requestTimeoutMs - timeout in milliseconds for requests

Method Detail

setTargetObserver

public void setTargetObserver(io.grpc.stub.StreamObserver<CopycatMessage> 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(CopycatMessage 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(CopycatMessage message)

Specified by:

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

onError

public void onError(Throwable t)

Specified by:

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

onCompleted

public void onCompleted()

Specified by:

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

toString

public String toString()

Overrides:

toString in class Object