class

Kiq::Launcher

Constants

HEARTBEAT_INTERVAL = 5

HEARTBEAT_TTL = 60

new(config : Config, queues : Array(String) | Nil = nil, concurrency : Int32 | Nil = nil, strict : Bool | Nil = nil)

beat

cleanup_dead_processes

clear_heartbeat

config

flush_stats

identity

info_payload

poller

process_signals

The Web UI pushes TSTP/TERM to <identity>-signals (1:1 with sidekiq's Process#quiet!/stop!).

processors

quiet

register_process

run

stop

Shut down, waiting for processors to exit (they leave BRPOP within one 2s timeout), then flush stats and clear the heartbeat.

stopping?

write_heartbeat