Class: Fluent::Plugin::GroongaInput::Repeater

Inherits:

Coolio::TCPSocket

• Object
• Coolio::TCPSocket
• Fluent::Plugin::GroongaInput::Repeater

Defined in:

lib/fluent/plugin/in_groonga.rb

Instance Method Summary

• #initialize(socket, handler) ⇒ Repeater constructor

  A new instance of Repeater.

• #on_close ⇒ Object
• #on_read(data) ⇒ Object

Constructor Details

#initialize(socket, handler) ⇒ Repeater

Returns a new instance of Repeater.

# File 'lib/fluent/plugin/in_groonga.rb', line 98

def initialize(socket, handler)
  super(socket)
  @handler = handler
end

Instance Method Details

#on_close ⇒ Object

# File 'lib/fluent/plugin/in_groonga.rb', line 107

def on_close
  @handler.close
end

#on_read(data) ⇒ Object

# File 'lib/fluent/plugin/in_groonga.rb', line 103

def on_read(data)
  @handler.write_back(data)
end