module

Kiq

Union of all registered job classes: the static type flowing through server middleware and perform dispatch.

Constants

Compile-time registry of all classes that include Kiq::Job.

NAME = "Kiq"
OPTIONS = {"ActiveJob::KiqAdapter::JobWrapper" => {queue: "default", retry: false}} of Nil => Nil

Compile-time per-class kiq_options (class name => NamedTupleLiteral).

SERVER_BLOCKS = [] of Proc(Config, Nil)

Deferred configure_server blocks (run by the Launcher, exactly what the sidekiq CLI does at boot; outside a server process the block is stored, not executed — same standalone semantics as sidekiq 8).

VERSION = "8.1.7"
Worker = Job

Sidekiq::Worker compatibility alias (sidekiq 6.3+).

Class methods

build_job(class_name : String, msg : Msg) : AnyJob

Build a job instance by class name (compile-time registry).

Source
configure
Source
configure_client
Source
configure_server
Source
default_configuration
Source
dispatch_perform(job : AnyJob, args : Array(Arg)) : Nil

Dispatch perform with runtime args into the job's own arity, generated per job class (same technique as active_job.cr: splat into a def requires static arity, so valid call arities are derived from the job's own perform signature at compile time).

Source
dump_json(msg : Msg) : String
Source
handle_exception(ex : Exception, ctx : Msg | Nil = nil) : Nil
Source
job_options(class_name : String) : Msg

Job-class options lookup through the compile-time registry; unknown classes get the global defaults (1:1 with JobUtil#normalized_hash).

Source
load_json(string : String) : Msg
Source
new_batch_bid
Source
new_jid
Source
now_ms
Source
perform_inline(class_name : String, args : Array(Arg)) : Bool

Execute a job inline through both middleware chains without Redis (1:1 with Sidekiq::Job::Setter#perform_inline).

Source
process_job_inline(msg : Msg) : Bool
Source
redis
Source
server=(server : Bool)
Source
server?
Source
testing!(mode : String, &block : -> _)
Source
write_msg(io : JSON::Builder, msg : Msg) : Nil
Source

Nested types