com.exalead.cloudview.alerting.realtime

Class MatchingService

java.lang.Object

com.exalead.cloudview.alerting.realtime.MatchingService

All Implemented Interfaces:

com.exalead.bee.Startable, com.exalead.cloudview.indexing.realtime.MatchingService

public class MatchingService
extends java.lang.Object
implements com.exalead.cloudview.indexing.realtime.MatchingService

Field Summary

Fields

Modifier and Type	Field and Description
protected java.lang.String	buildGroup
protected static org.apache.log4j.Logger	LOGGER
protected java.util.List<com.exalead.cloudview.indexing.realtime.MatcherDefinition>	matcherDefinitions
protected java.lang.Object	matcherDefinitionsLock
protected MatchersBuilder	matchersBuilder
protected java.util.concurrent.locks.ReentrantLock	matchersBuilderLock

Constructor Summary

Constructors

Constructor and Description
MatchingService(java.lang.String buildGroup)
MatchingService(java.lang.String buildGroup, int nbMatchersPerAlertGroup)

Method Summary

Modifier and Type	Method and Description
protected java.io.File	getBaseDir()
java.util.List<com.exalead.cloudview.indexing.realtime.MatcherDefinition>	getMatcherDefinitions(java.util.List<java.lang.String> alertGroups)
protected java.util.List<MatcherDefinition>	getMatcherDefinitionsFromDisk()
protected java.util.List<MatcherDefinition>	getMatcherDefinitionsFromDisk(AlertGroup alertGroup)
void	rebuildGroupAndReloadAll(com.exalead.alerting.realtime.messages.RebuildGroupAndReloadAll rebuildGroupAndReloadAll)
protected void	reloadAll(boolean forceReinitAnalysisPipelineOnNextJob)
void	start()
void	stop()

Methods inherited from class java.lang.Object

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

Field Detail

LOGGER

protected static final org.apache.log4j.Logger LOGGER

buildGroup

protected final java.lang.String buildGroup

matcherDefinitions

protected final java.util.List<com.exalead.cloudview.indexing.realtime.MatcherDefinition> matcherDefinitions

matcherDefinitionsLock

protected final java.lang.Object matcherDefinitionsLock

matchersBuilder

protected final MatchersBuilder matchersBuilder

matchersBuilderLock

protected final java.util.concurrent.locks.ReentrantLock matchersBuilderLock

Constructor Detail

MatchingService

public MatchingService(java.lang.String buildGroup)

MatchingService

public MatchingService(java.lang.String buildGroup,
                       int nbMatchersPerAlertGroup)

Method Detail

start

public void start()

Specified by:

start in interface com.exalead.bee.Startable

stop

public void stop()

Specified by:

stop in interface com.exalead.bee.Startable

rebuildGroupAndReloadAll

public void rebuildGroupAndReloadAll(com.exalead.alerting.realtime.messages.RebuildGroupAndReloadAll rebuildGroupAndReloadAll)
                              throws java.lang.Exception

Specified by:

rebuildGroupAndReloadAll in interface com.exalead.cloudview.indexing.realtime.MatchingService

Throws:

java.lang.Exception

getMatcherDefinitions

public java.util.List<com.exalead.cloudview.indexing.realtime.MatcherDefinition> getMatcherDefinitions(java.util.List<java.lang.String> alertGroups)

Specified by:

getMatcherDefinitions in interface com.exalead.cloudview.indexing.realtime.MatchingService

getMatcherDefinitionsFromDisk

protected java.util.List<MatcherDefinition> getMatcherDefinitionsFromDisk()
                                                                   throws java.lang.Exception

Throws:

java.lang.Exception

getMatcherDefinitionsFromDisk

protected java.util.List<MatcherDefinition> getMatcherDefinitionsFromDisk(AlertGroup alertGroup)

getBaseDir

protected java.io.File getBaseDir()

reloadAll

protected void reloadAll(boolean forceReinitAnalysisPipelineOnNextJob)
                  throws java.lang.Exception

Throws:

java.lang.Exception