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, config = nil) ⇒ GuardedLogRecordProcessor constructor

  A new instance of GuardedLogRecordProcessor.

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

Constructor Details

#initialize(inner, config = nil) ⇒ GuardedLogRecordProcessor

Returns a new instance of GuardedLogRecordProcessor.

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

def initialize(inner, config = nil)
  @inner = inner
  @config = config
end

Instance Method Details

#force_flush(timeout: nil) ⇒ Object

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

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 297

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

#shutdown(timeout: nil) ⇒ Object

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

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