apalis-postgres 1.0.0-rc.9

Background task processing for rust using apalis and postgres
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

use apalis_core::worker::context::WorkerContext;
use sqlx::Executor;

use crate::{error::Error, timestamp::Timestamp};

/// Register a worker in the database
///
/// Errors if worker already exists
pub async fn register_worker<E>(
    conn: &mut E,
    queue: &str,
    worker: &WorkerContext,
    last_seen: &Timestamp,
    backend_type: &str,
) -> Result<(), Error>
where
    for<'e> &'e mut E: Executor<'e, Database = sqlx::Postgres>,
{
    let res = sqlx::query_file!(
        "queries/worker/register.sql",
        worker.name(),
        queue,
        backend_type,
        worker.get_service(),
        last_seen
    )
    .execute(conn)
    .await?;
    if res.rows_affected() == 0 {
        return Err(Error::WorkerAlreadyExists(worker.name().to_owned()));
    }
    Ok(())
}