alluxio.proxy

Class RetryHandlingMetaMasterProxyClient

java.lang.Object

alluxio.AbstractClient

alluxio.AbstractMasterClient

alluxio.proxy.RetryHandlingMetaMasterProxyClient

All Implemented Interfaces:

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

@ThreadSafe
public class RetryHandlingMetaMasterProxyClient
extends AbstractMasterClient

A wrapper for the gRPC client to interact with the meta master.

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
RetryHandlingMetaMasterProxyClient(Address proxyAddress, MasterClientContext conf, long startTimeMs) Creates a new meta master client.

Method Summary

Modifier and Type	Method and Description
protected void	afterConnect()
protected ServiceType	getRemoteServiceType()
protected java.lang.String	getServiceName()
protected long	getServiceVersion()
void	proxyHeartbeat() Sends a heartbeat to the primary master.

Methods inherited from class alluxio.AbstractMasterClient

afterDisconnect, beforeConnect, getConfAddress, queryGrpcServerAddress

Methods inherited from class alluxio.AbstractClient

beforeDisconnect, checkVersion, close, connect, connectWithRuntimeException, disconnect, getRemoteHostName, getRemoteServiceVersion, getRemoteSockAddress, isClosed, isConnected, retryRPC, retryRPC

Methods inherited from class java.lang.Object

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

Constructor Detail

RetryHandlingMetaMasterProxyClient

public RetryHandlingMetaMasterProxyClient(Address proxyAddress,
                                          MasterClientContext conf,
                                          long startTimeMs)

Creates a new meta master client.

Parameters:

proxyAddress - address of the proxy

conf - master client configuration

startTimeMs - start timestamp

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()

Overrides:

afterConnect in class AbstractClient

proxyHeartbeat

public void proxyHeartbeat()
                    throws java.io.IOException

Sends a heartbeat to the primary master.

Throws:

java.io.IOException