graphile_worker 0.11.4

High performance Rust/PostgreSQL job queue (also suitable for getting jobs generated by PostgreSQL triggers/functions out into a different work queue)
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

use thiserror::Error;

/// Errors that can occur during Graphile Worker operations.
///
/// This enum represents the various errors that can occur when interacting
/// with the job queue database or processing jobs.
#[derive(Error, Debug)]
pub enum GraphileWorkerError {
    /// An error occurred while executing an SQL query
    #[error("Error occured while query: {0}")]
    SqlError(#[from] sqlx::Error),

    /// An error occurred while serializing or deserializing JSON data
    #[error("Error while serializing params: {0}")]
    JsonSerializeError(#[from] serde_json::Error),

    /// Job scheduling was skipped by a before_job_schedule hook
    #[error("Job scheduling was skipped by hook")]
    JobScheduleSkipped,

    /// Job scheduling failed due to a before_job_schedule hook
    #[error("Job scheduling failed: {0}")]
    JobScheduleFailed(String),
}

/// A Result type alias for GraphileWorkerError.
///
/// This type alias simplifies the return types for functions that can
/// return a GraphileWorkerError.
pub type Result<T> = core::result::Result<T, GraphileWorkerError>;