class Fluent::RecordReformerOutputCore::PlaceholderExpander
THIS CLASS MUST BE THREAD-SAFE
Attributes
log[R]
placeholders[R]
Public Class Methods
new(params)
click to toggle source
# File lib/fluent/plugin/out_record_reformer/core.rb, line 190 def initialize(params) @log = params[:log] @auto_typecast = params[:auto_typecast] end
Public Instance Methods
expand(str, placeholders, force_stringify = false)
click to toggle source
Expand string with placeholders
@param [String] str @param [Boolean] force_stringify the value must be string, used for hash key
# File lib/fluent/plugin/out_record_reformer/core.rb, line 232 def expand(str, placeholders, force_stringify = false) if @auto_typecast and !force_stringify single_placeholder_matched = str.match(/\A(\${[^}]+}|__[A-Z_]+__)\z/) if single_placeholder_matched log_if_unknown_placeholder($1, placeholders) return placeholders[single_placeholder_matched[1]] end end str.gsub(/(\${[^}]+}|__[A-Z_]+__)/) { log_if_unknown_placeholder($1, placeholders) placeholders[$1] } end
prepare_placeholders(placeholder_values)
click to toggle source
# File lib/fluent/plugin/out_record_reformer/core.rb, line 203 def prepare_placeholders(placeholder_values) placeholders = {} placeholder_values.each do |key, value| if value.kind_of?(Array) # tag_parts, etc size = value.size value.each_with_index do |v, idx| placeholders.store("${#{key}[#{idx}]}", v) placeholders.store("${#{key}[#{idx-size}]}", v) # support [-1] end elsif value.kind_of?(Hash) # record, etc value.each do |k, v| unless placeholder_values.has_key?(k) # prevent overwriting the reserved keys such as tag placeholders.store("${#{k}}", v) end placeholders.store(%Q[${#{key}["#{k}"]}], v) # record["foo"] end else # string, interger, float, and others? placeholders.store("${#{key}}", value) end end placeholders end
preprocess_map(value, force_stringify = false)
click to toggle source
# File lib/fluent/plugin/out_record_reformer/core.rb, line 199 def preprocess_map(value, force_stringify = false) value end
time_value(time)
click to toggle source
# File lib/fluent/plugin/out_record_reformer/core.rb, line 195 def time_value(time) Time.at(time).to_s end
Private Instance Methods
log_if_unknown_placeholder(placeholder, placeholders)
click to toggle source
# File lib/fluent/plugin/out_record_reformer/core.rb, line 248 def log_if_unknown_placeholder(placeholder, placeholders) unless placeholders.include?(placeholder) log.warn "record_reformer: unknown placeholder `#{placeholder}` found" end end