class LogStash::Outputs::Stride
An example output that does nothing.
Public Instance Methods
post_message(access_token,cloud_id,conversation_id,host,type,message)
click to toggle source
# File lib/logstash/outputs/stride.rb, line 37 def post_message(access_token,cloud_id,conversation_id,host,type,message) message = %Q|#{type} : #{message}| if type message = %Q|#{host} : #{message}| if host puts "Type : #{type}, Host : #{host}" uri = URI.parse("https://api.atlassian.com/site/#{cloud_id}/conversation/#{conversation_id}/message") request = Net::HTTP::Post.new(uri) request.content_type = "application/json" request["Authorization"] = "Bearer #{access_token}" request.body = '{"version":1,"type":"doc","content":[{"type":"paragraph","content":[{"type":"text","text":"'+message+'"}]}]}' req_options = { use_ssl: uri.scheme == "https", } response = Net::HTTP.start(uri.hostname, uri.port, req_options) do |http| http.request(request) end end
receive(event)
click to toggle source
# File lib/logstash/outputs/stride.rb, line 23 def receive(event) access_token = event.sprintf(@access_token) cloud_id = event.sprintf(@cloud_id) conversation_id = event.sprintf(@conversation_id) host = event.sprintf(@host) type = event.sprintf(@type) message = event.sprintf(@message) post_message(access_token,cloud_id,conversation_id,host,type,message) rescue Exception => e puts e.message end
register()
click to toggle source
# File lib/logstash/outputs/stride.rb, line 19 def register end