class Jaeger::Client::UdpSender::Transport
Constants
- FLAGS
Public Class Methods
new(host, port)
click to toggle source
# File lib/jaeger/client/udp_sender/transport.rb, line 9 def initialize(host, port) @socket = UDPSocket.new @host = host @port = port @buffer = ::Thrift::MemoryBufferTransport.new end
Public Instance Methods
close()
click to toggle source
# File lib/jaeger/client/udp_sender/transport.rb, line 27 def close; end
flush()
click to toggle source
# File lib/jaeger/client/udp_sender/transport.rb, line 20 def flush data = @buffer.read(@buffer.available) send_bytes(data) end
open()
click to toggle source
# File lib/jaeger/client/udp_sender/transport.rb, line 25 def open; end
write(str)
click to toggle source
# File lib/jaeger/client/udp_sender/transport.rb, line 16 def write(str) @buffer.write(str) end
Private Instance Methods
send_bytes(bytes)
click to toggle source
# File lib/jaeger/client/udp_sender/transport.rb, line 31 def send_bytes(bytes) @socket.send(bytes, FLAGS, @host, @port) @socket.flush rescue Errno::ECONNREFUSED warn 'Unable to connect to Jaeger Agent' rescue StandardError => e warn "Unable to send spans: #{e.message}" end