class ProtoHackers::JobCentre::Manager

Defined in:

9_job_centre.cr

Instance Method Summary

Instance Method Detail

def abort_job(worker_id : String, job_id : UInt64) : Bool #

[View source]
def add_job(queue : String, priority : Int32, payload : Hash(String, String)) : UInt64 #

[View source]
def delete_job(job_id : UInt64) : Bool #

[View source]
def get_job?(worker_id : String, queues : Array(String)) : Job | Nil #

[View source]
def id : UInt64 #

[View source]
def id=(id : UInt64) #

[View source]
def in_progress : Hash(String, Array(Job)) #

[View source]
def in_progress=(in_progress : Hash(String, Array(Job))) #

[View source]
def on_disconnect(worker_id : String) #

[View source]
def queues : Hash(String, Array(Job)) #

[View source]
def queues=(queues : Hash(String, Array(Job))) #

[View source]