class Fluent::Plugin::BaritoTransport
Attributes
logger[RW]
produce_url[RW]
Public Class Methods
new(produce_url, logger)
click to toggle source
# File lib/fluent/plugin/barito_transport.rb, line 7 def initialize(produce_url, logger) @produce_url = produce_url @logger = logger end
Public Instance Methods
send(timber, header)
click to toggle source
# File lib/fluent/plugin/barito_transport.rb, line 12 def send(timber, header) begin RestClient.post @produce_url, timber.to_json, header rescue Exception => e @logger.error [e.message, e.response, header].join(', ') end end