class

Kiq::Client

Constructors

new(config : Config = Kiq.default_configuration)

arg_of(msg : Msg, key : String) : Arg

enqueue(klass : String, *args : Arg) : String | Nil

Resque-compatible helpers (1:1 with Sidekiq::Client singleton).

enqueue_to(queue : String, klass : String, *args : Arg) : String | Nil

from_any(v : JSON::Any) : Arg

push(item : Msg) : String | Nil

push_bulk(items : Msg) : Array(String | Nil)

to_any(v : Arg) : JSON::Any

atomic_push(payloads : Array(Msg)) : Nil

config

normalize_item(item : Msg) : Msg

push(item : Msg) : String | Nil

The main method used to push a job to Redis. Returns the jid, or nil if a client middleware stopped the push.

push_bulk(items : Msg) : Array(String | Nil)

Push a large number of jobs in one round trip. items["args"] is an Array of Arrays; every job gets its own jid.

raw_push(payloads : Array(Msg)) : Nil

verify_json(item : Msg) : Nil