Class: OpenTelemetry::Instrumentation::ActionView::SpanSubscriber
- Inherits:
-
Object
- Object
- OpenTelemetry::Instrumentation::ActionView::SpanSubscriber
- Defined in:
- lib/opentelemetry/instrumentation/action_view/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
rubocop:disable Metrics/AbcSize.
-
#initialize(name:, tracer:) ⇒ SpanSubscriber
constructor
A new instance of SpanSubscriber.
- #start(name, id, payload) ⇒ Object
Constructor Details
#initialize(name:, tracer:) ⇒ SpanSubscriber
Returns a new instance of SpanSubscriber.
33 34 35 36 |
# File 'lib/opentelemetry/instrumentation/action_view/span_subscriber.rb', line 33 def initialize(name:, tracer:) @span_name = name.split('.')[0..1].reverse.join(' ').freeze @tracer = tracer end |
Instance Method Details
#finish(name, id, payload) ⇒ Object
rubocop:disable Metrics/AbcSize
51 52 53 54 55 56 57 58 59 60 61 62 63 64 65 66 67 68 69 |
# File 'lib/opentelemetry/instrumentation/action_view/span_subscriber.rb', line 51 def finish(name, id, payload) # rubocop:disable Metrics/AbcSize span = payload.delete(:__opentelemetry_span) token = payload.delete(:__opentelemetry_ctx_token) return unless span && token payload = transform_payload(payload) attrs = payload.map do |k, v| [k.to_s, sanitized_value(v)] if valid_payload_key?(k) && valid_payload_value?(v) end span.add_attributes(attrs.compact.to_h) 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
38 39 40 41 42 43 44 45 46 47 48 49 |
# File 'lib/opentelemetry/instrumentation/action_view/span_subscriber.rb', line 38 def start(name, id, payload) span = @tracer.start_span(@span_name, kind: :internal) token = OpenTelemetry::Context.attach( OpenTelemetry::Trace.context_with_span(span) ) payload.merge!( __opentelemetry_span: span, __opentelemetry_ctx_token: token ) [span, token] end |