Module: Datadog::Tracing::Contrib::WaterDrop

Defined in:
lib/datadog/tracing/contrib/waterdrop.rb,
lib/datadog/tracing/contrib/waterdrop/ext.rb,
lib/datadog/tracing/contrib/waterdrop/patcher.rb,
lib/datadog/tracing/contrib/waterdrop/producer.rb,
lib/datadog/tracing/contrib/waterdrop/middleware.rb,
lib/datadog/tracing/contrib/waterdrop/integration.rb,
lib/datadog/tracing/contrib/waterdrop/configuration/settings.rb,
lib/datadog/tracing/contrib/waterdrop/distributed/propagation.rb,
sig/datadog/tracing/contrib/waterdrop.rbs,
sig/datadog/tracing/contrib/waterdrop/ext.rbs,
sig/datadog/tracing/contrib/waterdrop/patcher.rbs,
sig/datadog/tracing/contrib/waterdrop/producer.rbs,
sig/datadog/tracing/contrib/waterdrop/middleware.rbs,
sig/datadog/tracing/contrib/waterdrop/integration.rbs,
sig/datadog/tracing/contrib/waterdrop/configuration/settings.rbs,
sig/datadog/tracing/contrib/waterdrop/distributed/propagation.rbs

Overview

WaterDrop integration public API

Defined Under Namespace

Modules: Configuration

Class Method Summary collapse

Class Method Details

.extract(data) ⇒ Object

Extracts trace context from message headers, returns TraceDigest or nil



11
12
13
14
15
16
17
# File 'sig/datadog/tracing/contrib/waterdrop.rbs', line 11

def self.extract(data)
  raise 'Please invoke Datadog.configure at least once before calling this method' unless @propagation

  # Steep: https://github.com/soutaro/steep/issues/477
  # @type ivar @propagation: WaterDrop::Distributed::Propagation
  @propagation.extract(data)
end

.inject(digest, data) ⇒ Object

Injects trace context into message headers



8
9
10
11
12
13
14
# File 'sig/datadog/tracing/contrib/waterdrop.rbs', line 8

def self.inject(digest, data)
  raise 'Please invoke Datadog.configure at least once before calling this method' unless @propagation

  # Steep: https://github.com/soutaro/steep/issues/477
  # @type ivar @propagation: WaterDrop::Distributed::Propagation
  @propagation.inject!(digest, data)
end