Contents

module Instana
  module Instrumentation
    class SidekiqClient
      def call(worker_class, msg, queue, _redis_pool)
        kv_payload = { :'sidekiq-client' => {} }
        kv_payload[:'sidekiq-client'][:queue] = queue
        kv_payload[:'sidekiq-client'][:job] = worker_class
        kv_payload[:'sidekiq-client'][:retry] = msg['retry'].to_s
        ::Instana.tracer.log_entry(:'sidekiq-client', kv_payload)

        # Temporary until we move connection collection to redis
        # instrumentation
        Sidekiq.redis_pool.with do |conn|
          opts = conn.client.options
          kv_payload[:'sidekiq-client'][:'redis-url'] = "#{opts[:host]}:#{opts[:port]}"
        end

        context = ::Instana.tracer.context
        if context
          msg['X-Instana-T'] = context.trace_id_header
          msg['X-Instana-S'] = context.span_id_header
        end

        result = yield

        kv_payload[:'sidekiq-client'][:job_id] = result['jid']
        result
      rescue => e
        ::Instana.tracer.log_error(e)
        raise
      ensure
        ::Instana.tracer.log_exit(:'sidekiq-client', kv_payload)
      end
    end
  end
end

if defined?(::Sidekiq) && ::Instana.config[:'sidekiq-client'][:enabled]
  ::Sidekiq.configure_client do |cfg|
    cfg.client_middleware do |chain|
      ::Instana.logger.warn "Instrumenting Sidekiq client"
      chain.add ::Instana::Instrumentation::SidekiqClient
    end
  end
end

Version data entries

8 entries across 8 versions & 1 rubygems

Version	Path
instana-1.7.6	lib/instana/instrumentation/sidekiq-client.rb
instana-1.7.5	lib/instana/instrumentation/sidekiq-client.rb
instana-1.7.4	lib/instana/instrumentation/sidekiq-client.rb
instana-1.7.3	lib/instana/instrumentation/sidekiq-client.rb
instana-1.7.2	lib/instana/instrumentation/sidekiq-client.rb
instana-1.7.1	lib/instana/instrumentation/sidekiq-client.rb
instana-1.7.0	lib/instana/instrumentation/sidekiq-client.rb
instana-1.6.1	lib/instana/instrumentation/sidekiq-client.rb