Sha256: 785ce65c6aafcf007dfcca80ddbe12c2ce65dbe9006ab2fc3df50ddf4800c387
Contents?: true
Size: 1.06 KB
Versions: 60
Compression:
Stored size: 1.06 KB
Contents
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
Version data entries
60 entries across 60 versions & 1 rubygems