class Sidekiq::Middleware::Server::RequestId

Attributes

no_reset[RW]

Public Class Methods

new(options = nil) click to toggle source
# File lib/sidekiq/middleware/server/request_id.rb, line 15
def initialize(options = nil)
  @options = options || default_options
end

Public Instance Methods

call(worker, item, queue) { || ... } click to toggle source
# File lib/sidekiq/middleware/server/request_id.rb, line 19
def call(worker, item, queue)
  ::RequestId.set(@options[:key], @options[:value].call(item))
  yield
ensure
  ::RequestId.set(@options[:key], nil) unless self.class.no_reset
end

Private Instance Methods

default_options() click to toggle source
# File lib/sidekiq/middleware/server/request_id.rb, line 28
def default_options
  { key: :request_id, value: lambda { |item| item['request_id'] } }
end