alluxio.master.journal.raft.transport

Class CopycatGrpcClientConnection

java.lang.Object

alluxio.master.journal.raft.transport.CopycatGrpcConnection

alluxio.master.journal.raft.transport.CopycatGrpcClientConnection

All Implemented Interfaces:

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

public class CopycatGrpcClientConnection
extends CopycatGrpcConnection

CopycatGrpcConnection implementation for client.

Nested Class Summary

Nested classes/interfaces inherited from class alluxio.master.journal.raft.transport.CopycatGrpcConnection

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

Constructor Summary

Constructors

Constructor and Description
CopycatGrpcClientConnection(io.atomix.catalyst.concurrent.ThreadContext context, ExecutorService executor, GrpcChannel channel, long requestTimeoutMs) Creates a connection object for client.

Method Summary

Modifier and Type	Method and Description
CompletableFuture<Void>	close()

Methods inherited from class alluxio.master.journal.raft.transport.CopycatGrpcConnection

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

CopycatGrpcClientConnection

public CopycatGrpcClientConnection(io.atomix.catalyst.concurrent.ThreadContext context,
                                   ExecutorService executor,
                                   GrpcChannel channel,
                                   long requestTimeoutMs)

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

Parameters:

context - copycat thread context

executor - transport executor

channel - underlying gRPC channel

requestTimeoutMs - timeout in milliseconds for requests

Method Detail

close

public CompletableFuture<Void> close()

Specified by:

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

Overrides:

close in class CopycatGrpcConnection