com.exalead.cloudview.alerting.scheduled

Class ScheduledAlertingExecutor

java.lang.Object

com.exalead.cloudview.alerting.scheduled.ScheduledAlertingExecutor

All Implemented Interfaces:

com.exalead.bee.Startable

public class ScheduledAlertingExecutor
extends java.lang.Object
implements com.exalead.bee.Startable

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	ScheduledAlertingExecutor.TimeBasedGroupJob Cron job to start a group

Field Summary

Fields

Modifier and Type	Field and Description
static java.util.Map<java.lang.String,com.exalead.cloudview.alerting.scheduled.ScheduledAlertingExecutor.GroupState>	groupStates
static java.lang.Object	statesMutex
static java.lang.String	v10

Constructor Summary

Constructors

Constructor and Description
ScheduledAlertingExecutor(AlertingDatabaseService dbs, java.lang.String statusFolder)

Method Summary

Modifier and Type	Method and Description
void	abortGroup(java.lang.String group) Aborts a running group.
AlertingStatus	getStatus()
void	runGroup(java.lang.String group) Run a group in the foreground.
protected static void	runSimpleExecutor(com.exalead.cloudview.alerting.scheduled.ScheduledAlertingExecutor.GroupState state)
protected void	scheduleOrStartGroup(AlertGroup ag, boolean reload)
protected void	scheduleOrStartGroup(java.lang.String group, boolean reload)
protected void	scheduleOrStartGroups(java.util.List<AlertGroup> alertGroups, boolean reload)
void	setConfig()
void	setGroupEnabled(java.lang.String group, boolean enabled) Sets a group as enabled.
void	setGroupPaused(java.lang.String group, boolean paused) Sets a group as paused.
void	start()
void	startGroup(java.lang.String group) Start the group in the background For a time-based group, performs a single run.
void	stop()
protected void	stopAndWaitAll()
protected void	stopAndWaitGroup(java.lang.String group)

Methods inherited from class java.lang.Object

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

Field Detail

statesMutex

public static java.lang.Object statesMutex

groupStates

public static java.util.Map<java.lang.String,com.exalead.cloudview.alerting.scheduled.ScheduledAlertingExecutor.GroupState> groupStates

v10

public static final java.lang.String v10

See Also:

Constant Field Values

Constructor Detail

ScheduledAlertingExecutor

public ScheduledAlertingExecutor(AlertingDatabaseService dbs,
                                 java.lang.String statusFolder)
                          throws java.io.IOException

Throws:

java.io.IOException

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

startGroup

public void startGroup(java.lang.String group)
                throws java.lang.Exception

Start the group in the background For a time-based group, performs a single run. For an interval-based group, start the background runner

Throws:

java.lang.Exception

runGroup

public void runGroup(java.lang.String group)
              throws java.lang.Exception

Run a group in the foreground.

Throws:

java.lang.IllegalStateException - if the group is already running

java.lang.Exception

abortGroup

public void abortGroup(java.lang.String group)
                throws java.lang.Exception

Aborts a running group. Returns when the group is not running anymore

Throws:

java.lang.Exception

setGroupEnabled

public void setGroupEnabled(java.lang.String group,
                            boolean enabled)
                     throws java.lang.Exception

Sets a group as enabled. For an interval-based group, also starts its background process

Throws:

java.lang.Exception

setGroupPaused

public void setGroupPaused(java.lang.String group,
                           boolean paused)

Sets a group as paused. A paused group cannot be run independently.

getStatus

public AlertingStatus getStatus()
                         throws java.lang.Exception

Throws:

java.lang.Exception

runSimpleExecutor

protected static void runSimpleExecutor(com.exalead.cloudview.alerting.scheduled.ScheduledAlertingExecutor.GroupState state)
                                 throws java.lang.Exception

Throws:

java.lang.Exception

stopAndWaitGroup

protected void stopAndWaitGroup(java.lang.String group)
                         throws java.lang.Exception

Throws:

java.lang.Exception

stopAndWaitAll

protected void stopAndWaitAll()
                       throws java.lang.Exception

Throws:

java.lang.Exception

scheduleOrStartGroups

protected void scheduleOrStartGroups(java.util.List<AlertGroup> alertGroups,
                                     boolean reload)
                              throws java.lang.Exception

Throws:

java.lang.Exception

scheduleOrStartGroup

protected void scheduleOrStartGroup(java.lang.String group,
                                    boolean reload)
                             throws java.lang.Exception

Throws:

java.lang.Exception

scheduleOrStartGroup

protected void scheduleOrStartGroup(AlertGroup ag,
                                    boolean reload)
                             throws java.lang.Exception

Throws:

java.lang.Exception

setConfig

public void setConfig()
               throws java.lang.Exception

Throws:

java.lang.Exception