Class LogviewerLogSearchHandler
java.lang.Object
org.apache.storm.daemon.logviewer.handler.LogviewerLogSearchHandler
- 
Nested Class SummaryNested Classes
- 
Field SummaryFieldsModifier and TypeFieldDescriptionstatic final intstatic final intstatic final intstatic final Pattern
- 
Constructor SummaryConstructorsConstructorDescriptionLogviewerLogSearchHandler(Map<String, Object> stormConf, Path logRoot, Path daemonLogRoot, ResourceAuthorizer resourceAuthorizer, StormMetricsRegistry metricsRegistry) Constructor.
- 
Method SummaryModifier and TypeMethodDescriptionjakarta.ws.rs.core.ResponsedeepSearchLogsForTopology(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.jakarta.ws.rs.core.ResponsesearchLogFile(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_SIZEpublic static final int GREP_MAX_SEARCH_SIZE- See Also:
 
- 
GREP_BUF_SIZEpublic static final int GREP_BUF_SIZE- See Also:
 
- 
GREP_CONTEXT_SIZEpublic static final int GREP_CONTEXT_SIZE- See Also:
 
- 
WORKER_LOG_FILENAME_PATTERN
 
- 
- 
Constructor Details- 
LogviewerLogSearchHandlerpublic LogviewerLogSearchHandler(Map<String, Object> stormConf, Path logRoot, Path daemonLogRoot, ResourceAuthorizer resourceAuthorizer, StormMetricsRegistry metricsRegistry) Constructor.- Parameters:
- stormConf- storm configuration
- logRoot- log root directory
- daemonLogRoot- daemon log root directory
- resourceAuthorizer-- ResourceAuthorizer
- metricsRegistry- The logviewer metrics registry
 
 
- 
- 
Method Details- 
searchLogFilepublic jakarta.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 file
- user- username
- isDaemon- whether the log file is regarding worker or daemon
- search- search string
- numMatchesStr- the count of maximum matches
- offsetStr- start offset for log file
- callback- callbackParameterName for JSONP
- origin- origin
- Returns:
- Response containing JSON content representing search result
- Throws:
- IOException
- InvalidRequestException
 
- 
deepSearchLogsForTopologypublic jakarta.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 ID
- user- username
- search- search string
- numMatchesStr- the count of maximum matches. Note that this number is with respect to each port, not to each log or each search request
- portStr- worker port, null or '*' if the request wants to search from all worker logs
- fileOffsetStr- index (offset) of the log files
- offsetStr- start offset for log file
- searchArchived- true if the request wants to search also archived files, false if not
- callback- callbackParameterName for JSONP
- origin- origin
- Returns:
- Response containing JSON content representing search result
- Throws:
- IOException
 
 
-