Struct Task

pub struct Task {
    pub id: Uuid,
    pub parent: Option<Uuid>,
    pub created_at: DateTime<Utc>,
    pub updated_at: DateTime<Utc>,
    pub task_type: String,
    pub request: Option<Value>,
    pub result: Option<Value>,
    pub error: Option<Value>,
    pub in_progress: bool,
    pub done: bool,
}

Fields

id: Uuid

parent: Option<Uuid>

created_at: DateTime<Utc>

updated_at: DateTime<Utc>

task_type: String

request: Option<Value>

result: Option<Value>

error: Option<Value>

in_progress: bool

done: bool

Implementations

impl Task

pub async fn create_task<'a, DB, P>( db: DB, tables: &P, id: Option<Uuid>, task_type: String, req: Option<Value>, parent: Option<Uuid>, ) -> Result<Self>

where P: TaskTableProvider, DB: Acquire<'a, Database = Postgres>,

pub async fn load( db: impl PgExecutor<'_>, tables: &dyn TaskTableProvider, id: Uuid, ) -> Result<Option<Self>>

pub async fn with_children( self, db: impl PgExecutor<'_>, tables: &dyn TaskTableProvider, recursive: bool, ) -> Result<Vec<Self>>

pub async fn children( &self, db: impl PgExecutor<'_>, tables: &dyn TaskTableProvider, recursive: bool, ) -> Result<Vec<Self>>

pub async fn load_children( db: impl PgExecutor<'_>, tables: &dyn TaskTableProvider, id: Uuid, include_self: bool, recursive: bool, ) -> Result<Vec<Self>>

pub async fn load_any_waiting( db: impl PgExecutor<'_>, tables: &dyn TaskTableProvider, allowed_types: &[impl TaskType], ) -> Result<Option<Self>>

pub async fn load_waiting( id: Uuid, db: impl PgExecutor<'_>, tables: &dyn TaskTableProvider, allowed_types: &[impl TaskType], ) -> Result<Option<Self>>

pub async fn set_error( id: Uuid, db: impl Acquire<'_, Database = Postgres>, tables: &dyn TaskTableProvider, error: Value, ) -> Result<()>

Sets the error value for the task

pub async fn save( &self, db: impl Acquire<'_, Database = Postgres>, tables: &dyn TaskTableProvider, ) -> Result<()>

Saves current state in DB

pub async fn update( &mut self, db: impl PgExecutor<'_>, tables: &dyn TaskTableProvider, ) -> Result<()>

Queries state of this task from DB and updates self.

pub async fn delete( &self, db: impl Acquire<'_, Database = Postgres>, tables: &dyn TaskTableProvider, ) -> Result<()>

Deletes this and all child tasks (recursively) from the DB. Call this when the task is done.

pub async fn fullfill( &mut self, db: impl Acquire<'_, Database = Postgres>, tables: &dyn TaskTableProvider, result: Option<impl Into<Value>>, error: Option<impl Into<Value>>, ) -> Result<()>

Fullfill task with result/error and mark as done

pub async fn wait_until_done( &mut self, db: &Pool<Postgres>, tables: &dyn TaskTableProvider, poll_interval: Option<Duration>, ) -> Result<()>

pub async fn wait_until_done_and_delete( &mut self, pool: &Pool<Postgres>, tables: &dyn TaskTableProvider, poll_interval: Option<Duration>, ) -> Result<()>

pub fn request<R: DeserializeOwned>(&mut self) -> Result<R>

Takes request returns it deserialized.

pub fn result_cloned<R: DeserializeOwned>(&self) -> Result<Option<R>>

Takes the result returns it deserialized.

pub fn as_result<R: DeserializeOwned>(&mut self) -> Result<Option<R>>

Converts self into the result payload (or error).

Trait Implementations

impl Clone for Task

fn clone(&self) -> Task

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for Task

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl<'a, R: Row> FromRow<'a, R> for Task

where &'a str: ColumnIndex<R>, Uuid: Decode<'a, R::Database> + Type<R::Database>, Option<Uuid>: Decode<'a, R::Database> + Type<R::Database>, DateTime<Utc>: Decode<'a, R::Database> + Type<R::Database>, String: Decode<'a, R::Database> + Type<R::Database>, Option<Value>: Decode<'a, R::Database> + Type<R::Database>, bool: Decode<'a, R::Database> + Type<R::Database>,

fn from_row(row: &'a R) -> Result<Self>