class OpenTelemetry::Exporter::Jaeger::Transport

A Thrift-compatible UDP transport.

Public Class Methods

new(host, port) click to toggle source
# File lib/opentelemetry/exporter/jaeger/transport.rb, line 12
def initialize(host, port)
  @socket = UDPSocket.new
  @socket.connect(host, port)
  @buffer = ::Thrift::MemoryBufferTransport.new
end

Public Instance Methods

close() click to toggle source
# File lib/opentelemetry/exporter/jaeger/transport.rb, line 33
def close; end
flush() click to toggle source
# File lib/opentelemetry/exporter/jaeger/transport.rb, line 22
def flush
  @socket.send(@buffer.read(@buffer.available), 0)
  @socket.flush
rescue Errno::ECONNREFUSED
  OpenTelemetry.logger.warn('Unable to connect to Jaeger Agent')
rescue StandardError => e
  OpenTelemetry.logger.warn("Unable to send spans: #{e.message}")
end
open() click to toggle source
# File lib/opentelemetry/exporter/jaeger/transport.rb, line 31
def open; end
write(string) click to toggle source
# File lib/opentelemetry/exporter/jaeger/transport.rb, line 18
def write(string)
  @buffer.write(string)
end