class Observed::Plugins::Fluentd

Public Instance Methods

report(tag, time, data) click to toggle source
# File lib/observed/fluentd.rb, line 19
def report(tag, time, data)
  fluent_logger.post(self.tag, transform.call(data))
end

Private Instance Methods

fluent_logger() click to toggle source
# File lib/observed/fluentd.rb, line 25
def fluent_logger
  @fluent_logger ||= Fluent::Logger::FluentLogger.new(nil, host: host, port: port)
end