adrift_core 0.0.11

Adrift a web framework for Rust
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
30
31
32
33
34
35
36

use std::{collections::HashMap, env};

use crate::commands::{Arg, Command};

pub struct QueueWork;

#[async_trait::async_trait]
impl Command for QueueWork {
    fn name(&self) -> &'static str {
        "queue:work"
    }

    fn description(&self) -> &'static str {
        "Start processing jobs on the queue as a daemon"
    }

    fn args(&self) -> Vec<Arg> {
        vec![]
    }

    async fn handle(&self, _args: HashMap<String, String>) -> anyhow::Result<()> {
        let database_url =
            env::var("DATABASE_URL").map_err(|_| anyhow::anyhow!("Failed to get DATABASE_URL"))?;

        let worker = job_queue::Worker::builder()
            .max_connections(10)
            .worker_count(4)
            .connect(&database_url)
            .await
            .map_err(|_| anyhow::anyhow!("Failed to connect to database"))?;

        worker.start().await?;

        Ok(())
    }
}