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