Class: Droonga::CollectorRunner

Inherits:
Object
  • Object
show all
Includes:
Loggable
Defined in:
lib/droonga/collector_runner.rb

Instance Method Summary collapse

Constructor Details

#initialize(plugins) ⇒ CollectorRunner

Returns a new instance of CollectorRunner.



25
26
27
28
29
 
# File 'lib/droonga/collector_runner.rb', line 25

def initialize(plugins)
  default_plugins = ["basic"]
  plugins += (default_plugins - plugins)
  @collector_classes = Collector.find_sub_classes(plugins)
end

Instance Method Details

#collect(message) ⇒ Object 



34
35
36
37
38
39
40
41
42
43
44
45
 
# File 'lib/droonga/collector_runner.rb', line 34

def collect(message)
  collector_message = CollectorMessage.new(message)
  logger.trace("collect: start",
               :type => collector_message.type)
  collector_class = find_collector_class(message)
  if collector_class.nil?
    raise UnsupportedMessageError.new(:collector, message)
  end
  collector = collector_class.new
  collector.collect(collector_message)
  logger.trace("collector: done")
end

#shutdown ⇒ Object 



31
32
 
# File 'lib/droonga/collector_runner.rb', line 31

def shutdown
end