alluxio.master.journal.raft.transport

Class CopycatGrpcServer

java.lang.Object

alluxio.master.journal.raft.transport.CopycatGrpcServer

All Implemented Interfaces:

io.atomix.catalyst.transport.Server

public class CopycatGrpcServer
extends Object
implements io.atomix.catalyst.transport.Server

Copycat transport Server implementation that uses Alluxio gRPC. Copycat guarantees each server will be used for listening only one address and won't be recycled. It also guarantees that active listen future will be completed before calling close.

Constructor Summary

Constructors

Constructor and Description
CopycatGrpcServer(AlluxioConfiguration conf, UserState userState, ExecutorService executor, CopycatGrpcProxy proxy) Creates copycat transport server that can be used to accept connections from remote copycat clients.

Method Summary

Modifier and Type	Method and Description
CompletableFuture<Void>	close()
CompletableFuture<Void>	listen(io.atomix.catalyst.transport.Address address, java.util.function.Consumer<io.atomix.catalyst.transport.Connection> listener)

Methods inherited from class java.lang.Object

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

Constructor Detail

CopycatGrpcServer

public CopycatGrpcServer(AlluxioConfiguration conf,
                         UserState userState,
                         ExecutorService executor,
                         CopycatGrpcProxy proxy)

Creates copycat transport server that can be used to accept connections from remote copycat clients.

Parameters:

conf - Alluxio configuration

userState - authentication user

executor - transport executor

proxy - external proxy configuration

Method Detail

listen

public CompletableFuture<Void> listen(io.atomix.catalyst.transport.Address address,
                                      java.util.function.Consumer<io.atomix.catalyst.transport.Connection> listener)

Specified by:

listen in interface io.atomix.catalyst.transport.Server

close

public CompletableFuture<Void> close()

Specified by:

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