Contents

module Sidekiq
  module CircuitBreaker
    module Scope
      def extract_scope(worker_class_name, msg, options)
        from_setup =
          begin
            scope = options.scope
            return scope if scope.is_a?(String)
            return unless scope.respond_to?(:call)

            options.scope.call(*msg['args'])
          end

        from_setup || worker_class_name
      end
    end
  end
end

Version data entries

1 entries across 1 versions & 1 rubygems

Version	Path
sidekiq-circuit-breaker-0.1.5	lib/sidekiq/circuit_breaker/scope.rb