ocypod 0.8.0

Ocypod is a Redis-backed service for orchestrating background jobs.
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

use log::error;

use actix_web::{web, HttpResponse, Responder, ResponseError};

use crate::models::{ApplicationState, OcyError};

pub async fn tagged_jobs(
    path: web::Path<String>,
    data: web::Data<ApplicationState>,
) -> impl Responder {
    let tag = path.into_inner();
    let mut conn = match data.pool.get().await {
        Ok(conn) => conn,
        Err(err) => return OcyError::from(err).error_response(),
    };

    match data.redis_manager.tagged_job_ids(&mut conn, &tag).await {
        Ok(tags) => HttpResponse::Ok().json(tags),
        Err(err) => {
            error!("Failed to read tag data: {}", err);
            err.error_response()
        }
    }
}