class Fluent::Plugin::SprintfFormatter
Public Class Methods
new()
click to toggle source
Calls superclass method
# File lib/fluent/plugin/formatter_sprintf.rb, line 12 def initialize super end
Public Instance Methods
configure(conf)
click to toggle source
Calls superclass method
# File lib/fluent/plugin/formatter_sprintf.rb, line 16 def configure(conf) super @time_format = @time_format || '%Y-%m-%d %H:%M:%S' r = /\$\{([^}]+)\}/ @keys = @sprintf_format.scan(r).map{ |key| key.first } @sprintf_format = @sprintf_format.gsub(/\$\{([^}]+)\}/, '%s') if @sprintf_blank_record_format @sprintf_blank_record_keys = @sprintf_blank_record_format.scan(r).map{ |key| key.first } @sprintf_blank_record_format = @sprintf_blank_record_format.gsub(/\$\{([^}]+)\}/, '%s') end begin @sprintf_format % @keys rescue ArgumentError => e raise Fluent::ConfigError, "formatter_sprintf: @sprintf_format is can't include '%'" end end
format(tag, time, record)
click to toggle source
# File lib/fluent/plugin/formatter_sprintf.rb, line 34 def format(tag, time, record) if record.empty? && @sprintf_blank_record_format return @sprintf_blank_record_format % get_values(@sprintf_blank_record_keys, tag, time, record) end @sprintf_format % get_values(@keys, tag, time, record) end
get_value(key, tag, time, record)
click to toggle source
# File lib/fluent/plugin/formatter_sprintf.rb, line 47 def get_value(key, tag, time, record) if key == 'tag' tag elsif key == 'time' Time.at(time).strftime(@time_format) else return @sprintf_blank_string if record[key].nil? if record[key].respond_to?(:empty?) && record[key].empty? return @sprintf_blank_string end if record[key].class == String && record[key].strip.empty? return @sprintf_blank_string end record[key] end end
get_values(keys, tag, time, record)
click to toggle source
# File lib/fluent/plugin/formatter_sprintf.rb, line 41 def get_values(keys, tag, time, record) keys.map{ |key| get_value(key, tag, time, record) } end