Module: Fluent::WorkerModule
- Defined in:
- lib/fluent/supervisor.rb
Instance Method Summary collapse
Instance Method Details
#after_start ⇒ Object
374 375 376 |
# File 'lib/fluent/supervisor.rb', line 374 def after_start (config[:worker_pid] ||= {})[@worker_id] = @pm.pid end |
#spawn(process_manager) ⇒ Object
366 367 368 369 370 371 372 |
# File 'lib/fluent/supervisor.rb', line 366 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 |