Contents

module Fluent
  class Simple2hash < Filter
    Plugin.register_filter('simple2hash', self)

    config_param :var, :string, :default => 'value'

    def configure(conf)
      super
      @var ||= conf['var']
    end

    def filter(tag, time, record)
      if record.is_a?(Numeric) or record.is_a?(Array) or record.is_a?(String)
        obj = Hash.new
        obj[@var] = record
        return obj
      else
        return record
      end
    end
  end
end

Version data entries

1 entries across 1 versions & 1 rubygems

Version	Path
fluent-plugin-simple-to-hash-0.0.2	lib/fluent/plugin/filter_simple2hash.rb