Module: Que::Scheduler

Defined in:
lib/que/scheduler/db.rb,
lib/que/scheduler/audit.rb,
lib/que/scheduler/version.rb,
lib/que/scheduler/schedule.rb,
lib/que/scheduler/time_zone.rb,
lib/que/scheduler/migrations.rb,
lib/que/scheduler/to_enqueue.rb,
lib/que/scheduler/defined_job.rb,
lib/que/scheduler/state_checks.rb,
lib/que/scheduler/configuration.rb,
lib/que/scheduler/scheduler_job.rb,
lib/que/scheduler/version_support.rb,
lib/que/scheduler/scheduler_job_args.rb,
lib/que/scheduler/enqueueing_calculator.rb,
lib/que/scheduler/jobs/que_scheduler_audit_clear_down_job.rb

Defined Under Namespace

Modules: Audit, Db, EnqueueingCalculator, Jobs, Migrations, StateChecks, TimeZone, VersionSupport Classes: ActiveJobType, Configuration, DefinedJob, EnqueuedJobType, QueJobType, Schedule, SchedulerJob, SchedulerJobArgs, ToEnqueue

Constant Summary collapse

VERSION = 
"5.1.1".freeze

Class Attribute Summary collapse

Class Method Summary collapse

Class Attribute Details

.configuration ⇒ Object

Returns the value of attribute configuration.



12
13
14
 
# File 'lib/que/scheduler/configuration.rb', line 12

def configuration
  @configuration
end

Class Method Details

.apply_defaults ⇒ Object 



19
20
21
22
23
24
25
26
27
28
29
 
# File 'lib/que/scheduler/configuration.rb', line 19

def apply_defaults
  configure do |config|
    config.schedule_location =
      ENV.fetch("QUE_SCHEDULER_CONFIG_LOCATION", "config/que_schedule.yml")
    config.transaction_adapter = ::Que.method(:transaction)
    config.que_scheduler_queue =
      ENV.fetch("QUE_SCHEDULER_QUEUE", Que::Scheduler::VersionSupport.default_scheduler_queue)
    config.schedule = nil
    config.time_zone = nil
  end
end

.configure {|configuration| ... } ⇒ Object

Yields:



14
15
16
17
 
# File 'lib/que/scheduler/configuration.rb', line 14

def configure
  self.configuration ||= Configuration.new
  yield(configuration)
end

.schedule ⇒ Object 



80
81
82
 
# File 'lib/que/scheduler/schedule.rb', line 80

def schedule
  Schedule.schedule
end