module JoobQ

Defined in:

joobq.cr
joobq/api_server.cr
joobq/api_validation.cr
joobq/config_mapper.cr
joobq/config_validator.cr
joobq/configure.cr
joobq/cron_job_scheduler.cr
joobq/dead_letter_manager.cr
joobq/delayed_job_scheduler.cr
joobq/error_context.cr
joobq/error_monitor.cr
joobq/job.cr
joobq/job_schema_registry.cr
joobq/middleware.cr
joobq/middlewares/retry.cr
joobq/middlewares/throttle.cr
joobq/middlewares/timeout.cr
joobq/queue.cr
joobq/queue_factory.cr
joobq/recurring_job_scheduler.cr
joobq/redis_health.cr
joobq/redis_metrics.cr
joobq/redis_pipeline.cr
joobq/redis_store.cr
joobq/scheduler.cr
joobq/store.cr
joobq/worker.cr
joobq/worker_manager.cr
joobq/yaml_config_loader.cr

Class Method Summary

Class Method Detail

def self.[](name : String) #

[View source]
def self.add(job) #

[View source]
def self.config : Configure #

[View source]
def self.configure(&) #

[View source]
def self.error_monitor : ErrorMonitor #

[View source]
def self.find_config_file : String | Nil #

[View source]
def self.forge #

[View source]
def self.initialize_config : Nil #

Initialize configuration with auto-discovery


[View source]
def self.initialize_config_with(loading_method : Symbol, *args, **kwargs) : Nil #

Initialize configuration with specific loading method


[View source]
def self.initialize_config_with(loading_method : Symbol, *args, **kwargs, &) : Nil #

Initialize configuration with hybrid loading method (requires block)


[View source]
def self.load_auto : Configure #

[View source]
def self.load_from_cli_args(args : Array(String)) : Configure #

[View source]
def self.load_from_file(path : String) : Configure #

[View source]
def self.load_from_string(yaml_content : String, source_path : String | Nil = nil) : Configure #

[View source]
def self.load_from_yaml(path : String | Nil = nil, env : String | Nil = nil) : Configure #

Configuration loading methods


[View source]
def self.load_from_yaml_sources(sources : Array(String)) : Configure #

[View source]
def self.load_hybrid(yaml_path : String | Nil = nil, &) #

[View source]
def self.load_with_env_overrides(base_path : String | Nil = nil, env : String | Nil = nil) : Configure #

[View source]
def self.queues #

[View source]
def self.reset #

[View source]
def self.reset_config : Nil #

Reset configuration (useful for testing)


[View source]
def self.scheduler #

[View source]
def self.set_config(config : Configure) : Nil #

Set a custom configuration


[View source]
def self.store #

[View source]