Class: Fluent::PluginHelper::Server::TCPCallbackSocket

Inherits:

CallbackSocket

• Object
• CallbackSocket
• Fluent::PluginHelper::Server::TCPCallbackSocket

Defined in:

lib/fluent/plugin_helper/server.rb

Constant Summary

ENABLED_EVENTS =

[:data, :write_complete, :close]

Instance Attribute Summary

• #buffer ⇒ Object

  Returns the value of attribute buffer.

Instance Method Summary

• #initialize(sock) ⇒ TCPCallbackSocket constructor

  A new instance of TCPCallbackSocket.

• #write(data) ⇒ Object

Methods inherited from CallbackSocket

#close, #close_after_write_complete, #data, #on, #remote_addr, #remote_host, #remote_port, #send

Constructor Details

#initialize(sock) ⇒ TCPCallbackSocket

Returns a new instance of TCPCallbackSocket.

# File 'lib/fluent/plugin_helper/server.rb', line 446

def initialize(sock)
  super("tcp", sock, ENABLED_EVENTS)
  @peeraddr = (@sock.peeraddr rescue PEERADDR_FAILED)
  @buffer = ''
end

Instance Attribute Details

#buffer ⇒ Object

Returns the value of attribute buffer.

# File 'lib/fluent/plugin_helper/server.rb', line 444

def buffer
  @buffer
end

Instance Method Details

#write(data) ⇒ Object

# File 'lib/fluent/plugin_helper/server.rb', line 452

def write(data)
  @sock.write(data)
end