Sha256: ea2648b933855606b6df88aa7c2e75e40d6ea5c4f523ecc73685d142e1609ae1

Contents?: true

Size: 725 Bytes

Versions: 7

Compression:

Stored size: 725 Bytes

Contents

# frozen_string_literal: true

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?

          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)

          true
        end

        def self.should_use?(key, options)
          options.include?(:all) || options.include?(key)
        end
      end
    end
  end
end

Version data entries

7 entries across 7 versions & 1 rubygems

Version Path
sidekiq-belt-2.0.0 lib/sidekiq/belt/ent/files.rb
sidekiq-belt-1.0.0 lib/sidekiq/belt/ent/files.rb
sidekiq-belt-0.3.7 lib/sidekiq/belt/ent/files.rb
sidekiq-belt-0.3.6 lib/sidekiq/belt/ent/files.rb
sidekiq-belt-0.3.5 lib/sidekiq/belt/ent/files.rb
sidekiq-belt-0.3.4 lib/sidekiq/belt/ent/files.rb
sidekiq-belt-0.3.2 lib/sidekiq/belt/ent/files.rb