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/db_support.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/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, DbSupport, EnqueueingCalculator, Jobs, Migrations, StateChecks, TimeZone Classes: ActiveJobType, Configuration, DefinedJob, EnqueuedJobType, QueJobType, Schedule, SchedulerJob, SchedulerJobArgs, ToEnqueue

Constant Summary collapse

VERSION =

New major

"6.0.0".freeze

Class Attribute Summary collapse

Class Method Summary collapse

Class Attribute Details

.configuration ⇒ Object

:reek:Attribute



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

def configuration
  @configuration
end

Class Method Details

.apply_defaults ⇒ Object 



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

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::DEFAULT_QUEUE)
    config.schedule = nil
    config.time_zone = nil
  end
end

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

Yields:



16
17
18
19
 
# File 'lib/que/scheduler/configuration.rb', line 16

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