Class: Foam::Otel::GuardedLogRecordProcessor

Inherits:

Object

• Object
• Foam::Otel::GuardedLogRecordProcessor

Defined in:

lib/foam/otel/pipelines.rb

Instance Method Summary

• #force_flush(timeout: nil) ⇒ Object
• #initialize(inner) ⇒ GuardedLogRecordProcessor constructor

  A new instance of GuardedLogRecordProcessor.

• #on_emit(log_record, context) ⇒ Object
• #shutdown(timeout: nil) ⇒ Object

Constructor Details

#initialize(inner) ⇒ GuardedLogRecordProcessor

Returns a new instance of GuardedLogRecordProcessor.

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

def initialize(inner) = @inner = inner

Instance Method Details

#force_flush(timeout: nil) ⇒ Object

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

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

#on_emit(log_record, context) ⇒ Object

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

def on_emit(log_record, context) = guarded { @inner.on_emit(log_record, context) }

#shutdown(timeout: nil) ⇒ Object

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

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