Sha256: cd2307486c404651381b52d0c5ca52068db5f87a309b490de1746dbbe2bf605b
Contents?: true
Size: 1.48 KB
Versions: 1
Compression:
Stored size: 1.48 KB
Contents
require 'rekiq/validator' module Rekiq class Configuration include Validator attr_accessor :schedule_post_work, :work_time_shift, :work_time_tolerance, :schedule_expired validate :schedule_post_work, :bool validate :work_time_shift, :numeric validate :work_time_tolerance, :numeric, greater_than_or_equal_to: 0 validate :schedule_expired, :bool def initialize # indicates if next work is scheduled after or before the worker completes # this is relevant when we want to guarantee that workers do not run in paralel # type bool, default false @schedule_post_work = false # indicates a shift, in seconds, to apply to event time returned from schedule # to calculate the work_time # type int, default 0 @work_time_shift = 0 # indicates the tolerance, in seconds, for work_time relative to current time # type int (value greater than or equal to 0), default 0 @work_time_tolerance = 0 # indicates if expired work_times are to be scheduled # a work_time is considered expired when it's before current time minus # work_time_tolerance # type bool, default false @schedule_expired = false end end class << self def configure yield configuration configuration.validate! end def configuration @configuration ||= Configuration.new end def reset_configuration @configuration = Configuration.new end end end
Version data entries
1 entries across 1 versions & 1 rubygems
Version | Path |
---|---|
rekiq-1.2.0 | lib/rekiq/configuration.rb |