org.apache.ambari.server.controller.logging

Class LoggingRequestHelperImpl

java.lang.Object

org.apache.ambari.server.controller.logging.LoggingRequestHelperImpl

All Implemented Interfaces:

LoggingRequestHelper

public class LoggingRequestHelperImpl
extends Object
implements LoggingRequestHelper

Convenience class to handle the connection details of a LogSearch query request.

Constructor Summary

Constructors

Modifier	Constructor and Description
	LoggingRequestHelperImpl(String hostName, String portNumber, String protocol, CredentialStoreService credentialStoreService, Cluster cluster, String externalAddress)
protected	LoggingRequestHelperImpl(String hostName, String portNumber, String protocol, CredentialStoreService credentialStoreService, Cluster cluster, String externalAddress, org.apache.ambari.server.controller.logging.LoggingRequestHelperImpl.NetworkConnection networkConnection)

Method Summary

Modifier and Type	Method and Description
protected static org.codehaus.jackson.map.ObjectMapper	createJSONObjectMapper()
String	createLogFileTailURI(String baseURI, String componentName, String hostName) Generates the log file tail URI, using the LogSearch server's query parameters.
int	getLogSearchConnectTimeoutInMilliseconds()
int	getLogSearchReadTimeoutInMilliseconds()
HostLogFilesResponse	sendGetLogFileNamesRequest(String hostName) Sends a request to obtain the log file names for a given host
LogLevelQueryResponse	sendLogLevelQueryRequest(String componentName, String hostName) Sends a request to obtain the log level counts for a given component on a given host
LogQueryResponse	sendQueryRequest(Map<String,String> queryParameters) Sends a search query request to the LogSearch server
void	setLogSearchConnectTimeoutInMilliseconds(int logSearchConnectTimeoutInMilliseconds)
void	setLogSearchReadTimeoutInMilliseconds(int logSearchReadTimeoutInMilliseconds)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

LoggingRequestHelperImpl

public LoggingRequestHelperImpl(String hostName,
                                String portNumber,
                                String protocol,
                                CredentialStoreService credentialStoreService,
                                Cluster cluster,
                                String externalAddress)

LoggingRequestHelperImpl

protected LoggingRequestHelperImpl(String hostName,
                                   String portNumber,
                                   String protocol,
                                   CredentialStoreService credentialStoreService,
                                   Cluster cluster,
                                   String externalAddress,
                                   org.apache.ambari.server.controller.logging.LoggingRequestHelperImpl.NetworkConnection networkConnection)

Method Detail

getLogSearchConnectTimeoutInMilliseconds

public int getLogSearchConnectTimeoutInMilliseconds()

setLogSearchConnectTimeoutInMilliseconds

public void setLogSearchConnectTimeoutInMilliseconds(int logSearchConnectTimeoutInMilliseconds)

getLogSearchReadTimeoutInMilliseconds

public int getLogSearchReadTimeoutInMilliseconds()

setLogSearchReadTimeoutInMilliseconds

public void setLogSearchReadTimeoutInMilliseconds(int logSearchReadTimeoutInMilliseconds)

sendQueryRequest

public LogQueryResponse sendQueryRequest(Map<String,String> queryParameters)

Description copied from interface: LoggingRequestHelper

Sends a search query request to the LogSearch server

Specified by:

sendQueryRequest in interface LoggingRequestHelper

Parameters:

queryParameters - the query parameters to pass to LogSearch

Returns:

a LogQueryResponse, containing the results of the search

sendGetLogFileNamesRequest

public HostLogFilesResponse sendGetLogFileNamesRequest(String hostName)

Description copied from interface: LoggingRequestHelper

Sends a request to obtain the log file names for a given host

Specified by:

sendGetLogFileNamesRequest in interface LoggingRequestHelper

Parameters:

hostName - the host name

Returns:

a HostLogFilesResponse, containing include the log file names for components associated with a hostname

sendLogLevelQueryRequest

public LogLevelQueryResponse sendLogLevelQueryRequest(String componentName,
                                                      String hostName)

Description copied from interface: LoggingRequestHelper

Sends a request to obtain the log level counts for a given component on a given host

Specified by:

sendLogLevelQueryRequest in interface LoggingRequestHelper

Parameters:

componentName - the component name

hostName - the host name

Returns:

a LogLevelQueryResponse, containing the log level counts for this component/host combination

createLogFileTailURI

public String createLogFileTailURI(String baseURI,
                                   String componentName,
                                   String hostName)

Generates the log file tail URI, using the LogSearch server's query parameters.

Specified by:

createLogFileTailURI in interface LoggingRequestHelper

Parameters:

baseURI - the base URI for this request, typically the URI to the Ambari Integration searchEngine component

componentName - the component name

hostName - the host name

Returns:

createJSONObjectMapper

protected static org.codehaus.jackson.map.ObjectMapper createJSONObjectMapper()