Class: Wurk::RetrySet

Inherits:

JobSet

• Object
• SortedSet
• JobSet
• Wurk::RetrySet

Defined in:

lib/wurk/retry_set.rb

Overview

ZSET keyed by next-retry timestamp (score = epoch seconds). Wire-compat with Sidekiq — the ‘retry` key, score format, and JSON payload all match.

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

Constant Summary

Constants inherited from SortedSet

SortedSet::PAGE_SIZE

Instance Attribute Summary

Attributes inherited from SortedSet

#name

Instance Method Summary

• #initialize(name = 'retry') ⇒ RetrySet constructor

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

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 = 'retry') ⇒ RetrySet

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

# File 'lib/wurk/retry_set.rb', line 13

def initialize(name = 'retry')
  super
end