Module: Freddy::Tracing

Defined in:
lib/freddy/tracing.rb

Constant Summary collapse

RESPONSE_QUEUE_PREFIX = 
'amq.gen-'

Class Method Summary collapse

Class Method Details

.inject_tracing_information_to_properties!(properties, span) ⇒ Object 



42
43
44
45
46
 
# File 'lib/freddy/tracing.rb', line 42

def self.inject_tracing_information_to_properties!(properties, span)
  context = OpenTelemetry::Trace.context_with_span(span)
  properties[:headers] ||= {}
  OpenTelemetry.propagation.inject(properties[:headers], context: context)
end

.span_destination(destination, routing_key) ⇒ Object 



34
35
36
37
38
39
40
 
# File 'lib/freddy/tracing.rb', line 34

def self.span_destination(destination, routing_key)
  if routing_key.to_s.start_with?(RESPONSE_QUEUE_PREFIX)
    "#{destination}.(response queue)"
  else
    "#{destination}.#{routing_key}"
  end
end

.span_for_produce(exchange, routing_key, payload, correlation_id: nil, timeout_in_seconds: nil) ⇒ Object

NOTE: Make sure you finish the span youself.



8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
 
# File 'lib/freddy/tracing.rb', line 8

def self.span_for_produce(exchange, routing_key, payload, correlation_id: nil, timeout_in_seconds: nil)
  destination = exchange.name
  destination_kind = exchange.type == :direct ? 'queue' : 'topic'

  attributes = {
    'payload.type' => (payload[:type] || 'unknown').to_s,
    OpenTelemetry::SemanticConventions::Trace::MESSAGING_SYSTEM => 'rabbitmq',
    OpenTelemetry::SemanticConventions::Trace::MESSAGING_RABBITMQ_ROUTING_KEY => routing_key,
    OpenTelemetry::SemanticConventions::Trace::MESSAGING_DESTINATION => destination,
    OpenTelemetry::SemanticConventions::Trace::MESSAGING_DESTINATION_KIND => destination_kind,
    OpenTelemetry::SemanticConventions::Trace::MESSAGING_OPERATION => 'send'
  }

  attributes['freddy.timeout_in_seconds'] = timeout_in_seconds if timeout_in_seconds

  if correlation_id
    attributes[OpenTelemetry::SemanticConventions::Trace::MESSAGING_CONVERSATION_ID] = correlation_id
  end

  Freddy.tracer.start_span(
    "#{span_destination(destination, routing_key)} send",
    kind: OpenTelemetry::Trace::SpanKind::PRODUCER,
    attributes: attributes
  )
end