class Sidekiq::BasicFetch
- Sidekiq::BasicFetch
- Sidekiq::Fetch
- Reference
- Object
Defined in:
sidekiq/server/fetch.crConstant Summary
-
TIMEOUT =
2 -
We want the fetch operation to timeout every few seconds so we can check if the process is shutting down.
Constructors
Instance Method Summary
- #bulk_requeue(ctx, inprogress : Array(Sidekiq::UnitOfWork)) : Int32
- #queues : Array(String)
-
#queues_cmd
Creating the Redis#brpop command takes into account any configured queue weights.
- #retrieve_work(ctx) : Sidekiq::UnitOfWork | Nil
- #strict!
Instance methods inherited from class Sidekiq::Fetch
bulk_requeue(ctx : Sidekiq::Context, jobs : Array(UnitOfWork)) : Int32
bulk_requeue,
retrieve_work(ctx : Sidekiq::Context) : UnitOfWork | Nil
retrieve_work
Constructor Detail
Instance Method Detail
def queues_cmd
#
Creating the Redis#brpop command takes into account any configured queue weights. By default Redis#brpop returns data from the first queue that has pending elements. We recreate the queue command each time we invoke Redis#brpop to honor weights and avoid queue starvation.