class Jaeger::UdpSender::Transport
Constants
- FLAGS
Public Class Methods
new(host, port)
click to toggle source
# File lib/jaeger/udp_sender/transport.rb, line 8 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/udp_sender/transport.rb, line 26 def close; end
flush()
click to toggle source
# File lib/jaeger/udp_sender/transport.rb, line 19 def flush data = @buffer.read(@buffer.available) send_bytes(data) end
open()
click to toggle source
# File lib/jaeger/udp_sender/transport.rb, line 24 def open; end
write(str)
click to toggle source
# File lib/jaeger/udp_sender/transport.rb, line 15 def write(str) @buffer.write(str) end
Private Instance Methods
send_bytes(bytes)
click to toggle source
# File lib/jaeger/udp_sender/transport.rb, line 30 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