alluxio

Class AbstractMasterClient

java.lang.Object

alluxio.AbstractClient

alluxio.AbstractMasterClient

All Implemented Interfaces:

Client, Closeable, AutoCloseable

Direct Known Subclasses:

BlockMasterClient, FileSystemMasterClient, FileSystemMasterClient, RetryHandlingBlockMasterClient, RetryHandlingFileSystemMasterClient, RetryHandlingJobMasterClient, RetryHandlingJobMasterClient, RetryHandlingJournalMasterClient, 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

mAddress, mChannel, mClosed, mConfAddress, mConnected, mContext, mServiceVersion, mVersionService

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method and Description
InetSocketAddress	getAddress()
InetSocketAddress	getConfAddress()

Methods inherited from class alluxio.AbstractClient

afterConnect, afterDisconnect, beforeConnect, beforeDisconnect, checkVersion, close, connect, disconnect, getRemoteServiceType, getRemoteServiceVersion, 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,
                            InetSocketAddress address,
                            java.util.function.Supplier<RetryPolicy> retryPolicySupplier)

Creates a new master client base.

Parameters:

clientConf - master client configuration

address - address to connect to

retryPolicySupplier - retry policy to use

Method Detail

getAddress

public InetSocketAddress getAddress()
                             throws UnavailableException

Specified by:

getAddress in interface Client

Overrides:

getAddress in class AbstractClient

Returns:

the InetSocketAddress of the remote

Throws:

UnavailableException - if the primary address cannot be determined

getConfAddress

public InetSocketAddress getConfAddress()
                                 throws UnavailableException

Specified by:

getConfAddress in interface Client

Overrides:

getConfAddress in class AbstractClient

Returns:

the InetSocketAddress of the configuration remote

Throws:

UnavailableException - if the primary address cannot be determined