class Sidekiq::Processor

Overview

The Processor is a standalone fiber which:

  1. fetches a job from Redis
  2. executes the job a. instantiate the Worker b. run the middleware chain c. call #perform

A Processor can exit due to shutdown (processor_stopped) or due to an error during job execution (processor_died)

If an error occurs in the job execution, the Processor calls the Manager to create a new one to replace itself and exits.

Included Modules

Defined in:

sidekiq/server/processor.cr

Constructors

Class Method Summary

Instance Method Summary

Instance methods inherited from module Sidekiq::Util

fire_event(event, reverse = false) fire_event, safe_routine(ctx, name, &block) safe_routine, watchdog(ctx, last_words, &) watchdog

Instance methods inherited from module Sidekiq::ExceptionHandler

handle_exception(ctx : Sidekiq::Context, ex : Exception, ctx_hash : Hash(String, JSON::Any) | Nil = nil) handle_exception

Constructor Detail

def self.new(mgr : Sidekiq::Server) #

[View source]

Class Method Detail

def self.fetch_counts #

[View source]
def self.reset_counts(p, f) #

[View source]
def self.worker_state #

[View source]

Instance Method Detail

def identity : String #

[View source]
def job : Job | Nil #

[View source]
def process_one #

[View source]
def start #

[View source]
def stats(job, &) #

[View source]
def terminate #

[View source]
def work : Sidekiq::UnitOfWork | Nil #

[View source]