Class: Fluent::PluginHelper::Server::TLSCallbackSocket

Inherits:

CallbackSocket

• Object
• CallbackSocket
• Fluent::PluginHelper::Server::TLSCallbackSocket

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) ⇒ TLSCallbackSocket constructor

  A new instance of TLSCallbackSocket.

• #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) ⇒ TLSCallbackSocket

Returns a new instance of TLSCallbackSocket.

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

def initialize(sock)
  super("tls", sock, ENABLED_EVENTS)
  @peeraddr = (@sock.to_io.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 479

def buffer
  @buffer
end

Instance Method Details

#write(data) ⇒ Object

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

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