Class: OpenTelemetry::Instrumentation::ActiveSupport::SpanSubscriber
- Inherits:
-
Object
- Object
- OpenTelemetry::Instrumentation::ActiveSupport::SpanSubscriber
- Defined in:
- lib/opentelemetry/instrumentation/active_support/span_subscriber.rb
Constant Summary collapse
- ALWAYS_VALID_PAYLOAD_TYPES =
[TrueClass, FalseClass, String, Numeric, Symbol].freeze
Instance Method Summary collapse
- #finish(name, id, payload) ⇒ Object
-
#initialize(name:, tracer:, notification_payload_transform: nil, disallowed_notification_payload_keys: [], kind: nil) ⇒ SpanSubscriber
constructor
A new instance of SpanSubscriber.
- #start(name, id, payload) ⇒ Object
Constructor Details
#initialize(name:, tracer:, notification_payload_transform: nil, disallowed_notification_payload_keys: [], kind: nil) ⇒ SpanSubscriber
Returns a new instance of SpanSubscriber.
60 61 62 63 64 65 66 |
# File 'lib/opentelemetry/instrumentation/active_support/span_subscriber.rb', line 60 def initialize(name:, tracer:, notification_payload_transform: nil, disallowed_notification_payload_keys: [], kind: nil) @span_name = name.split('.')[0..1].reverse.join(' ').freeze @tracer = tracer @notification_payload_transform = notification_payload_transform @disallowed_notification_payload_keys = disallowed_notification_payload_keys @kind = kind || :internal end |
Instance Method Details
#finish(name, id, payload) ⇒ Object
79 80 81 82 83 84 85 86 87 88 89 90 91 92 93 94 95 96 97 |
# File 'lib/opentelemetry/instrumentation/active_support/span_subscriber.rb', line 79 def finish(name, id, payload) span = payload.delete(:__opentelemetry_span) token = payload.delete(:__opentelemetry_ctx_token) return unless span && token attrs = transform_payload(payload).each_with_object({}) do |(k, v), accum| accum[k.to_s] = sanitized_value(v) if valid_payload_key?(k) && valid_payload_value?(v) end span.add_attributes(attrs) if (e = payload[:exception_object]) span.record_exception(e) span.status = OpenTelemetry::Trace::Status.error("Unhandled exception of type: #{e.class}") end span.finish OpenTelemetry::Context.detach(token) end |
#start(name, id, payload) ⇒ Object
68 69 70 71 72 73 74 75 76 77 |
# File 'lib/opentelemetry/instrumentation/active_support/span_subscriber.rb', line 68 def start(name, id, payload) span = @tracer.start_span(@span_name, kind: @kind) token = OpenTelemetry::Context.attach( OpenTelemetry::Trace.context_with_span(span) ) payload[:__opentelemetry_span] = span payload[:__opentelemetry_ctx_token] = token [span, token] end |