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