Package org.graylog.scheduler

Class DefaultJobSchedulerConfig

java.lang.Object

org.graylog.scheduler.DefaultJobSchedulerConfig

All Implemented Interfaces:

JobSchedulerConfig

@Singleton
public class DefaultJobSchedulerConfig
extends Object
implements JobSchedulerConfig

This is the default JobSchedulerConfig.

Constructor Summary

Constructors

Constructor	Description
DefaultJobSchedulerConfig(LeaderElectionService leaderElectionService, JobSchedulerConfiguration config)

Method Summary

Modifier and Type	Method	Description
boolean	canExecute()	Determines if the scheduler can execute the next loop iteration.
Map<String,Integer>	concurrencyLimits()	Concurrency limits per job type.
int	numberOfWorkerThreads()	The number of worker threads to start.

Methods inherited from class java.lang.Object

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

Constructor Details

DefaultJobSchedulerConfig

@Inject
public DefaultJobSchedulerConfig(LeaderElectionService leaderElectionService,
 JobSchedulerConfiguration config)

Method Details

canExecute

public boolean canExecute()

Description copied from interface: JobSchedulerConfig

Determines if the scheduler can execute the next loop iteration. This method will be called at the beginning of each scheduler loop iteration so it should be fast!

Specified by:

canExecute in interface JobSchedulerConfig

Returns:

true if scheduler can execute next loop iteration

numberOfWorkerThreads

public int numberOfWorkerThreads()

Description copied from interface: JobSchedulerConfig

The number of worker threads to start.

Specified by:

numberOfWorkerThreads in interface JobSchedulerConfig

Returns:

number of worker threads

concurrencyLimits

public Map<String,Integer> concurrencyLimits()

Description copied from interface: JobSchedulerConfig

Concurrency limits per job type.

Specified by:

concurrencyLimits in interface JobSchedulerConfig

Returns:

mapping of job type to max number of worker threads to assign for this job type. A missing entry signifies unlimited concurrency (up to numberOfWorkerThreads)