class

Kiq::Batch

Inherits Reference < Object

Completes tracked nodes and triggers the next one (1:1 with Sidekiq::PipelineCallback; node classes resolve through the compile-time registry instead of const_get).

Constants

BID_EXPIRE_TTL = 2592000
CALLBACK_FLAG_TTL = 86400

Constructors

new(existing_bid : String | Nil = nil)
Source

Class methods

current
Source
current_parent_bid
Source
enqueue_callbacks(event : Symbol, bid : String) : Nil
Source
process_failed_job(bid : String, jid : String) : Nil
Source
process_successful_job(bid : String, jid : String) : Nil
Source
push_callbacks(args : Array(Array(JSON::Any)), queue : String) : Nil
Source
to_i(v) : Int64

nil.to_i == 0 semantics for Redis reads

Source
with_current(batch : Batch | Nil, parent_bid : String | Nil, &)
Source
with_redis_lock(lock_key : String, timeout : Int32 = 30, max_wait : Int32 = 60, &) : Nil

Distributed Redis lock (SET NX EX with token-checked release), 1:1.

Source

Instance methods

add_jobs
Source
add_jobs
Source
callback_batch=(callback_batch : String)
Source
callback_queue
Source
callback_queue=(callback_queue : String)
Source
conditional_redis_increment(force : Bool = false) : Nil
Source
created_at
Source
description
Source
description=(description : String)
Source
increment_job_queue(jid : String) : Nil
Source
invalidate_all
Source
on(event : Symbol, callback : Kiq::Batch::Callback::CallbackHandler.class, options : Hash(String, Arg) = {} of String => Arg) : Nil
Source
parent
Source
parent_bid
Source
run
Source
valid?(batch : Batch = self) : Bool
Source

Nested types