Class LogviewerLogSearchHandler
java.lang.Object
org.apache.storm.daemon.logviewer.handler.LogviewerLogSearchHandler
-
Nested Class Summary
-
Field Summary
Modifier and TypeFieldDescriptionstatic final int
static final int
static final int
static final Pattern
-
Constructor Summary
ConstructorDescriptionLogviewerLogSearchHandler
(Map<String, Object> stormConf, Path logRoot, Path daemonLogRoot, ResourceAuthorizer resourceAuthorizer, StormMetricsRegistry metricsRegistry) Constructor. -
Method Summary
Modifier and TypeMethodDescriptionjavax.ws.rs.core.Response
deepSearchLogsForTopology
(String topologyId, String user, String search, String numMatchesStr, String portStr, String fileOffsetStr, String offsetStr, Boolean searchArchived, String callback, String origin) Advanced search across worker log files in a topology.javax.ws.rs.core.Response
searchLogFile
(String fileName, String user, boolean isDaemon, String search, String numMatchesStr, String offsetStr, String callback, String origin) Search from a worker log file.
-
Field Details
-
GREP_MAX_SEARCH_SIZE
public static final int GREP_MAX_SEARCH_SIZE- See Also:
-
GREP_BUF_SIZE
public static final int GREP_BUF_SIZE- See Also:
-
GREP_CONTEXT_SIZE
public static final int GREP_CONTEXT_SIZE- See Also:
-
WORKER_LOG_FILENAME_PATTERN
-
-
Constructor Details
-
LogviewerLogSearchHandler
public LogviewerLogSearchHandler(Map<String, Object> stormConf, Path logRoot, Path daemonLogRoot, ResourceAuthorizer resourceAuthorizer, StormMetricsRegistry metricsRegistry) Constructor.- Parameters:
stormConf
- storm configurationlogRoot
- log root directorydaemonLogRoot
- daemon log root directoryresourceAuthorizer
-ResourceAuthorizer
metricsRegistry
- The logviewer metrics registry
-
-
Method Details
-
searchLogFile
public javax.ws.rs.core.Response searchLogFile(String fileName, String user, boolean isDaemon, String search, String numMatchesStr, String offsetStr, String callback, String origin) throws IOException, InvalidRequestException Search from a worker log file.- Parameters:
fileName
- log fileuser
- usernameisDaemon
- whether the log file is regarding worker or daemonsearch
- search stringnumMatchesStr
- the count of maximum matchesoffsetStr
- start offset for log filecallback
- callbackParameterName for JSONPorigin
- origin- Returns:
- Response containing JSON content representing search result
- Throws:
IOException
InvalidRequestException
-
deepSearchLogsForTopology
public javax.ws.rs.core.Response deepSearchLogsForTopology(String topologyId, String user, String search, String numMatchesStr, String portStr, String fileOffsetStr, String offsetStr, Boolean searchArchived, String callback, String origin) throws IOException Advanced search across worker log files in a topology.- Parameters:
topologyId
- topology IDuser
- usernamesearch
- search stringnumMatchesStr
- the count of maximum matches. Note that this number is with respect to each port, not to each log or each search requestportStr
- worker port, null or '*' if the request wants to search from all worker logsfileOffsetStr
- index (offset) of the log filesoffsetStr
- start offset for log filesearchArchived
- true if the request wants to search also archived files, false if notcallback
- callbackParameterName for JSONPorigin
- origin- Returns:
- Response containing JSON content representing search result
- Throws:
IOException
-