Module: Fluent::WorkerModule

Defined in:
lib/fluent/supervisor.rb

Instance Method Summary collapse

Instance Method Details

#after_startObject



197
198
199
# File 'lib/fluent/supervisor.rb', line 197

def after_start
  config[:worker_pid] = @pm.pid
end

#spawn(process_manager) ⇒ Object



192
193
194
195
# File 'lib/fluent/supervisor.rb', line 192

def spawn(process_manager)
  main_cmd = config[:main_cmd]
  @pm = process_manager.spawn(main_cmd)
end