Class: Fluent::GroongaInput

Inherits:
Input
  • Object
show all
Defined in:
lib/fluent/plugin/in_groonga.rb

Defined Under Namespace

Classes: BaseInput, GQTPInput, HTTPInput, Repeater

Instance Method Summary collapse

Constructor Details

#initialize ⇒ GroongaInput

Returns a new instance of GroongaInput.



33
34
35
 
# File 'lib/fluent/plugin/in_groonga.rb', line 33

def initialize
  super
end

Instance Method Details

#configure(conf) ⇒ Object 



46
47
48
49
50
51
52
53
54
55
 
# File 'lib/fluent/plugin/in_groonga.rb', line 46

def configure(conf)
  super
  case @protocol
  when :http
    @input = HTTPInput.new(self)
  when :gqtp
    @input = GQTPInput.new(self)
  end
  @input.configure(conf)
end

#shutdown ⇒ Object 



61
62
63
 
# File 'lib/fluent/plugin/in_groonga.rb', line 61

def shutdown
  @input.shutdown
end

#start ⇒ Object 



57
58
59
 
# File 'lib/fluent/plugin/in_groonga.rb', line 57

def start
  @input.start
end