Sha256: 2597f0c2a44fa91365bae2d23aaa424e42dc882a1269f2013af6fff7bdbba20f
Contents?: true
Size: 1.56 KB
Versions: 3
Compression:
Stored size: 1.56 KB
Contents
# frozen_string_literal: true # Copyright The OpenTelemetry Authors # # SPDX-License-Identifier: Apache-2.0 module OpenTelemetry module Instrumentation module Sinatra module Middlewares # Middleware to trace Sinatra requests class TracerMiddleware def initialize(app) @app = app end def call(env) tracer.in_span( env['PATH_INFO'], attributes: { 'http.method' => env['REQUEST_METHOD'], 'http.url' => env['PATH_INFO'] }, kind: :server, with_parent: parent_context(env) ) do |span| app.call(env).tap { |resp| trace_response(span, env, resp) } end end private attr_reader :app def parent_context(env) OpenTelemetry.propagation.http.extract(env) end def tracer OpenTelemetry::Instrumentation::Sinatra::Instrumentation.instance.tracer end def trace_response(span, env, resp) status, _headers, _response_body = resp span.set_attribute('http.status_code', status) span.set_attribute('http.status_text', ::Rack::Utils::HTTP_STATUS_CODES[status]) span.set_attribute('http.route', env['sinatra.route'].split.last) if env['sinatra.route'] span.name = env['sinatra.route'] if env['sinatra.route'] span.status = OpenTelemetry::Trace::Status.http_to_status(status) end end end end end end
Version data entries
3 entries across 3 versions & 1 rubygems