Struct AsyncJob 

pub struct AsyncJob {

    pub id: String,
    pub tenant: TenantId,
    pub project: ProjectId,
    pub kind: String,
    pub status: AsyncJobStatus,
    pub request: String,
    pub parameters: Json<Value>,
    pub claims: Json<UserTokenClaims>,
    pub submitted_by: String,
    pub progress: Option<String>,
    pub output: Option<Json<Value>>,
    pub output_content_type: Option<String>,
    pub error: Option<Json<Value>>,
    pub attempts: i32,
    pub max_attempts: i32,
    pub locked_by: Option<String>,
    pub lease_expires_at: Option<OffsetDateTime>,
    pub created_at: OffsetDateTime,
    pub updated_at: OffsetDateTime,
    pub started_at: Option<OffsetDateTime>,
    pub finished_at: Option<OffsetDateTime>,
    pub expires_at: OffsetDateTime,
}

A job as stored.

Fields

id: String

tenant: TenantId

project: ProjectId

kind: String

status: AsyncJobStatus

request: String

parameters: Json<Value>

claims: Json<UserTokenClaims>

The submitter’s verified token claims; the worker runs the job as them.

submitted_by: String

progress: Option<String>

output: Option<Json<Value>>

output_content_type: Option<String>

error: Option<Json<Value>>

An OperationOutcome, once failed.

attempts: i32

max_attempts: i32

locked_by: Option<String>

lease_expires_at: Option<OffsetDateTime>

created_at: OffsetDateTime

updated_at: OffsetDateTime

started_at: Option<OffsetDateTime>

finished_at: Option<OffsetDateTime>

expires_at: OffsetDateTime

Trait Implementations

impl Clone for AsyncJob

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for AsyncJob

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

Formats the value using the given formatter.

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

where &'a str: ColumnIndex<R>, String: Decode<'a, R::Database> + Type<R::Database>, TenantId: Decode<'a, R::Database> + Type<R::Database>, ProjectId: Decode<'a, R::Database> + Type<R::Database>, AsyncJobStatus: Decode<'a, R::Database> + Type<R::Database>, Json<Value>: Decode<'a, R::Database> + Type<R::Database>, Json<UserTokenClaims>: Decode<'a, R::Database> + Type<R::Database>, Option<String>: Decode<'a, R::Database> + Type<R::Database>, Option<Json<Value>>: Decode<'a, R::Database> + Type<R::Database>, i32: Decode<'a, R::Database> + Type<R::Database>, Option<OffsetDateTime>: Decode<'a, R::Database> + Type<R::Database>, OffsetDateTime: Decode<'a, R::Database> + Type<R::Database>,

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