alluxio.master.journal.raft.transport

Class CopycatGrpcClient

java.lang.Object

alluxio.master.journal.raft.transport.CopycatGrpcClient

All Implemented Interfaces:

io.atomix.catalyst.transport.Client

public class CopycatGrpcClient
extends Object
implements io.atomix.catalyst.transport.Client

Copycat transport Client implementation that uses Alluxio gRPC. Copycat guarantees that listen will be called once for each distinct address. It also guarantees pending futures will all be closed prior to calling close.

Constructor Summary

Constructors

Constructor and Description
CopycatGrpcClient(AlluxioConfiguration conf, UserState userState, ExecutorService executor) Creates copycat transport client that can be used to connect to remote copycat servers.

Method Summary

Modifier and Type	Method and Description
CompletableFuture<Void>	close()
CompletableFuture<io.atomix.catalyst.transport.Connection>	connect(io.atomix.catalyst.transport.Address address)

Methods inherited from class java.lang.Object

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

Constructor Detail

CopycatGrpcClient

public CopycatGrpcClient(AlluxioConfiguration conf,
                         UserState userState,
                         ExecutorService executor)

Creates copycat transport client that can be used to connect to remote copycat servers.

Parameters:

conf - Alluxio configuration

userState - authentication user

executor - transport executor

Method Detail

connect

public CompletableFuture<io.atomix.catalyst.transport.Connection> connect(io.atomix.catalyst.transport.Address address)

Specified by:

connect in interface io.atomix.catalyst.transport.Client

close

public CompletableFuture<Void> close()

Specified by:

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