Sha256: e316cdc26b33907d0ee22cfab875a369c96062f9a8870c01d0259ef264dfaeaa

Contents?: true

Size: 759 Bytes

Versions: 20

Compression:

Stored size: 759 Bytes

Contents

# frozen_string_literal: true

module Labkit
  module Middleware
    module Sidekiq
      module Context
        # This middleware for Sidekiq-client uses the values stored on a job to
        # reinstantiate a context in which the job will run.
        class Server
          def call(_worker_class, job, _queue)
            worker_name = (job["wrapped"].presence || job["class"]).to_s
            data = job.merge(Labkit::Context.log_key(:caller_id) => worker_name)
                      .select { |key, _| key.start_with?("#{Labkit::Context::LOG_KEY}.") || Labkit::Context::RAW_KEYS.include?(key.to_s) }

            Labkit::Context.with_context(data) do |_context|
              yield
            end
          end
        end
      end
    end
  end
end

Version data entries

20 entries across 20 versions & 1 rubygems

Version Path
gitlab-labkit-0.37.0 lib/labkit/middleware/sidekiq/context/server.rb
gitlab-labkit-0.36.1 lib/labkit/middleware/sidekiq/context/server.rb
gitlab-labkit-0.36.0 lib/labkit/middleware/sidekiq/context/server.rb
gitlab-labkit-0.35.1 lib/labkit/middleware/sidekiq/context/server.rb
gitlab-labkit-0.35.0 lib/labkit/middleware/sidekiq/context/server.rb
gitlab-labkit-0.34.0 lib/labkit/middleware/sidekiq/context/server.rb
gitlab-labkit-0.33.0 lib/labkit/middleware/sidekiq/context/server.rb
gitlab-labkit-0.32.0 lib/labkit/middleware/sidekiq/context/server.rb
gitlab-labkit-0.31.1 lib/labkit/middleware/sidekiq/context/server.rb
gitlab-labkit-0.31.0 lib/labkit/middleware/sidekiq/context/server.rb
gitlab-labkit-0.30.1 lib/labkit/middleware/sidekiq/context/server.rb
gitlab-labkit-0.30.0 lib/labkit/middleware/sidekiq/context/server.rb
gitlab-labkit-0.29.0 lib/labkit/middleware/sidekiq/context/server.rb
gitlab-labkit-0.28.0 lib/labkit/middleware/sidekiq/context/server.rb
gitlab-labkit-0.27.0 lib/labkit/middleware/sidekiq/context/server.rb
gitlab-labkit-0.26.0 lib/labkit/middleware/sidekiq/context/server.rb
gitlab-labkit-0.25.0 lib/labkit/middleware/sidekiq/context/server.rb
gitlab-labkit-0.24.0 lib/labkit/middleware/sidekiq/context/server.rb
gitlab-labkit-0.23.0 lib/labkit/middleware/sidekiq/context/server.rb
gitlab-labkit-0.22.0 lib/labkit/middleware/sidekiq/context/server.rb