public class TaskManagerThreadDumpHandler extends AbstractResourceManagerHandler<RestfulGateway,EmptyRequestBody,ThreadDumpInfo,TaskManagerMessageParameters>
TaskExecutor
.log, MAPPER
leaderRetriever, logger, responseHeaders, timeout
Constructor and Description |
---|
TaskManagerThreadDumpHandler(GatewayRetriever<? extends RestfulGateway> leaderRetriever,
Time timeout,
Map<String,String> responseHeaders,
MessageHeaders<EmptyRequestBody,ThreadDumpInfo,TaskManagerMessageParameters> messageHeaders,
GatewayRetriever<ResourceManagerGateway> resourceManagerGatewayRetriever) |
Modifier and Type | Method and Description |
---|---|
protected CompletableFuture<ThreadDumpInfo> |
handleRequest(HandlerRequest<EmptyRequestBody> request,
ResourceManagerGateway gateway) |
getResourceManagerGateway, 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 TaskManagerThreadDumpHandler(GatewayRetriever<? extends RestfulGateway> leaderRetriever, Time timeout, Map<String,String> responseHeaders, MessageHeaders<EmptyRequestBody,ThreadDumpInfo,TaskManagerMessageParameters> messageHeaders, GatewayRetriever<ResourceManagerGateway> resourceManagerGatewayRetriever)
protected CompletableFuture<ThreadDumpInfo> handleRequest(@Nonnull HandlerRequest<EmptyRequestBody> request, @Nonnull ResourceManagerGateway gateway) throws RestHandlerException
handleRequest
in class AbstractResourceManagerHandler<RestfulGateway,EmptyRequestBody,ThreadDumpInfo,TaskManagerMessageParameters>
RestHandlerException
Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.