alluxio.master.meta

Class RetryHandlingMetaMasterMasterClient

java.lang.Object

alluxio.AbstractClient

alluxio.AbstractMasterClient

alluxio.master.meta.RetryHandlingMetaMasterMasterClient

All Implemented Interfaces:

Client, java.io.Closeable, java.lang.AutoCloseable

@ThreadSafe
public final class RetryHandlingMetaMasterMasterClient
extends AbstractMasterClient

A wrapper for the gRPC client to interact with the primary meta master, used by Alluxio standby masters.

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
RetryHandlingMetaMasterMasterClient(MasterClientContext conf) Creates a instance of RetryHandlingMetaMasterMasterClient.

Method Summary

Modifier and Type	Method and Description
protected void	afterConnect()
long	getId(Address address) Returns a master id for a master address.
protected ServiceType	getRemoteServiceType()
protected java.lang.String	getServiceName()
protected long	getServiceVersion()
MetaCommand	heartbeat(long masterId) Sends a heartbeat to the leader master.
void	register(long masterId, java.util.List<ConfigProperty> configList) Registers with the leader master.

Methods inherited from class alluxio.AbstractMasterClient

getAddress, getConfAddress

Methods inherited from class alluxio.AbstractClient

afterDisconnect, beforeConnect, beforeDisconnect, checkVersion, close, connect, disconnect, getRemoteServiceVersion, isClosed, isConnected, retryRPC, retryRPC

Methods inherited from class java.lang.Object

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

Constructor Detail

RetryHandlingMetaMasterMasterClient

public RetryHandlingMetaMasterMasterClient(MasterClientContext conf)

Creates a instance of RetryHandlingMetaMasterMasterClient.

Parameters:

conf - master client configuration

Method Detail

getRemoteServiceType

protected ServiceType getRemoteServiceType()

Specified by:

getRemoteServiceType in class AbstractClient

getServiceName

protected java.lang.String getServiceName()

Specified by:

getServiceName in class AbstractClient

getServiceVersion

protected long getServiceVersion()

Specified by:

getServiceVersion in class AbstractClient

afterConnect

protected void afterConnect()
                     throws java.io.IOException

Overrides:

afterConnect in class AbstractClient

Throws:

java.io.IOException

getId

public long getId(Address address)
           throws java.io.IOException

Returns a master id for a master address.

Parameters:

address - the address to get a master id for

Returns:

a master id

Throws:

java.io.IOException

heartbeat

public MetaCommand heartbeat(long masterId)
                      throws java.io.IOException

Sends a heartbeat to the leader master. Standby masters periodically execute this method so that the leader master knows they are still running.

Parameters:

masterId - the master id

Returns:

whether this master should re-register

Throws:

java.io.IOException

register

public void register(long masterId,
                     java.util.List<ConfigProperty> configList)
              throws java.io.IOException

Registers with the leader master.

Parameters:

masterId - the master id of the standby master registering

configList - the configuration of this master

Throws:

java.io.IOException