class Mosquito::RedisBackend

• Mosquito::RedisBackend
• Mosquito::Backend
• Reference
• Object

Extended Modules

• Mosquito::Backend::ClassMethods

Defined in:

Constant Summary

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

Class Method Summary

• .delete(key : String, in ttl = 0) : Nil
• .expires_in(key : String) : Int64
• .flush : Nil

  is this even a good idea?

• .get(key : String, field : String) : String | Nil
• .increment(key : String, field : String, by value : Int32) : Int64
• .increment(key : String, field : String) : Int64
• .list_queues : Array(String)
• .redis
• .retrieve(key : String) : Hash(String, String)
• .set(key : String, field : String, value : String) : String
• .store(key : String, value : Hash(String, String)) : Nil

Instance Method Summary

• #dead_q
• #dequeue : Task | Nil
• #deschedule : Array(Task)
• #enqueue(task : Task) : Task

  from queue.cr

• #finish(task : Task)
• #flush : Nil
• #pending_q
• #redis
• #schedule(task : Task, at scheduled_time : Time) : Task
• #scheduled_q
• #size(include_dead = true) : Int64
• #terminate(task : Task)
• #waiting_q

Class Method Detail

Instance Method Detail