Package org.graylog.scheduler

Interface JobSchedulerConfig

All Known Implementing Classes:
DefaultJobSchedulerConfig
public interface JobSchedulerConfig
Used by the scheduler to configure itself.

  • 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.

  • Method Details

    • canExecute

      boolean canExecute()
      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!
      Returns:
      true if scheduler can execute next loop iteration

    • numberOfWorkerThreads

      int numberOfWorkerThreads()
      The number of worker threads to start.
      Returns:
      number of worker threads

    • concurrencyLimits

      Map<String,Integer> concurrencyLimits()
      Concurrency limits per job type.
      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)