fluent input plugin sample

fluent.conf

<source>
  type xxxx
  host 192.168.x.x
  port 1999
</source>

in_sample.rb

module Fluent
  class XXXXInput < Input
    # pluginの登録
    Fluent::Plugin.register_input('xxxx', self)

    def initialize
      super
      # 初期化処理    
    end

    def configure(conf)
      super
      # 設定ファイルの情報をconfから取得してpluginにセットする

      @host = conf.has_key?('host') ? conf['host'] : 'localhost'
      @port = conf.has_key?('port') ? conf['port'] : 9999
    end

    def start
      super
      # fluent起動後のデータ取得処理。
      .....

      # tag, time, recodeを取得してbufferへ渡す
      Engine.emit(@tag, Fluent::Event.new(time, record))
    end

    def shutdown
      super
      # リソースの解放などの終了処理
    end
  end
end