lib/sidekiq/belt/ent/files.rb in sidekiq-belt-0.3.1 vs lib/sidekiq/belt/ent/files.rb in sidekiq-belt-0.3.2
- old
+ new
@@ -2,23 +2,27 @@
require "sidekiq"
require_relative "periodic_pause"
require_relative "periodic_run"
+require_relative "periodic_sort"
module Sidekiq
module Belt
module Ent
module Files
def self.use!(options = [:all])
return unless Sidekiq.ent?
- all = options.include?(:all)
+ Sidekiq::Belt::Ent::PeriodicPause.use! if should_use?(:periodic_pause, options)
+ Sidekiq::Belt::Ent::PeriodicRun.use! if should_use?(:periodic_run, options)
+ Sidekiq::Belt::Ent::PeriodicSort.use! if should_use?(:periodic_sort, options)
- Sidekiq::Belt::Ent::PeriodicPause.use! if all || options.include?(:periodic_pause)
- Sidekiq::Belt::Ent::PeriodicRun.use! if all || options.include?(:periodic_run)
-
true
+ end
+
+ def self.should_use?(key, options)
+ options.include?(:all) || options.include?(key)
end
end
end
end
end