Sha256: 9bc0341995242a9df0d7a4a92263f841fc284f4bb8784c98e0f910162e21467a
Contents?: true
Size: 1.31 KB
Versions: 7
Compression:
Stored size: 1.31 KB
Contents
require 'net_http_unix'
require 'ostruct'
#
# This class will handle the sending of log messages to unix domain socket
#
module Stackify
class UnixSocketSender < AgentBaseSender
# send_request() This function will send http request via unix domain socket
# @msgs {Object} log group message
# return {Object} Return an object {status, message}
def send_request log_group
begin
client = NetX::HTTPUnix.new('unix://' + Stackify.configuration.unix_socket_path)
req = Net::HTTP::Post.new(Stackify.configuration.agent_log_url)
req.set_content_type('application/json')
req.body = log_group
response = client.request(req)
Stackify.internal_log :debug, "[UnixSocketSender] status_code = #{response.code}"
if response.code.to_i == 200
Stackify.internal_log :debug, "[UnixSocketSender]: Successfully send message via unix domain socket."
return OpenStruct.new({status: 200, msg: 'OK'})
else
Stackify.internal_log :debug, "[UnixSocketSender] Sending failed."
return OpenStruct.new({status: 500, msg: 'Not OK'})
end
rescue => exception
Stackify.log_internal_error "[UnixSocketSender] send_logs() Error: #{exception}"
return OpenStruct.new({status: 500, msg: exception})
end
end
end
end
Version data entries
7 entries across 7 versions & 1 rubygems