alluxio.master.journal.raft.transport

Class CopycatGrpcTransport

java.lang.Object

alluxio.master.journal.raft.transport.CopycatGrpcTransport

All Implemented Interfaces:

io.atomix.catalyst.transport.Transport, AutoCloseable

public class CopycatGrpcTransport
extends Object
implements io.atomix.catalyst.transport.Transport

Copycat Transport implementation that uses Alluxio gRPC.

Nested Class Summary

Nested classes/interfaces inherited from interface io.atomix.catalyst.transport.Transport

io.atomix.catalyst.transport.Transport.Builder

Constructor Summary

Constructors

Constructor and Description
CopycatGrpcTransport(AlluxioConfiguration clientConf, AlluxioConfiguration serverConf, UserState clientUser, UserState serverUser) Creates Transport for CopyCat that uses Alluxio gRPC.
CopycatGrpcTransport(AlluxioConfiguration conf, UserState user) Creates Transport for CopyCat that uses Alluxio gRPC.

Method Summary

Modifier and Type	Method and Description
io.atomix.catalyst.transport.Client	client()
void	close()
io.atomix.catalyst.transport.Server	server()
CopycatGrpcTransport	withServerProxy(CopycatGrpcProxy proxy) Sets external proxy configuration for servers.

Methods inherited from class java.lang.Object

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

Constructor Detail

CopycatGrpcTransport

public CopycatGrpcTransport(AlluxioConfiguration conf,
                            UserState user)

Creates Transport for CopyCat that uses Alluxio gRPC.

Parameters:

conf - Alluxio configuration

user - Alluxio user

CopycatGrpcTransport

public CopycatGrpcTransport(AlluxioConfiguration clientConf,
                            AlluxioConfiguration serverConf,
                            UserState clientUser,
                            UserState serverUser)

Creates Transport for CopyCat that uses Alluxio gRPC.

Parameters:

clientConf - Alluxio configuration for clients

serverConf - Alluxio configuration for servers

clientUser - User for clients

serverUser - User for servers

Method Detail

withServerProxy

public CopycatGrpcTransport withServerProxy(CopycatGrpcProxy proxy)

Sets external proxy configuration for servers.

Parameters:

proxy - external proxy configuration

Returns:

the updated transport instance

client

public io.atomix.catalyst.transport.Client client()

Specified by:

client in interface io.atomix.catalyst.transport.Transport

server

public io.atomix.catalyst.transport.Server server()

Specified by:

server in interface io.atomix.catalyst.transport.Transport

close

public void close()

Specified by:

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

Specified by:

close in interface AutoCloseable