alluxio.client.metrics

Class MetricsMasterClient

java.lang.Object

alluxio.AbstractClient

alluxio.AbstractMasterClient

alluxio.client.metrics.MetricsMasterClient

All Implemented Interfaces:

alluxio.Client, Closeable, AutoCloseable

@ThreadSafe
public class MetricsMasterClient
extends alluxio.AbstractMasterClient

A client to use for interacting with a metrics master.

Nested Class Summary

Nested classes/interfaces inherited from class alluxio.AbstractClient

alluxio.AbstractClient.RpcCallable<V>

Field Summary

Fields inherited from class alluxio.AbstractClient

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

Constructor Summary

Constructors

Constructor and Description
MetricsMasterClient(alluxio.master.MasterClientContext conf) Creates a new metrics master client.

Method Summary

Modifier and Type	Method and Description
protected void	afterConnect()
protected alluxio.grpc.ServiceType	getRemoteServiceType()
protected String	getServiceName()
protected long	getServiceVersion()
void	heartbeat(List<alluxio.grpc.ClientMetrics> metrics) The method the worker should periodically execute to heartbeat back to the master.

Methods inherited from class alluxio.AbstractMasterClient

getAddress

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

MetricsMasterClient

public MetricsMasterClient(alluxio.master.MasterClientContext conf)

Creates a new metrics master client.

Parameters:

conf - master client configuration

Method Detail

getRemoteServiceType

protected alluxio.grpc.ServiceType getRemoteServiceType()

Specified by:

getRemoteServiceType in class alluxio.AbstractClient

getServiceName

protected String getServiceName()

Specified by:

getServiceName in class alluxio.AbstractClient

getServiceVersion

protected long getServiceVersion()

Specified by:

getServiceVersion in class alluxio.AbstractClient

afterConnect

protected void afterConnect()

Overrides:

afterConnect in class alluxio.AbstractClient

heartbeat

public void heartbeat(List<alluxio.grpc.ClientMetrics> metrics)
               throws IOException

The method the worker should periodically execute to heartbeat back to the master.

Parameters:

metrics - a list of client metrics

Throws:

IOException