public class JobMetricsHandler extends AbstractMetricsHandler<JobMetricsMessageParameters>
log, MAPPER
leaderRetriever, logger, responseHeaders, timeout
Constructor and Description |
---|
JobMetricsHandler(GatewayRetriever<? extends RestfulGateway> leaderRetriever,
Time timeout,
Map<String,String> headers,
MetricFetcher metricFetcher) |
Modifier and Type | Method and Description |
---|---|
protected MetricStore.ComponentMetricStore |
getComponentMetricStore(HandlerRequest<EmptyRequestBody,JobMetricsMessageParameters> request,
MetricStore metricStore)
Returns the
MetricStore.ComponentMetricStore that should be queried for metrics. |
handleRequest
getMessageHeaders, respondToRequest
closeAsync, closeHandlerAsync, respondAsLeader
channelRead0
acceptInboundMessage, channelRead
channelActive, channelInactive, channelReadComplete, channelRegistered, channelUnregistered, channelWritabilityChanged, exceptionCaught, userEventTriggered
ensureNotSharable, handlerAdded, handlerRemoved, isSharable
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
close
public JobMetricsHandler(GatewayRetriever<? extends RestfulGateway> leaderRetriever, Time timeout, Map<String,String> headers, MetricFetcher metricFetcher)
@Nullable protected MetricStore.ComponentMetricStore getComponentMetricStore(HandlerRequest<EmptyRequestBody,JobMetricsMessageParameters> request, MetricStore metricStore)
AbstractMetricsHandler
MetricStore.ComponentMetricStore
that should be queried for metrics.getComponentMetricStore
in class AbstractMetricsHandler<JobMetricsMessageParameters>
Copyright © 2014–2021 The Apache Software Foundation. All rights reserved.