Class: Fluent::Plugin::Marginalia

Inherits:
Filter
  • Object
show all
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 collapse

MARGINALIA_PREPENDED_REGEXP = 
%r{^(?<comment>/\*.*\*/)(?<sql>.*)}m.freeze
MARGINALIA_APPENDED_REGEXP = 
%r{(?<sql>.*)(?<comment>/\*.*\*/)$}m.freeze

Instance Method Summary collapse

Instance Method Details

#filter(_tag, _time, record) ⇒ Object 



25
26
27
28
29
 
# File 'lib/fluent/plugin/filter_marginalia.rb', line 25

def filter(_tag, _time, record)
  parse_comments(record)

  record
end