Sha256: 329101bf59efc02e6b841b5b64e868fdfe87c963d0d3b20c0605a739b6e2a090

Contents?: true

Size: 526 Bytes

Versions: 9

Compression:

Stored size: 526 Bytes

Contents

# frozen_string_literal: true

module Sidekiq
  module Throttled
    class Strategy
      module Base
        def limit(job_args = nil)
          @limit.respond_to?(:call) ? @limit.call(*job_args) : @limit
        end

        private

        def key(job_args)
          key = @base_key.dup
          return key unless @key_suffix

          key << ":#{@key_suffix.call(*job_args)}"
        rescue => e
          Sidekiq.logger.error "Failed to get key suffix: #{e}"
          raise e
        end
      end
    end
  end
end

Version data entries

9 entries across 9 versions & 1 rubygems

Version Path
sidekiq-throttled-1.1.0 lib/sidekiq/throttled/strategy/base.rb
sidekiq-throttled-1.0.1 lib/sidekiq/throttled/strategy/base.rb
sidekiq-throttled-1.0.0 lib/sidekiq/throttled/strategy/base.rb
sidekiq-throttled-1.0.0.alpha.1 lib/sidekiq/throttled/strategy/base.rb
sidekiq-throttled-1.0.0.alpha lib/sidekiq/throttled/strategy/base.rb
sidekiq-throttled-0.18.0 lib/sidekiq/throttled/strategy/base.rb
sidekiq-throttled-0.17.0 lib/sidekiq/throttled/strategy/base.rb
sidekiq-throttled-0.16.2 lib/sidekiq/throttled/strategy/base.rb
sidekiq-throttled-0.16.1 lib/sidekiq/throttled/strategy/base.rb