module Fluent::WorkerModule

Public Instance Methods

after_start() click to toggle source
# File lib/fluent/supervisor.rb, line 197
def after_start
  config[:worker_pid] = @pm.pid
end
spawn(process_manager) click to toggle source
# File lib/fluent/supervisor.rb, line 192
def spawn(process_manager)
  main_cmd = config[:main_cmd]
  @pm = process_manager.spawn(main_cmd)
end