lib/sidekiq/throttled/strategy.rb in sidekiq-throttled-0.18.0 vs lib/sidekiq/throttled/strategy.rb in sidekiq-throttled-1.0.0.alpha

- old
+ new

@@ -1,12 +1,12 @@ # frozen_string_literal: true # internal -require "sidekiq/throttled/errors" -require "sidekiq/throttled/strategy_collection" -require "sidekiq/throttled/strategy/concurrency" -require "sidekiq/throttled/strategy/threshold" +require_relative "./errors" +require_relative "./strategy_collection" +require_relative "./strategy/concurrency" +require_relative "./strategy/threshold" module Sidekiq module Throttled # Meta-strategy that couples {Concurrency} and {Threshold} strategies. # @@ -33,17 +33,17 @@ # @param [#call] observer Process called after throttled. def initialize(name, concurrency: nil, threshold: nil, key_suffix: nil, observer: nil) # rubocop:disable Metrics/MethodLength @observer = observer @concurrency = StrategyCollection.new(concurrency, - :strategy => Concurrency, - :name => name, - :key_suffix => key_suffix) + strategy: Concurrency, + name: name, + key_suffix: key_suffix) @threshold = StrategyCollection.new(threshold, - :strategy => Threshold, - :name => name, - :key_suffix => key_suffix) + strategy: Threshold, + name: name, + key_suffix: key_suffix) return if @concurrency.any? || @threshold.any? raise ArgumentError, "Neither :concurrency nor :threshold given" end