shigoto_queue (shigoto v1.9.10)

View Source

Per-queue gen_server that polls for available jobs and dispatches them to the executor supervisor. Supports graceful shutdown, queue weights, and pause/resume.

Summary

Functions

Pause a queue — stops claiming new jobs but lets in-flight jobs finish.

Resume a paused queue.

Functions

pause(Pid)

-spec pause(pid()) -> ok.

Pause a queue — stops claiming new jobs but lets in-flight jobs finish.

resume(Pid)

-spec resume(pid()) -> ok.

Resume a paused queue.