Package com.floragunn.signals.watch.checks

Class AbstractSearchInput

java.lang.Object

com.floragunn.signals.watch.common.WatchElement

com.floragunn.signals.watch.checks.Check

com.floragunn.signals.watch.checks.AbstractInput

com.floragunn.signals.watch.checks.AbstractSearchInput

All Implemented Interfaces:

org.elasticsearch.common.xcontent.ToXContent, org.elasticsearch.common.xcontent.ToXContentObject

Direct Known Subclasses:

SearchInput, SearchTemplateInput

public abstract class AbstractSearchInput
extends AbstractInput

Nested Class Summary

Nested classes/interfaces inherited from interface org.elasticsearch.common.xcontent.ToXContent

org.elasticsearch.common.xcontent.ToXContent.DelegatingMapParams, org.elasticsearch.common.xcontent.ToXContent.MapParams, org.elasticsearch.common.xcontent.ToXContent.Params

Field Summary

Fields

Modifier and Type	Field	Description
protected List<String>	indices
protected org.elasticsearch.action.support.IndicesOptions	indicesOptions
protected org.elasticsearch.action.search.SearchType	searchType
protected org.elasticsearch.script.TemplateScript.Factory	templateScriptFactory
protected org.elasticsearch.common.unit.TimeValue	timeout

Fields inherited from class com.floragunn.signals.watch.checks.AbstractInput

target

Fields inherited from class com.floragunn.signals.watch.checks.Check

name

Fields inherited from interface org.elasticsearch.common.xcontent.ToXContent

EMPTY_PARAMS

Constructor Summary

Constructors

Constructor	Description
AbstractSearchInput(String name, String target, List<String> indices)

Method Summary

Modifier and Type	Method	Description
void	compileScripts(WatchInitializationService watchInitService)
protected org.elasticsearch.action.search.SearchRequest	createSearchRequest(org.elasticsearch.common.xcontent.NamedXContentRegistry xContentRegistry, String searchBody)
protected abstract org.elasticsearch.script.Script	createTemplateScript()
boolean	execute(WatchExecutionContext ctx)
protected boolean	executeSearchRequest(WatchExecutionContext ctx, String searchBody)
protected String	executeTemplateScript(WatchExecutionContext ctx)
List<String>	getIndices()
protected String[]	getIndicesAsArray()
org.elasticsearch.common.unit.TimeValue	getTimeout()
static org.elasticsearch.action.support.IndicesOptions	parseIndicesOptions(com.fasterxml.jackson.databind.JsonNode jsonNode)
void	setTimeout(org.elasticsearch.common.unit.TimeValue timeout)

Methods inherited from class com.floragunn.signals.watch.checks.AbstractInput

setResult

Methods inherited from class com.floragunn.signals.watch.checks.Check

create, getIndexMapping, getName, getTemplateScriptParamsAsMap, toString

Methods inherited from class com.floragunn.signals.watch.common.WatchElement

getChildByNameAndType, getChildByNameAndType, getChildren, render, render

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.elasticsearch.common.xcontent.ToXContent

toXContent

Methods inherited from interface org.elasticsearch.common.xcontent.ToXContentObject

isFragment

Field Detail

indices

protected final List<String> indices

timeout

protected org.elasticsearch.common.unit.TimeValue timeout

templateScriptFactory

protected org.elasticsearch.script.TemplateScript.Factory templateScriptFactory

searchType

protected org.elasticsearch.action.search.SearchType searchType

indicesOptions

protected org.elasticsearch.action.support.IndicesOptions indicesOptions

Constructor Detail

AbstractSearchInput

public AbstractSearchInput(String name,
                           String target,
                           List<String> indices)

Method Detail

getIndices

public List<String> getIndices()

getIndicesAsArray

protected String[] getIndicesAsArray()

createTemplateScript

protected abstract org.elasticsearch.script.Script createTemplateScript()

executeTemplateScript

protected String executeTemplateScript(WatchExecutionContext ctx)

compileScripts

public void compileScripts(WatchInitializationService watchInitService)
                    throws com.floragunn.searchsupport.jobs.config.validation.ConfigValidationException

Throws:

com.floragunn.searchsupport.jobs.config.validation.ConfigValidationException

execute

public boolean execute(WatchExecutionContext ctx)
                throws CheckExecutionException

Specified by:

execute in class Check

Throws:

CheckExecutionException

executeSearchRequest

protected boolean executeSearchRequest(WatchExecutionContext ctx,
                                       String searchBody)

createSearchRequest

protected org.elasticsearch.action.search.SearchRequest createSearchRequest(org.elasticsearch.common.xcontent.NamedXContentRegistry xContentRegistry,
                                                                            String searchBody)

parseIndicesOptions

public static org.elasticsearch.action.support.IndicesOptions parseIndicesOptions(com.fasterxml.jackson.databind.JsonNode jsonNode)
                                                                           throws com.floragunn.searchsupport.jobs.config.validation.ConfigValidationException

Throws:

com.floragunn.searchsupport.jobs.config.validation.ConfigValidationException

getTimeout

public org.elasticsearch.common.unit.TimeValue getTimeout()

setTimeout

public void setTimeout(org.elasticsearch.common.unit.TimeValue timeout)