Class: Fluent::Plugin::JqFormatter

Inherits:
Formatter
  • Object
show all
Includes:
JqMixin
Defined in:
lib/fluent/plugin/formatter_jq.rb

Constant Summary

Constants included from JqMixin

JqMixin::JqError

Instance Method Summary collapse

Methods included from JqMixin

#configure, included, #jq_transform, #shutdown, #start, #start_process

Constructor Details

#initialize ⇒ JqFormatter

Returns a new instance of JqFormatter.



32
33
34
 
# File 'lib/fluent/plugin/formatter_jq.rb', line 32

def initialize
  super
end

Instance Method Details

#format(tag, time, record) ⇒ Object 



36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
 
# File 'lib/fluent/plugin/formatter_jq.rb', line 36

def format(tag, time, record)
  item = jq_transform record
  if item.instance_of?(String)
    item
  else
    MultiJson.dump item
  end
rescue JqError
  msg = "Format failed with #{@jq}#{log.on_debug { ' on ' + MultiJson.dump(record) }}, error: #{$!.message}"
  log.error msg
  case @on_error
  when :skip
    return ''
  when :ignore
    return MultiJson.dump(record)
  when :raise_error
    raise msg
  end
end