class LogStash::Outputs::SumoLogic

Now you can use logstash to deliver logs to Sumo Logic

Create a HTTP Source in your Sumo Logic account and you can now use logstash to parse your log and send your logs to your account at Sumo Logic.

Attributes

stats[R]

Public Instance Methods

close() click to toggle source
# File lib/logstash/outputs/sumologic.rb, line 153
def close
  @monitor.stop()
  @piler.stop()
  @sender.stop()
  client.close()
end
multi_receive(events) click to toggle source
# File lib/logstash/outputs/sumologic.rb, line 137
def multi_receive(events)
  Array(events).map { |event| receive(event) }
end
receive(event) click to toggle source
# File lib/logstash/outputs/sumologic.rb, line 141
def receive(event)
  begin
    @piler.input(event)
  rescue Exception => exception
    log_err("error when processing event",
      :event => event,
      :message => exception.message,
      :class => exception.class.name,
      :backtrace => exception.backtrace)
  end
end
register() click to toggle source
# File lib/logstash/outputs/sumologic.rb, line 121
def register
  set_logger(@logger)
  @stats = Statistics.new
  @queue = MessageQueue.new(@stats, config)
  @piler = Piler.new(@queue, @stats, config)
  @monitor = Monitor.new(@queue, @stats, config)
  @sender = Sender.new(client, @queue, @stats, config)
  if @sender.connect()
    @sender.start()
    @piler.start()
    @monitor.start()
  else
    throw "connection failed, please check the url and retry"
  end
end