Sha256: 1cf58f10a907cc3329e523bc76d105dd03e046b463fedeab8b664e9818252593

Contents?: true

Size: 573 Bytes

Versions: 2

Compression:

Stored size: 573 Bytes

Contents

# frozen_string_literal: true

require "sidekiq"

require_relative "failed_batch_remove"
require_relative "force_batch_callback"

module Sidekiq
  module Belt
    module Pro
      module Files
        def self.use!(options = [:all])
          return unless Sidekiq.pro?

          all = options.include?(:all)

          Sidekiq::Belt::Pro::FailedBatchRemove.use! if all || options.include?(:failed_batch_remove)
          Sidekiq::Belt::Pro::ForceBatchCallback.use! if all || options.include?(:force_batch_callback)

          true
        end
      end
    end
  end
end

Version data entries

2 entries across 2 versions & 1 rubygems

Version Path
sidekiq-belt-2.0.0 lib/sidekiq/belt/pro/files.rb
sidekiq-belt-1.0.0 lib/sidekiq/belt/pro/files.rb