Module: OpenTelemetry::Exporter::OTLP::Common

Extended by:
Common
Included in:
Common
Defined in:
lib/opentelemetry/exporter/otlp/common.rb,
lib/opentelemetry/exporter/otlp/common/version.rb,
lib/opentelemetry/exporter/otlp/common/utilities.rb

Overview

Contains common functionality between the different OTLP export protocols

Defined Under Namespace

Modules: Utilities

Constant Summary collapse

VERSION =

Current OpenTelemetry OTLP exporter common version

'0.3.0'

Instance Method Summary collapse

Instance Method Details

#as_encoded_etsr(span_data) ⇒ String

As encoded etsr (ExportTraceServiceRequest)

Parameters:

  • span_data (Enumerable<OpenTelemetry::SDK::Trace::SpanData>) —

    the list of recorded SDK::Trace::SpanData structs to be encoded.

Returns:

  • (String) —

    returns an encoded ETSR of the provided span data



33
34
35
36
37
38
 
# File 'lib/opentelemetry/exporter/otlp/common.rb', line 33

def as_encoded_etsr(span_data)
  Opentelemetry::Proto::Collector::Trace::V1::ExportTraceServiceRequest.encode(as_etsr(span_data))
rescue StandardError => e
  OpenTelemetry.handle_error(exception: e, message: 'unexpected error in OTLP::Common#as_encoded_etsr')
  nil
end

#as_etsr(span_data) ⇒ Opentelemetry::Proto::Collector::Trace::V1::ExportTraceServiceRequest

As etsr (ExportTraceServiceRequest)

Parameters:

  • span_data (Enumerable<OpenTelemetry::SDK::Trace::SpanData>) —

    the list of recorded SDK::Trace::SpanData structs to be encoded.

Returns:

  • (Opentelemetry::Proto::Collector::Trace::V1::ExportTraceServiceRequest) —

    returns an ETSR of the provided span data



48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
 
# File 'lib/opentelemetry/exporter/otlp/common.rb', line 48

def as_etsr(span_data)
  Opentelemetry::Proto::Collector::Trace::V1::ExportTraceServiceRequest.new(
    resource_spans: span_data
                    .group_by(&:resource)
                    .map do |resource, span_datas|
                      Opentelemetry::Proto::Trace::V1::ResourceSpans.new(
                        resource: Opentelemetry::Proto::Resource::V1::Resource.new(
                          attributes: resource.attribute_enumerator.map { |key, value| as_otlp_key_value(key, value) }
                        ),
                        scope_spans: span_datas
                                     .group_by(&:instrumentation_scope)
                                     .map do |il, sds|
                                       Opentelemetry::Proto::Trace::V1::ScopeSpans.new(
                                         scope: Opentelemetry::Proto::Common::V1::InstrumentationScope.new(
                                           name: il.name,
                                           version: il.version
                                         ),
                                         spans: sds.map { |sd| as_otlp_span(sd) }
                                       )
                                     end
                      )
                    end
  )
end