init

Function init 

Source
pub fn init() -> Result<(), Error>
Expand description

Initializes the job queue system by:

  1. Setting up a logger via env_logger::init.
  2. Attempting to acquire a database connection using DB::get_conn.
  3. Running any pending database migrations using MIGRATIONS.
  4. 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.
    // ...
}