require 'fluent/formatter'

module Fluent
  module TextFormatter
    class GELFFormatter < Formatter

      Plugin.register_formatter("gelf", self)

      require 'fluent/gelf_util'
      include GelfUtil

      config_param :use_record_host, :bool, :default => true
      config_param :add_msec_time, :bool, :default => false

      def configure(conf)
        super(conf)
        require 'gelf'
      end

      def format(tag, time, record)
        gelfentry = make_gelfentry(
          tag,time,record,
          {
            :use_record_host => @use_record_host,
            :add_msec_time => @add_msec_time
          }
        )

        make_json(gelfentry,{})
      end

    end
  end
end