Package org.graylog.scheduler

Class JobExecutionEngine

java.lang.Object

org.graylog.scheduler.JobExecutionEngine

public class JobExecutionEngine
extends Object

The job execution engine checks runnable triggers and starts job execution in the given worker pool.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static interface	JobExecutionEngine.Factory

Constructor Summary

Constructors

Constructor	Description
JobExecutionEngine(DBJobTriggerService jobTriggerService, DBJobDefinitionService jobDefinitionService, JobSchedulerEventBus eventBus, JobScheduleStrategies scheduleStrategies, JobTriggerUpdates.Factory jobTriggerUpdatesFactory, RefreshingLockService.Factory refreshingLockServiceFactory, Map<String,Job.Factory> jobFactory, JobWorkerPool workerPool, JobSchedulerConfig schedulerConfig, com.codahale.metrics.MetricRegistry metricRegistry)
JobExecutionEngine(DBJobTriggerService jobTriggerService, DBJobDefinitionService jobDefinitionService, JobSchedulerEventBus eventBus, JobScheduleStrategies scheduleStrategies, JobTriggerUpdates.Factory jobTriggerUpdatesFactory, RefreshingLockService.Factory refreshingLockServiceFactory, Map<String,Job.Factory> jobFactory, JobWorkerPool workerPool, JobSchedulerConfig schedulerConfig, com.codahale.metrics.MetricRegistry metricRegistry, long backoffMillis)

Method Summary

Modifier and Type	Method	Description
boolean	execute()	Execute the engine.
void	shutdown()	Signal shutdown to the engine.
void	updateLockedJobs()

Methods inherited from class java.lang.Object

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

Constructor Details

JobExecutionEngine

@Inject
public JobExecutionEngine(DBJobTriggerService jobTriggerService,
 DBJobDefinitionService jobDefinitionService,
 JobSchedulerEventBus eventBus,
 JobScheduleStrategies scheduleStrategies,
 JobTriggerUpdates.Factory jobTriggerUpdatesFactory,
 RefreshingLockService.Factory refreshingLockServiceFactory,
 Map<String,Job.Factory> jobFactory,
 JobWorkerPool workerPool,
 JobSchedulerConfig schedulerConfig,
 com.codahale.metrics.MetricRegistry metricRegistry)

JobExecutionEngine

public JobExecutionEngine(DBJobTriggerService jobTriggerService,
 DBJobDefinitionService jobDefinitionService,
 JobSchedulerEventBus eventBus,
 JobScheduleStrategies scheduleStrategies,
 JobTriggerUpdates.Factory jobTriggerUpdatesFactory,
 RefreshingLockService.Factory refreshingLockServiceFactory,
 Map<String,Job.Factory> jobFactory,
 JobWorkerPool workerPool,
 JobSchedulerConfig schedulerConfig,
 com.codahale.metrics.MetricRegistry metricRegistry,
 long backoffMillis)

Method Details

shutdown

public void shutdown()

Signal shutdown to the engine.

execute

public boolean execute()

Execute the engine. This will try to lock a trigger and execute the job if there are free slots in the worker pool and the engine is not shutting down.

Returns:

true if a job trigger has been locked and the related job has been triggered, false otherwise

updateLockedJobs

public void updateLockedJobs()