class

ProtoHackers::JobCentre::Manager

Inherits Reference < Object

Instance methods

abort_job(worker_id : String, job_id : UInt64) : Bool
Source
add_job(queue : String, priority : Int32, payload : Hash(String, String)) : UInt64
Source
delete_job(job_id : UInt64) : Bool
Source
get_job?(worker_id : String, queues : Array(String)) : Job | Nil
Source
id=(id : UInt64)
Source
in_progress
Source
in_progress=(in_progress : Hash(String, Array(Job)))
Source
on_disconnect(worker_id : String)
Source
queues
Source
queues=(queues : Hash(String, Array(Job)))
Source