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