Contents

require "fluent/plugin/filter"

module Fluent
  module Plugin
    class DockergelfFilter < Fluent::Plugin::Filter
      Fluent::Plugin.register_filter("dockergelf", self)
      def configure(conf)
        @f = File.new('/tempfile/out.txt', 'w')
        super
      end
      def filter(tag, time, record)
        @f.write(tag.to_s)
        @f.write("\n")
        @f.write(time.to_s)
        @f.write("\n")
        @f.write(record.to_s)
        @f.write("\n")
        record
      end
    end
  end
end

Version data entries

1 entries across 1 versions & 1 rubygems

Version	Path
fluent-plugin-dockergelf-0.1.3	lib/fluent/plugin/filter_dockergelf.rb