class Sidekiq::Scheduled::Poller

Overview

The Poller checks Redis every N seconds for jobs in the retry or scheduled set have passed their timestamp and should be enqueued. If so, it just pops the job back onto its original queue so the workers can pick it up like any other job.

Included Modules

Defined in:

sidekiq/server/scheduled.cr

Constant Summary

INITIAL_WAIT = 10

Constructors

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 #

[View source]

Instance Method Detail

def context : Sidekiq::Context #

[View source]
def enqueue(ctx : Sidekiq::Context) #

[View source]
def start(ctx) #

[View source]
def terminate #

[View source]