runledger-runtime 0.1.1

Async worker, scheduler, and reaper runtime for the Runledger job system
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29

//! 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::JobRegistry`] stores the concrete handlers a worker may claim
//! - [`worker::run_worker_loop`] claims jobs, executes handlers, and records
//!   progress/results
//! - [`scheduler::run_scheduler_loop`] materializes due cron schedules into
//!   runnable jobs
//! - [`reaper::run_reaper_loop`] recovers jobs whose worker lease expired
//! - [`config::JobsConfig`] centralizes 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.

pub mod config;
pub mod error;
pub mod reaper;
pub mod registry;
pub mod scheduler;
pub mod worker;

pub use error::{Error, ReaperError, Result, RuntimeError, SchedulerError, WorkerError};

#[cfg(test)]
#[path = "../test_support.rs"]
pub(crate) mod test_support;