Class: Fluent::RecordReformerOutputCore::RubyPlaceholderExpander

Inherits:
Object
  • Object
show all
Defined in:
lib/fluent/plugin/out_record_reformer/core.rb

Overview

THIS CLASS MUST BE THREAD-SAFE

Defined Under Namespace

Classes: CleanroomExpander

Instance Attribute Summary collapse

Instance Method Summary collapse

Constructor Details

#initialize(params) ⇒ RubyPlaceholderExpander

Returns a new instance of RubyPlaceholderExpander.



259
260
261
262
263
 
# File 'lib/fluent/plugin/out_record_reformer/core.rb', line 259

def initialize(params)
  @log = params[:log]
  @auto_typecast = params[:auto_typecast]
  @cleanroom_expander = CleanroomExpander.new
end

Instance Attribute Details

#log ⇒ Object (readonly)

Returns the value of attribute log.



257
258
259
 
# File 'lib/fluent/plugin/out_record_reformer/core.rb', line 257

def log
  @log
end

Instance Method Details

#expand(str, placeholders, force_stringify = false) ⇒ Object

Expand string with placeholders

Parameters:

  • str (String) 


308
309
310
311
312
313
314
315
316
317
318
319
320
321
322
323
 
# File 'lib/fluent/plugin/out_record_reformer/core.rb', line 308

def expand(str, placeholders, force_stringify = false)
  @cleanroom_expander.expand(
    str,
    placeholders['tag'],
    placeholders['time'],
    placeholders['record'],
    placeholders['tag_parts'],
    placeholders['tag_prefix'],
    placeholders['tag_suffix'],
    placeholders['hostname'],
  )
rescue => e
  log.warn "record_reformer: failed to expand `#{str}`", :error_class => e.class, :error => e.message
  log.warn_backtrace
  nil
end

#prepare_placeholders(placeholder_values) ⇒ Object 



301
302
303
 
# File 'lib/fluent/plugin/out_record_reformer/core.rb', line 301

def prepare_placeholders(placeholder_values)
  placeholder_values
end

#preprocess_map(value, force_stringify = false) ⇒ Object

Preprocess record map to convert into ruby string expansion

Parameters:

  • value (Hash|String|Array) —

    record map config

  • force_stringify (Boolean) (defaults to: false) —

    the value must be string, used for hash key



273
274
275
276
277
278
279
280
281
282
283
284
285
286
287
288
289
290
291
292
293
294
295
296
297
298
299
 
# File 'lib/fluent/plugin/out_record_reformer/core.rb', line 273

def preprocess_map(value, force_stringify = false)
  new_value = nil
  if value.is_a?(String)
    if @auto_typecast and !force_stringify
      num_placeholders = value.scan('${').size
      if num_placeholders == 1 and value.start_with?('${') && value.end_with?('}')
        new_value = value[2..-2] # ${..} => ..
      end
    end
    unless new_value
      new_value = "%Q[#{value.gsub('${', '#{')}]" # xx${..}xx => %Q[xx#{..}xx]
    end
  elsif value.is_a?(Hash)
    new_value = {}
    value.each_pair do |k, v|
      new_value[preprocess_map(k, true)] = preprocess_map(v)
    end
  elsif value.is_a?(Array)
    new_value = []
    value.each_with_index do |v, i|
      new_value[i] = preprocess_map(v)
    end
  else
    new_value = value
  end
  new_value
end

#time_value(time) ⇒ Object 



265
266
267
 
# File 'lib/fluent/plugin/out_record_reformer/core.rb', line 265

def time_value(time)
  Time.at(time)
end