Class: Fluent::GroongaInput::Repeater

Inherits:

Coolio::TCPSocket

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

show all

Defined in:

lib/fluent/plugin/in_groonga.rb,
lib/fluent/plugin/in_groonga.rb more...

Instance Method Summary (collapse)

• - (Repeater) initialize(socket, handler) constructor

  A new instance of Repeater.

• - (Object) on_close
• - (Object) on_read(data)

64
65
66
67

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

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

73
74
75

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

def on_close
  @handler.close
end

69
70
71

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

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