Class LogviewerLogPageHandler
- java.lang.Object
-
- org.apache.storm.daemon.logviewer.handler.LogviewerLogPageHandler
-
public class LogviewerLogPageHandler extends Object
-
-
Constructor Summary
Constructors Constructor Description LogviewerLogPageHandler(String logRoot, String daemonLogRoot, WorkerLogs workerLogs, ResourceAuthorizer resourceAuthorizer, StormMetricsRegistry metricsRegistry)
Constructor.
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description jakarta.ws.rs.core.Response
daemonLogPage(String fileName, Integer start, Integer length, String grep, String user)
Provides a daemon log file to view.jakarta.ws.rs.core.Response
listLogFiles(String user, Integer port, String topologyId, String callback, String origin)
Enumerate worker log files for given criteria.jakarta.ws.rs.core.Response
logPage(String fileName, Integer start, Integer length, String grep, String user)
Provides a worker log file to view, starting from the specified position or default starting position of the most recent page.
-
-
-
Constructor Detail
-
LogviewerLogPageHandler
public LogviewerLogPageHandler(String logRoot, String daemonLogRoot, WorkerLogs workerLogs, ResourceAuthorizer resourceAuthorizer, StormMetricsRegistry metricsRegistry)
Constructor.- Parameters:
logRoot
- root worker log directorydaemonLogRoot
- root daemon log directoryworkerLogs
-WorkerLogs
resourceAuthorizer
-ResourceAuthorizer
metricsRegistry
- The logviewer metrics registry
-
-
Method Detail
-
listLogFiles
public jakarta.ws.rs.core.Response listLogFiles(String user, Integer port, String topologyId, String callback, String origin) throws IOException
Enumerate worker log files for given criteria.- Parameters:
user
- usernameport
- worker's port, null for all workerstopologyId
- topology ID, null for all topologiescallback
- callbackParameterName for JSONPorigin
- origin- Returns:
- list of worker logs for given criteria
- Throws:
IOException
-
logPage
public jakarta.ws.rs.core.Response logPage(String fileName, Integer start, Integer length, String grep, String user) throws IOException, InvalidRequestException
Provides a worker log file to view, starting from the specified position or default starting position of the most recent page.- Parameters:
fileName
- file to viewstart
- start offset, or null if the most recent page is desiredlength
- length to read in this page, or null if default page length is desiredgrep
- search string if request is a result of the search, can be nulluser
- username- Returns:
- HTML view page of worker log
- Throws:
IOException
InvalidRequestException
-
daemonLogPage
public jakarta.ws.rs.core.Response daemonLogPage(String fileName, Integer start, Integer length, String grep, String user) throws IOException, InvalidRequestException
Provides a daemon log file to view.- Parameters:
fileName
- file to viewstart
- start offset, or null if the most recent page is desiredlength
- length to read in this page, or null if default page length is desiredgrep
- search string if request is a result of the search, can be nulluser
- username- Returns:
- HTML view page of daemon log
- Throws:
IOException
InvalidRequestException
-
-