module Fluent::WorkerModule
Public Instance Methods
after_start()
click to toggle source
# File lib/fluent/supervisor.rb, line 416 def after_start (config[:worker_pid] ||= {})[@worker_id] = @pm.pid end
dump()
click to toggle source
Calls superclass method
# File lib/fluent/supervisor.rb, line 420 def dump super unless @stop end
spawn(process_manager)
click to toggle source
# File lib/fluent/supervisor.rb, line 408 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