module JoobQ
Defined in:
joobq.crjoobq/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
- .[](name : String)
- .add(job)
- .config : Configure
- .configure(&)
- .error_monitor : ErrorMonitor
- .find_config_file : String | Nil
- .forge
-
.initialize_config : Nil
Initialize configuration with auto-discovery
-
.initialize_config_with(loading_method : Symbol, *args, **kwargs) : Nil
Initialize configuration with specific loading method
-
.initialize_config_with(loading_method : Symbol, *args, **kwargs, &) : Nil
Initialize configuration with hybrid loading method (requires block)
- .load_auto : Configure
- .load_from_cli_args(args : Array(String)) : Configure
- .load_from_file(path : String) : Configure
- .load_from_string(yaml_content : String, source_path : String | Nil = nil) : Configure
-
.load_from_yaml(path : String | Nil = nil, env : String | Nil = nil) : Configure
Configuration loading methods
- .load_from_yaml_sources(sources : Array(String)) : Configure
- .load_hybrid(yaml_path : String | Nil = nil, &)
- .load_with_env_overrides(base_path : String | Nil = nil, env : String | Nil = nil) : Configure
- .queues
- .reset
-
.reset_config : Nil
Reset configuration (useful for testing)
- .scheduler
-
.set_config(config : Configure) : Nil
Set a custom configuration
- .store
Class Method Detail
def self.initialize_config_with(loading_method : Symbol, *args, **kwargs) : Nil
#
Initialize configuration with specific loading method
def self.initialize_config_with(loading_method : Symbol, *args, **kwargs, &) : Nil
#
Initialize configuration with hybrid loading method (requires block)
Configuration loading methods