alluxio.master.metrics

Class MetricsMasterClientServiceHandler

java.lang.Object

alluxio.grpc.MetricsMasterClientServiceGrpc.MetricsMasterClientServiceImplBase

alluxio.master.metrics.MetricsMasterClientServiceHandler

All Implemented Interfaces:

io.grpc.BindableService

@NotThreadSafe
public final class MetricsMasterClientServiceHandler
extends MetricsMasterClientServiceGrpc.MetricsMasterClientServiceImplBase

This class is a gRPC handler for metrics master RPCs invoked by an Alluxio client.

Constructor Summary

Constructors

Constructor and Description
MetricsMasterClientServiceHandler(MetricsMaster metricsMaster)

Method Summary

Modifier and Type	Method and Description
void	clearMetrics(ClearMetricsPRequest request, io.grpc.stub.StreamObserver<ClearMetricsPResponse> responseObserver)
void	getMetrics(GetMetricsPOptions options, io.grpc.stub.StreamObserver<GetMetricsPResponse> responseObserver)
void	metricsHeartbeat(MetricsHeartbeatPRequest request, io.grpc.stub.StreamObserver<MetricsHeartbeatPResponse> responseObserver)

Methods inherited from class alluxio.grpc.MetricsMasterClientServiceGrpc.MetricsMasterClientServiceImplBase

bindService

Methods inherited from class java.lang.Object

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

Constructor Detail

MetricsMasterClientServiceHandler

public MetricsMasterClientServiceHandler(MetricsMaster metricsMaster)

Parameters:

metricsMaster - MetricsMaster instance

Method Detail

clearMetrics

public void clearMetrics(ClearMetricsPRequest request,
                         io.grpc.stub.StreamObserver<ClearMetricsPResponse> responseObserver)

Overrides:

clearMetrics in class MetricsMasterClientServiceGrpc.MetricsMasterClientServiceImplBase

metricsHeartbeat

public void metricsHeartbeat(MetricsHeartbeatPRequest request,
                             io.grpc.stub.StreamObserver<MetricsHeartbeatPResponse> responseObserver)

Overrides:

metricsHeartbeat in class MetricsMasterClientServiceGrpc.MetricsMasterClientServiceImplBase

getMetrics

public void getMetrics(GetMetricsPOptions options,
                       io.grpc.stub.StreamObserver<GetMetricsPResponse> responseObserver)

Overrides:

getMetrics in class MetricsMasterClientServiceGrpc.MetricsMasterClientServiceImplBase