Contents

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

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

  def filter(tag, time, record)
    record[@key] = Time.parse(record[@key]).strftime('%s')
    record
  end
end if defined?(Fluent::Filter)

Version data entries

1 entries across 1 versions & 1 rubygems

Version	Path
fluent-plugin-dio-0.0.1	lib/fluent/plugin/filter_dio.rb