Class: Fluent::Plugin::Marginalia

Inherits:

Filter

• Object
• Filter
• Fluent::Plugin::Marginalia

Includes:

MarginaliaExtractor

Defined in:

lib/fluent/plugin/filter_marginalia.rb

Overview

Filters SQL statements for Marginalia comments.

Examples: SELECT COUNT(*) FROM “projects” /*application:sidekiq,correlation_id:d67cae54c169e0cab7d73389e2934f0e,jid:52a1c8a9e4c555ea573f20f0,job_class:Geo::MetricsUpdateWorker*/ /*application:sidekiq,correlation_id:d67cae54c169e0cab7d73389e2934f0e,jid:52a1c8a9e4c555ea573f20f0,job_class:Geo::MetricsUpdateWorker*/ SELECT COUNT(*) FROM “projects”

Constant Summary

Constants included from MarginaliaExtractor

Fluent::Plugin::MarginaliaExtractor::MARGINALIA_APPENDED_REGEXP, Fluent::Plugin::MarginaliaExtractor::MARGINALIA_PREPENDED_REGEXP

Instance Method Summary

• #filter(_tag, _time, record) ⇒ Object

Methods included from MarginaliaExtractor

#extract_entries, #match_marginalia_comment, #parse_entries, #parse_marginalia_into_record, #scrub_comment, #store_key

Instance Method Details

#filter(_tag, _time, record) ⇒ Object

# File 'lib/fluent/plugin/filter_marginalia.rb', line 24

def filter(_tag, _time, record)
  parse_marginalia_into_record(record, @key, @strip_comment)

  record
end