Class: Fluent::Plugin::SqlMaskFilter

Inherits:
Filter
  • Object
show all
Defined in:
lib/fluent/plugin/filter_sql_mask.rb

Instance Method Summary collapse

Instance Method Details

#filter(tag, time, record) ⇒ Object 



26
27
28
29
30
31
32
33
34
35
36
 
# File 'lib/fluent/plugin/filter_sql_mask.rb', line 26

def filter(tag, time, record)
  if record.has_key? @field
    record[@field] = PgQuery.normalize record[@field]
  end
  record
rescue
  if record.has_key? @field
    record[@field] = "[FILTERED]"
  end
  record
end