Class: Wurk::ScheduledSet

Inherits:
JobSet show all
Defined in:
lib/wurk/scheduled_set.rb

Overview

ZSET of jobs scheduled to run at a future time (score = epoch seconds). The scheduled-poller pops eligible members and re-enqueues via the client. Wire-compat with Sidekiq’s ‘schedule` key.

Spec: docs/target/sidekiq-free.md §19.5.

Constant Summary

Constants inherited from SortedSet

Wurk::SortedSet::PAGE_SIZE

Instance Attribute Summary

Attributes inherited from SortedSet

#name

Instance Method Summary collapse

Methods inherited from JobSet

#delete_by_jid, #delete_by_value, #each, #fetch, #find_job, #kill_all, #pop_each, #remove_job, #retry_all, #schedule

Methods inherited from SortedSet

#as_json, #clear, #scan, #size

Methods included from API::Fast::SortedSetExt

#scan

Constructor Details

#initialize(name = 'schedule') ⇒ ScheduledSet

Optional ‘name` allows tests to operate on a namespaced ZSET; production callers always use the default `’schedule’‘ key (wire-compat with Sidekiq).



14
15
16
 
# File 'lib/wurk/scheduled_set.rb', line 14

def initialize(name = 'schedule')
  super
end