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