apalis-postgres 1.0.0-rc.7

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

use apalis_core::worker::context::WorkerContext;
use apalis_sql::DateTime;
use sqlx::PgPool;

pub async fn register(
    pool: PgPool,
    worker_type: String,
    worker: WorkerContext,
    last_seen: DateTime,
    backend_type: &str,
) -> Result<(), sqlx::Error> {
    let res = sqlx::query_file!(
        "queries/worker/register.sql",
        worker.name(),
        worker_type,
        backend_type,
        worker.get_service(),
        last_seen
    )
    .execute(&pool)
    .await?;
    if res.rows_affected() == 0 {
        return Err(sqlx::Error::Io(std::io::Error::new(
            std::io::ErrorKind::AddrInUse,
            "WORKER_ALREADY_EXISTS",
        )));
    }
    Ok(())
}