alluxio.client.metrics

Class RetryHandlingMetricsMasterClient

java.lang.Object

alluxio.AbstractClient

alluxio.AbstractMasterClient

alluxio.client.metrics.RetryHandlingMetricsMasterClient

All Implemented Interfaces:

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

@ThreadSafe
public class RetryHandlingMetricsMasterClient
extends AbstractMasterClient
implements MetricsMasterClient

A wrapper for the gRPC client to interact with the metrics 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
RetryHandlingMetricsMasterClient(MasterClientContext conf) Creates a new metrics master client.

Method Summary

Modifier and Type	Method and Description
protected void	afterConnect()
void	clearMetrics() Clear the master metrics.
java.util.Map<java.lang.String,MetricValue>	getMetrics() Gets all the metrics stored in the current master from metric name to metric value.
protected ServiceType	getRemoteServiceType()
protected java.lang.String	getServiceName()
protected long	getServiceVersion()
void	heartbeat(java.util.List<ClientMetrics> metrics) The method the worker should periodically execute to heartbeat back to the 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

Methods inherited from interface java.io.Closeable

close

Constructor Detail

RetryHandlingMetricsMasterClient

public RetryHandlingMetricsMasterClient(MasterClientContext conf)

Creates a new metrics master client.

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

Overrides:

afterConnect in class AbstractClient

clearMetrics

public void clearMetrics()
                  throws java.io.IOException

Description copied from interface: MetricsMasterClient

Clear the master metrics.

Specified by:

clearMetrics in interface MetricsMasterClient

Throws:

java.io.IOException

heartbeat

public void heartbeat(java.util.List<ClientMetrics> metrics)
               throws java.io.IOException

Description copied from interface: MetricsMasterClient

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

Specified by:

heartbeat in interface MetricsMasterClient

Parameters:

metrics - a list of client metrics

Throws:

java.io.IOException

getMetrics

public java.util.Map<java.lang.String,MetricValue> getMetrics()
                                                       throws AlluxioStatusException

Description copied from interface: MetricsMasterClient

Gets all the metrics stored in the current master from metric name to metric value.

Specified by:

getMetrics in interface MetricsMasterClient

Returns:

a map of metrics information

Throws:

AlluxioStatusException