1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51
|
# frozen_string_literal: true
require 'thread'
require 'socket'
module Aws
module ClientSideMonitoring
# @api private
class Publisher
attr_reader :agent_port
attr_reader :agent_host
def initialize(opts = {})
@agent_host = opts[:agent_host] || "127.0.0.1"
@agent_port = opts[:agent_port]
@mutex = Mutex.new
end
def agent_port=(value)
@mutex.synchronize do
@agent_port = value
end
end
def agent_host=(value)
@mutex.synchronize do
@agent_host = value
end
end
def publish(request_metrics)
send_datagram(request_metrics.api_call.to_json)
request_metrics.api_call_attempts.each do |attempt|
send_datagram(attempt.to_json)
end
end
def send_datagram(msg)
if @agent_port
socket = UDPSocket.new
begin
socket.connect(@agent_host, @agent_port)
socket.send(msg, 0)
rescue Errno::ECONNREFUSED
# Drop on the floor
end
end
end
end
end
end
|