pub fn init() -> Result<(), Error>Expand description
Initializes the job queue system by:
- Setting up a logger via
env_logger::init. - Attempting to acquire a database connection using
DB::get_conn. - Running any pending database migrations using
MIGRATIONS. - Starting the autoscaling worker system with
start_autoscaling_worker.
§Returns
Ok(())if all steps succeed.Err(diesel::result::Error)if a connection or migration step fails.
§Examples
ⓘ
fn main() {
// Initialize everything
if let Err(e) = zirv_queue::init() {
eprintln!("Failed to initialize queue system: {:?}", e);
std::process::exit(1);
}
// The worker threads are now running in the background.
// ...
}