class LogStash::Outputs::Circonus
Public Instance Methods
receive(event)
click to toggle source
# File lib/logstash/outputs/circonus.rb, line 53 def receive(event) # TODO (lusis) # batch and flush annotation_event = Hash[*@annotation.collect{|k,v| [event.sprintf(k),event.sprintf(v)]}.flatten] @logger.warn("Annotation event", :data => annotation_event) annotation_array = [] annotation_path = "#{@uri.path}annotation" @logger.warn("Annotation path", :data => annotation_path) request = Net::HTTP::Post.new(annotation_path) annotation_event['start'] = event.timestamp.to_i unless annotation_event['start'] annotation_event['stop'] = event.timestamp.to_i unless annotation_event['stop'] @logger.warn("Annotation event", :data => annotation_event) annotation_array << annotation_event begin request.set_form_data(:annotations => LogStash::Json.dump(annotation_array)) @logger.warn(annotation_event) request.add_field("X-Circonus-Auth-Token", "#{@api_token}") request.add_field("X-Circonus-App-Name", "#{event.sprintf(@app_name)}") response = @client.request(request) @logger.warn("Circonus convo", :request => request.inspect, :response => response.inspect) raise unless response.code == '200' rescue Exception => e @logger.warn("Unhandled exception", :request => request.inspect, :response => response.inspect, :exception => e.inspect) end end
register()
click to toggle source
# File lib/logstash/outputs/circonus.rb, line 41 def register require "net/https" require "uri" @url = "https://circonus.com/api/json/" @uri = URI.parse(@url) @client = Net::HTTP.new(@uri.host, @uri.port) @client.use_ssl = true @client.verify_mode = OpenSSL::SSL::VERIFY_NONE end