alluxio.master

Class ZkMasterInquireClient

java.lang.Object

alluxio.master.ZkMasterInquireClient

All Implemented Interfaces:

MasterInquireClient, Closeable, AutoCloseable

@ThreadSafe
public final class ZkMasterInquireClient
extends Object
implements MasterInquireClient, Closeable

Utility to get leader from zookeeper.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	ZkMasterInquireClient.ZkMasterConnectDetails Details used to connect to the leader Alluxio master via Zookeeper.

Nested classes/interfaces inherited from interface alluxio.master.MasterInquireClient

MasterInquireClient.ConnectDetails, MasterInquireClient.Factory

Method Summary

Modifier and Type	Method and Description
void	close()
static ZkMasterInquireClient	getClient(String zookeeperAddress, String electionPath, String leaderPath, int inquireRetryCount, boolean authEnabled) Gets the client.
MasterInquireClient.ConnectDetails	getConnectDetails() Returns canonical connect details representing how this client connects to the master.
List<InetSocketAddress>	getMasterRpcAddresses()
InetSocketAddress	getPrimaryRpcAddress()

Methods inherited from class java.lang.Object

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

Method Detail

getClient

public static ZkMasterInquireClient getClient(String zookeeperAddress,
                                              String electionPath,
                                              String leaderPath,
                                              int inquireRetryCount,
                                              boolean authEnabled)

Gets the client.

Parameters:

zookeeperAddress - the address for Zookeeper

electionPath - the path of the master election

leaderPath - the path of the leader

inquireRetryCount - the number of times to retry connections

authEnabled - if Alluxio client-side auth is enabled

Returns:

the client

getPrimaryRpcAddress

public InetSocketAddress getPrimaryRpcAddress()
                                       throws UnavailableException

Specified by:

getPrimaryRpcAddress in interface MasterInquireClient

Returns:

the rpc address of the primary master. The implementation should perform retries if appropriate

Throws:

UnavailableException - if the primary rpc address cannot be determined

getMasterRpcAddresses

public List<InetSocketAddress> getMasterRpcAddresses()
                                              throws UnavailableException

Specified by:

getMasterRpcAddresses in interface MasterInquireClient

Returns:

a list of all masters' RPC addresses

Throws:

UnavailableException - if the master rpc addresses cannot be determined

close

public void close()

Specified by:

close in interface Closeable

Specified by:

close in interface AutoCloseable

getConnectDetails

public MasterInquireClient.ConnectDetails getConnectDetails()

Description copied from interface: MasterInquireClient

Returns canonical connect details representing how this client connects to the master.

Specified by:

getConnectDetails in interface MasterInquireClient

Returns:

the connect details