module Sidekiq::Slog

Constants

VERSION

Public Class Methods

aj_job_args(args) click to toggle source
# File lib/sidekiq-slog/middleware.rb, line 20
def self.aj_job_args(args)
  first_arg = args.first

  # check if the first argument looks like a AJ metadata hash
  if first_arg.is_a?(Hash) && first_arg.key?('arguments')
    first_arg['arguments'].map do |arg|
      if arg.is_a?(Hash) && arg.key?('_aj_globalid')
        arg['_aj_globalid']
      else
        arg
      end
    end
  end
end
aj_job_class(msg) click to toggle source
# File lib/sidekiq-slog/middleware.rb, line 11
def self.aj_job_class(msg)
  msg['wrapped']
end
job_args(msg) click to toggle source
# File lib/sidekiq-slog/middleware.rb, line 15
def self.job_args(msg)
  args = msg['args']
  aj_job_args(args) || args
end
job_class(msg) click to toggle source
# File lib/sidekiq-slog/middleware.rb, line 7
def self.job_class(msg)
  aj_job_class(msg) || msg['class']
end
job_id(msg) click to toggle source
# File lib/sidekiq-slog/middleware.rb, line 3
def self.job_id(msg)
  msg['jid']
end