Expand description
Async runtime loops for executing Runledger jobs against a persistence backend.
Use this crate to wire the operational pieces around runledger-core
handlers and runledger-postgres storage:
registry::JobRegistrystores the concrete handlers a worker may claimworker::run_worker_loopclaims jobs, executes handlers, and records progress/resultsscheduler::run_scheduler_loopmaterializes due cron schedules into runnable jobsreaper::run_reaper_looprecovers jobs whose worker lease expiredconfig::JobsConfigcentralizes poll, lease, and concurrency settings
A typical service builds a shared PostgreSQL pool, registers handlers in a
registry::JobRegistry, and starts the worker, scheduler, and reaper
loops with coordinated shutdown signals.
Re-exports§
pub use error::Error;pub use error::ReaperError;pub use error::Result;pub use error::RuntimeError;pub use error::SchedulerError;pub use error::WorkerError;