Class: Foam::Otel::GuardedSpanProcessor

Inherits:
Object
  • Object
show all
Defined in:
lib/foam/otel/pipelines.rb

Overview

A tenant span/log processor supplied via additional_* — wrapped so a throwing tenant instance is skipped with a loud warning and breaks neither the app nor foam's export (rule 18 C / rule 9). Never-throw is foam's guarantee for foam-invoked calls; the wrapper enforces it.

Instance Method Summary collapse

Constructor Details

#initialize(inner) ⇒ GuardedSpanProcessor

Returns a new instance of GuardedSpanProcessor.



174
 
# File 'lib/foam/otel/pipelines.rb', line 174

def initialize(inner) = @inner = inner

Instance Method Details

#force_flush(timeout: nil) ⇒ Object 



177
 
# File 'lib/foam/otel/pipelines.rb', line 177

def force_flush(timeout: nil) = guarded { @inner.force_flush(timeout: timeout) } || OpenTelemetry::SDK::Trace::Export::SUCCESS

#on_finish(span) ⇒ Object 



176
 
# File 'lib/foam/otel/pipelines.rb', line 176

def on_finish(span) = guarded { @inner.on_finish(span) }

#on_start(span, context) ⇒ Object 



175
 
# File 'lib/foam/otel/pipelines.rb', line 175

def on_start(span, context) = guarded { @inner.on_start(span, context) }

#shutdown(timeout: nil) ⇒ Object 



178
 
# File 'lib/foam/otel/pipelines.rb', line 178

def shutdown(timeout: nil) = guarded { @inner.shutdown(timeout: timeout) } || OpenTelemetry::SDK::Trace::Export::SUCCESS