alluxio.master.journal.raft.transport

Class CopycatGrpcServerConnection

java.lang.Object

alluxio.master.journal.raft.transport.CopycatGrpcConnection

alluxio.master.journal.raft.transport.CopycatGrpcServerConnection

All Implemented Interfaces:

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

public class CopycatGrpcServerConnection
extends CopycatGrpcConnection

CopycatGrpcConnection implementation for server.

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
CopycatGrpcServerConnection(String transportId, io.atomix.catalyst.concurrent.ThreadContext context, ExecutorService executor, long requestTimeoutMs) Creates a connection object for server.

Method Summary

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

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

CopycatGrpcServerConnection

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

Creates a connection object for server. Note: CopycatGrpcConnection.setTargetObserver(io.grpc.stub.StreamObserver<alluxio.grpc.CopycatMessage>) 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