@ChannelHandler.Sharable public class TaskManagerLogHandler extends RuntimeMonitorHandlerBase
This code is based on the "HttpStaticFileServerHandler" from the Netty project's HTTP server example.
Modifier and Type | Class and Description |
---|---|
static class |
TaskManagerLogHandler.FileMode |
httpsEnabled, localJobManagerAddress, localJobManagerAddressFuture, timeout
Constructor and Description |
---|
TaskManagerLogHandler(JobManagerRetriever retriever,
scala.concurrent.ExecutionContextExecutor executor,
scala.concurrent.Future<String> localJobManagerAddressPromise,
scala.concurrent.duration.FiniteDuration timeout,
TaskManagerLogHandler.FileMode fileMode,
Configuration config,
boolean httpsEnabled,
BlobView blobView) |
Modifier and Type | Method and Description |
---|---|
String[] |
getPaths()
Returns an array of REST URL's under which this handler can be registered.
|
protected void |
respondAsLeader(io.netty.channel.ChannelHandlerContext ctx,
io.netty.handler.codec.http.router.Routed routed,
ActorGateway jobManager)
Response when running with leading JobManager.
|
channelRead0
acceptInboundMessage, channelRead
channelActive, channelInactive, channelReadComplete, channelRegistered, channelUnregistered, channelWritabilityChanged, exceptionCaught, userEventTriggered
handlerAdded, handlerRemoved, isSharable
public TaskManagerLogHandler(JobManagerRetriever retriever, scala.concurrent.ExecutionContextExecutor executor, scala.concurrent.Future<String> localJobManagerAddressPromise, scala.concurrent.duration.FiniteDuration timeout, TaskManagerLogHandler.FileMode fileMode, Configuration config, boolean httpsEnabled, BlobView blobView)
public String[] getPaths()
RuntimeMonitorHandlerBase
getPaths
in class RuntimeMonitorHandlerBase
protected void respondAsLeader(io.netty.channel.ChannelHandlerContext ctx, io.netty.handler.codec.http.router.Routed routed, ActorGateway jobManager)
respondAsLeader
in class RuntimeMonitorHandlerBase
Copyright © 2014–2018 The Apache Software Foundation. All rights reserved.