abstract class Mosquito::Backend

• Mosquito::Backend
• Reference
• Object

Direct Known Subclasses

• Mosquito::RedisBackend
• Mosquito::TestBackend

Defined in:

mosquito/backend.cr

Constant Summary

KEY_PREFIX = {"mosquito"}

QUEUES = ["waiting", "scheduled", "pending", "dead"] of ::String

Constructors

• .new(name : String | Symbol)

Class Method Summary

• .build_key(*parts)
• .named(name)
• .search_queues

Instance Method Summary

• #build_key(*parts)
• #dead_q
• #delete(key : String, in ttl = 0) : Nil
• #dequeue : JobRun | Nil
• #deschedule : Array(JobRun)
• #dump_dead_q : Array(String)
• #dump_pending_q : Array(String)
• #dump_scheduled_q : Array(String)
• #dump_waiting_q : Array(String)
• #enqueue(job_run : JobRun) : JobRun

  from queue.cr

• #expires_in(key : String) : Int64
• #finish(job_run : JobRun)
• #flush : Nil
• #pending_q
• #retrieve(key : String) : Hash(String, String)
• #schedule(job_run : JobRun, at scheduled_time : Time) : JobRun
• #scheduled_job_run_time(job_run : JobRun) : String | Nil
• #scheduled_q
• #size(include_dead : Bool = true) : Int64
• #store(key : String, value : Hash(String, String)) : Nil
• #terminate(job_run : JobRun)
• #waiting_q

Constructor Detail

Class Method Detail

Instance Method Detail