public class AggregatingTaskManagersMetricsHandler extends AbstractAggregatingMetricsHandler<AggregateTaskManagerMetricsParameters>
Specific taskmanagers can be selected for aggregation by specifying a comma-separated list of
taskmanager IDs. /metrics?get=X,Y&taskmanagers=A,B
log, MAPPER
leaderRetriever, logger, responseHeaders, timeout
Constructor and Description |
---|
AggregatingTaskManagersMetricsHandler(GatewayRetriever<? extends RestfulGateway> leaderRetriever,
Time timeout,
Map<String,String> responseHeaders,
Executor executor,
MetricFetcher fetcher) |
handleRequest
getMessageHeaders, respondToRequest
closeAsync, closeHandlerAsync, respondAsLeader
channelRead0, getTimeout
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 AggregatingTaskManagersMetricsHandler(GatewayRetriever<? extends RestfulGateway> leaderRetriever, Time timeout, Map<String,String> responseHeaders, Executor executor, MetricFetcher fetcher)
Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.