Contents

class Fluent::DioFilter < Fluent::Filter
  Fluent::Plugin.register_filter('dio', self)

  config_param :keys, :string, :default => 'time'

  def configure(conf)
    super

    @keys = @keys.split(',').map(&:strip)
  end

  def filter(tag, time, record)
    @keys.each do |key|
      record[key] = Time.parse(record[key]).to_i
    end
    record
  end
end if defined?(Fluent::Filter)

Version data entries

2 entries across 2 versions & 1 rubygems

Version	Path
fluent-plugin-dio-1.0.1	lib/fluent/plugin/filter_dio.rb
fluent-plugin-dio-1.0.0	lib/fluent/plugin/filter_dio.rb