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