ruboty-fluent-logger.gemspec

lib = File.expand_path('../lib', __FILE__)
$LOAD_PATH.unshift(lib) unless $LOAD_PATH.include?(lib)

Gem::Specification.new do |spec|
  spec.name          = "ruboty-fluent-logger"
  spec.version       = "1.0.0"
  spec.authors       = ["chiastolite"]
  spec.email         = ["[email protected]"]
  spec.summary       = "foward all messages to fluentd"
  spec.license       = "MIT"

  spec.files         = `git ls-files -z`.split("\x0")
  spec.require_paths = ["."]

  spec.add_dependency 'fluent-logger'
end

ruboty-fluent-logger.rb

require 'fluent-logger'

module Ruboty
  module Handlers
    class FluentLogger < Base
      env :FLUENTD_HOST, 'Fluentd Host'
      env :FLUENTD_PORT, 'Fluentd Port'
      env :LOGGER_TAG,   'Fluentd Tag'
      ::Fluent::Logger::FluentLogger.open(nil, host: ENV['FLUENTD_HOST'], port: ENV['FLUENTD_PORT'])

      on(
        /.*/,
        name: 'capture',
        description: 'capture all messages.',
        all: true
      )

      def capture(message)
        ::Fluent::Logger.post(ENV['LOGGER_TAG'], {from_name: message.from_name, body: message.body})
      end
    end
  end
end