alluxio

Class AbstractMasterClient

java.lang.Object

alluxio.AbstractClient

alluxio.AbstractMasterClient

All Implemented Interfaces:

Client, Closeable, AutoCloseable

Direct Known Subclasses:

AbstractJobMasterClient, BlockMasterClient, FileSystemMasterClient, FileSystemMasterClient, RaftJournalServiceClient, RetryHandlingBlockMasterClient, RetryHandlingFileSystemMasterClient, RetryHandlingMetaMasterClient, RetryHandlingMetaMasterConfigClient, RetryHandlingMetaMasterMasterClient, RetryHandlingMetricsMasterClient, RetryHandlingTableMasterClient

@ThreadSafe
public abstract class AbstractMasterClient
extends AbstractClient

The base class for master clients.

Nested Class Summary

Nested classes/interfaces inherited from class alluxio.AbstractClient

AbstractClient.RpcCallable<V>

Field Summary

Fields inherited from class alluxio.AbstractClient

mChannel, mClosed, mConnected, mContext, mServerAddress, mServiceVersion, mVersionService

Constructor Summary

Constructors

Constructor and Description
AbstractMasterClient(MasterClientContext clientConf) Creates a new master client base.
AbstractMasterClient(MasterClientContext clientConf, java.util.function.Supplier<RetryPolicy> retryPolicySupplier) Creates a new master client base.

Method Summary

Modifier and Type	Method and Description
protected GrpcServerAddress	queryGrpcServerAddress() AbstractClient works with Grpc Servers.

Methods inherited from class alluxio.AbstractClient

afterConnect, afterDisconnect, beforeConnect, beforeDisconnect, checkVersion, close, connect, disconnect, getConfAddress, getRemoteHostName, getRemoteServiceType, getRemoteServiceVersion, getRemoteSockAddress, getServiceName, getServiceVersion, isClosed, isConnected, retryRPC, retryRPC

Methods inherited from class java.lang.Object

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

Constructor Detail

AbstractMasterClient

public AbstractMasterClient(MasterClientContext clientConf)

Creates a new master client base.

Parameters:

clientConf - master client configuration

AbstractMasterClient

public AbstractMasterClient(MasterClientContext clientConf,
                            java.util.function.Supplier<RetryPolicy> retryPolicySupplier)

Creates a new master client base.

Parameters:

clientConf - master client configuration

retryPolicySupplier - retry policy to use

Method Detail

queryGrpcServerAddress

protected GrpcServerAddress queryGrpcServerAddress()
                                            throws UnavailableException

Description copied from class: AbstractClient

AbstractClient works with Grpc Servers. Child classes should only override this method to query the address of the grpc server they talk to. The conversion from GrpcServerAddress to more generic SocketAddress required by Client.getRemoteSockAddress() is handled by this class.

Specified by:

queryGrpcServerAddress in class AbstractClient

Returns:

the GrpcServerAddress of the remote server

Throws:

UnavailableException - if address can't be determined