class Fluent::Plugin::SqlMaskFilter

Public Instance Methods

filter(tag, time, record) click to toggle source
# File lib/fluent/plugin/filter_sql_mask.rb, line 32
def filter(tag, time, record)
  if record.has_key? @field
    record[@field] = Mask.masked record[@field]
    if record[@field].empty?
      record[@field] = "[ PARSE ERROR | FILTERED WHOLE SQL ]"
    end
  end
  record
end