Class: Fluent::PluginHelper::Server::UDPCallbackSocket
Constant Summary
collapse
- ENABLED_EVENTS =
[]
Instance Method Summary
collapse
#close, #close_after_write_complete, #data, #on, #send
Constructor Details
#initialize(sock, peeraddr, **kwargs) ⇒ UDPCallbackSocket
Returns a new instance of UDPCallbackSocket.
476
477
478
479
|
# File 'lib/fluent/plugin_helper/server.rb', line 476
def initialize(sock, peeraddr, **kwargs)
super("udp", sock, ENABLED_EVENTS, **kwargs)
@peeraddr = peeraddr
end
|
Instance Method Details
#remote_addr ⇒ Object
481
482
483
|
# File 'lib/fluent/plugin_helper/server.rb', line 481
def remote_addr
@peeraddr[3]
end
|
#remote_host ⇒ Object
485
486
487
|
# File 'lib/fluent/plugin_helper/server.rb', line 485
def remote_host
@peeraddr[2]
end
|
#remote_port ⇒ Object
489
490
491
|
# File 'lib/fluent/plugin_helper/server.rb', line 489
def remote_port
@peeraddr[1]
end
|
#write(data) ⇒ Object
493
494
495
|
# File 'lib/fluent/plugin_helper/server.rb', line 493
def write(data)
@sock.send(data, 0, @peeraddr[3], @peeraddr[1])
end
|