class

Kiq::JobSet

Inherits Reference < Object

Web-UI extensions to the existing JobSet: pagination/fetch/scan with sidekiq's semantics (api.rb JobSet).

Constructors

new(name : String)
Source

Instance methods

clear
Source
each
Source
entries(count : Int32 = 50) : Array(Msg)

Payloads in score order (first count entries).

Source
fetch(score : Float64, jid : String) : Array(SortedEntry)

Find an entry by score + jid (sidekiq JobSet#fetch).

Source
kill_all
Source
name
Source
page(page_str : String | Nil, count : Int32, reverse : Bool = false) : Tuple(Int32, Int64, Array(SortedEntry))

Page through the set: [current_page, total_size, entries].

Source
retry_all

Retry all entries (RetrySet/DeadSet) — same decrement as #retry.

Source
scan(substr : String) : Array(SortedEntry)

Scan by substring (sidekiq JobSet#scan used by filtering).

Source
size
Source