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