public class AggregatingJobsMetricsHandler extends AbstractAggregatingMetricsHandler<AggregatedJobMetricsParameters>
Specific jobs can be selected for aggregation by specifying a comma-separated list of job IDs.
/metrics?get=X,Y&jobs=A,B
log, MAPPER
leaderRetriever, localAddressFuture, logger, responseHeaders, timeout
Constructor and Description |
---|
AggregatingJobsMetricsHandler(CompletableFuture<String> localRestAddress,
GatewayRetriever<? extends RestfulGateway> leaderRetriever,
Time timeout,
Map<String,String> responseHeaders,
Executor executor,
MetricFetcher<?> fetcher) |
handleRequest
getMessageHeaders, respondToRequest
closeAsync, closeHandlerAsync, respondAsLeader
channelRead0
acceptInboundMessage, channelRead
channelActive, channelInactive, channelReadComplete, channelRegistered, channelUnregistered, channelWritabilityChanged, exceptionCaught, userEventTriggered
handlerAdded, handlerRemoved, isSharable
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
close
public AggregatingJobsMetricsHandler(CompletableFuture<String> localRestAddress, GatewayRetriever<? extends RestfulGateway> leaderRetriever, Time timeout, Map<String,String> responseHeaders, Executor executor, MetricFetcher<?> fetcher)
Copyright © 2014–2019 The Apache Software Foundation. All rights reserved.