Class: Jaeger::Client::UdpSender::Transport
- Inherits:
-
Object
- Object
- Jaeger::Client::UdpSender::Transport
- Defined in:
- lib/jaeger/client/udp_sender/transport.rb
Constant Summary collapse
- FLAGS =
0
Instance Method Summary collapse
- #close ⇒ Object
- #flush ⇒ Object
-
#initialize(host, port) ⇒ Transport
constructor
A new instance of Transport.
- #open ⇒ Object
- #write(str) ⇒ Object
Constructor Details
#initialize(host, port) ⇒ Transport
Returns a new instance of Transport.
7 8 9 10 11 |
# File 'lib/jaeger/client/udp_sender/transport.rb', line 7 def initialize(host, port) @socket = UDPSocket.new @socket.connect(host, port) @buffer = ::Thrift::MemoryBufferTransport.new end |
Instance Method Details
#close ⇒ Object
23 |
# File 'lib/jaeger/client/udp_sender/transport.rb', line 23 def close; end |
#flush ⇒ Object
17 18 19 20 |
# File 'lib/jaeger/client/udp_sender/transport.rb', line 17 def flush data = @buffer.read(@buffer.available) send_bytes(data) end |
#open ⇒ Object
22 |
# File 'lib/jaeger/client/udp_sender/transport.rb', line 22 def open; end |
#write(str) ⇒ Object
13 14 15 |
# File 'lib/jaeger/client/udp_sender/transport.rb', line 13 def write(str) @buffer.write(str) end |