alluxio.master.journal.raft.transport

Class CopycatMessageServiceClientHandler

java.lang.Object

alluxio.grpc.CopycatMessageServerGrpc.CopycatMessageServerImplBase

alluxio.master.journal.raft.transport.CopycatMessageServiceClientHandler

All Implemented Interfaces:

io.grpc.BindableService

public class CopycatMessageServiceClientHandler
extends CopycatMessageServerGrpc.CopycatMessageServerImplBase

gRPC service handler for message exchange between copycat clients and servers that are created by CopycatGrpcTransport.

Constructor Summary

Constructors

Constructor and Description
CopycatMessageServiceClientHandler(io.atomix.catalyst.transport.Address serverAddress, java.util.function.Consumer<io.atomix.catalyst.transport.Connection> listener, io.atomix.catalyst.concurrent.ThreadContext context, ExecutorService executor, long requestTimeoutMs)

Method Summary

Modifier and Type	Method and Description
io.grpc.stub.StreamObserver<CopycatMessage>	connect(io.grpc.stub.StreamObserver<CopycatMessage> responseObserver) RPC for establishing bi-di stream between client/server.

Methods inherited from class alluxio.grpc.CopycatMessageServerGrpc.CopycatMessageServerImplBase

bindService

Methods inherited from class java.lang.Object

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

Constructor Detail

CopycatMessageServiceClientHandler

public CopycatMessageServiceClientHandler(io.atomix.catalyst.transport.Address serverAddress,
                                          java.util.function.Consumer<io.atomix.catalyst.transport.Connection> listener,
                                          io.atomix.catalyst.concurrent.ThreadContext context,
                                          ExecutorService executor,
                                          long requestTimeoutMs)

Parameters:

serverAddress - server address

listener - listener for incoming connections

context - copycat thread context

executor - transport executor

requestTimeoutMs - request timeout value for new connections

Method Detail

connect

public io.grpc.stub.StreamObserver<CopycatMessage> connect(io.grpc.stub.StreamObserver<CopycatMessage> responseObserver)

RPC for establishing bi-di stream between client/server.

Overrides:

connect in class CopycatMessageServerGrpc.CopycatMessageServerImplBase

Parameters:

responseObserver - client's stream observer

Returns:

server's stream observer