Fyst 2088 log client activity (#137)

* wip

* give it a shot

* linter

* test

* test

* fix log

* wip

* define propagator as xray

* linter

* try new initializer

* linter

* update requirements in intializers

---------

Co-authored-by: Drew Proebstel <[email protected]>

Author: DrewProebstel

Gemfile

@@ -81,3 +81,4 @@ gem "standard", ">= 1.35.1"
 gem "opentelemetry-sdk", "~> 1.8"
 gem "opentelemetry-exporter-otlp", "~> 0.30.0"
 gem "opentelemetry-instrumentation-all", "~> 0.80.0"
+gem "opentelemetry-propagator-xray"

Gemfile.lock

@@ -505,6 +505,8 @@ GEM
       opentelemetry-helpers-sql-obfuscation
       opentelemetry-instrumentation-base (~> 0.23.0)
       opentelemetry-semantic_conventions (>= 1.8.0)
+    opentelemetry-propagator-xray (0.24.0)
+      opentelemetry-api (~> 1.0)
     opentelemetry-registry (0.4.0)
       opentelemetry-api (~> 1.1)
     opentelemetry-sdk (1.8.1)
@@ -795,6 +797,7 @@ DEPENDENCIES
   mailgun-ruby
   opentelemetry-exporter-otlp (~> 0.30.0)
   opentelemetry-instrumentation-all (~> 0.80.0)
+  opentelemetry-propagator-xray
   opentelemetry-sdk (~> 1.8)
   pg
   phony

config/initializers/opentelemetry.rb

@@ -1,6 +1,34 @@
+# Basic packages for your application
 require "opentelemetry/sdk"
 require "opentelemetry/instrumentation/all"
+
+# Add imports for OTel components into the application
+require "opentelemetry-api"
+require "opentelemetry-exporter-otlp"
+require "opentelemetry-sdk"
+
+# Import the gem containing the AWS X-Ray for OTel Ruby ID Generator and propagator
+require "opentelemetry-propagator-xray"
+
+# Configure OpenTelmetry Ruby SDK
 OpenTelemetry::SDK.configure do |c|
+  # Set the service name to identify your application in the X-Ray backend service map
   c.service_name = "pya"
-  c.use_all
+
+  c.span_processors = [
+    # Use the BatchSpanProcessor to send traces in groups instead of one at a time
+    Trace::Export::BatchSpanProcessor.new(
+      # Use the default OLTP Exporter to send traces to the ADOT Collector
+      OpenTelemetry::Exporter::OTLP::Exporter.new(
+        # The ADOT Collector is running as a sidecar and listening on port 4318
+        "http://localhost:4318"
+      )
+    )
+  ]
+
+  # The X-Ray ID Generator generates spans with X-Ray backend compliant IDs
+  c.id_generator = OpenTelemetry::Propagator::XRay::IDGenerator
+
+  # The X-Ray Propagator injects the X-Ray Tracing Header into downstream calls
+  c.propagators = [OpenTelemetry::Propagator::XRay::TextMapPropagator.new]
 end