module Fluent::WorkerModule
Public Instance Methods
after_start()
click to toggle source
# File lib/fluent/supervisor.rb, line 230 def after_start (config[:worker_pid] ||= {})[@worker_id] = @pm.pid end
spawn(process_manager)
click to toggle source
# File lib/fluent/supervisor.rb, line 222 def spawn(process_manager) main_cmd = config[:main_cmd] env = { 'SERVERENGINE_WORKER_ID' => @worker_id.to_i.to_s, } @pm = process_manager.spawn(env, *main_cmd) end