Struct Task 

pub struct Task {
    pub id: i64,
    pub service_id: i32,
    pub corpus_id: i32,
    pub status: i32,
    pub entry: String,
}

A CorTeX task, for a given corpus-service pair

Fields

id: i64

task primary key, auto-incremented by postgresql

service_id: i32

id of the service owning this task

corpus_id: i32

id of the corpus hosting this task

status: i32

current processing status of this task

entry: String

entry path on the file system

Implementations

impl Task

pub fn delete_by_entry( &self, connection: &mut PgConnection, ) -> Result<usize, Error>

Delete task by entry

pub fn delete_by_service_id( &self, connection: &mut PgConnection, ) -> Result<usize, Error>

Delete all tasks matching this task’s service id

pub fn delete_by_id( &self, connection: &mut PgConnection, ) -> Result<usize, Error>

Delete task by id

pub fn find(taskid: i64, connection: &mut PgConnection) -> Result<Task, Error>

Find task by id, error if none

pub fn count_todo(connection: &mut PgConnection) -> i64

Count of TODO tasks for real conversion services — the pending-conversion backlog (work waiting to be dispatched to the fleet). The single operational “is the fleet keeping up?” number, shared by /metrics (cortex_tasks_todo), the admin dashboard, and cortex status. One count over tasks; bounded, and fast via the partial todo_index once a running dispatcher drains the backlog. 0 on a query error (best-effort, matching the report paths).

Excludes the magic infrastructure services (1=init, 2=import; real services are id > 2): their rows are status-0 (TODO) placeholders that exist for other services to activate over and never receive real conversion work, so counting them inflated the backlog with tasks that are never truly pending.

pub fn find_by_entry( entry: &str, connection: &mut PgConnection, ) -> Result<Task, Error>

Find task by entry, error if none

pub fn find_by_name( name: &str, corpus: &Corpus, service: &Service, connection: &mut PgConnection, ) -> Result<Task, Error>

Find task by name-suffix of an entry, error if none

Trait Implementations

impl AsChangeset for Task

type Target = table

The table which Self::Changeset will be updating

type Changeset = <(Grouped<Eq<service_id, <i32 as AsExpression<<service_id as Expression>::SqlType>>::Expression>>, Grouped<Eq<corpus_id, <i32 as AsExpression<<corpus_id as Expression>::SqlType>>::Expression>>, Grouped<Eq<status, <i32 as AsExpression<<status as Expression>::SqlType>>::Expression>>, Grouped<Eq<entry, <String as AsExpression<<entry as Expression>::SqlType>>::Expression>>) as AsChangeset>::Changeset

The update statement this type represents

fn as_changeset(self) -> <Self as AsChangeset>::Changeset

Convert self into the actual update statement being executed

impl<'update> AsChangeset for &'update Task

where (Eq<service_id, &'update i32>, Eq<corpus_id, &'update i32>, Eq<status, &'update i32>, Eq<entry, &'update String>): AsChangeset,

type Target = table

The table which Self::Changeset will be updating

type Changeset = <(Grouped<Eq<service_id, <&'update i32 as AsExpression<<service_id as Expression>::SqlType>>::Expression>>, Grouped<Eq<corpus_id, <&'update i32 as AsExpression<<corpus_id as Expression>::SqlType>>::Expression>>, Grouped<Eq<status, <&'update i32 as AsExpression<<status as Expression>::SqlType>>::Expression>>, Grouped<Eq<entry, <&'update String as AsExpression<<entry as Expression>::SqlType>>::Expression>>) as AsChangeset>::Changeset

The update statement this type represents

fn as_changeset(self) -> <Self as AsChangeset>::Changeset

Convert self into the actual update statement being executed

impl<__FK> BelongsTo<&Corpus> for Task

where __FK: Hash + Eq, for<'__a> &'__a i32: Into<Option<&'__a __FK>>, for<'__a> &'__a Corpus: Identifiable<Id = &'__a __FK>,

type ForeignKey = __FK

The foreign key of this struct

type ForeignKeyColumn = corpus_id

The database column representing the foreign key of the table this struct represents

fn foreign_key(&self) -> Option<&Self::ForeignKey>

Returns the foreign key for self

fn foreign_key_column() -> Self::ForeignKeyColumn

Returns the foreign key column of this struct’s table

impl<__FK> BelongsTo<&Service> for Task

where __FK: Hash + Eq, for<'__a> &'__a i32: Into<Option<&'__a __FK>>, for<'__a> &'__a Service: Identifiable<Id = &'__a __FK>,

type ForeignKey = __FK

The foreign key of this struct

type ForeignKeyColumn = service_id

The database column representing the foreign key of the table this struct represents

fn foreign_key(&self) -> Option<&Self::ForeignKey>

Returns the foreign key for self

fn foreign_key_column() -> Self::ForeignKeyColumn

Returns the foreign key column of this struct’s table

impl<__FK> BelongsTo<&Task> for LogInfo

where __FK: Hash + Eq, for<'__a> &'__a i64: Into<Option<&'__a __FK>>, for<'__a> &'__a Task: Identifiable<Id = &'__a __FK>,

type ForeignKey = __FK

The foreign key of this struct

type ForeignKeyColumn = task_id

The database column representing the foreign key of the table this struct represents

fn foreign_key(&self) -> Option<&Self::ForeignKey>

Returns the foreign key for self

fn foreign_key_column() -> Self::ForeignKeyColumn

Returns the foreign key column of this struct’s table

impl<__FK> BelongsTo<&Task> for LogWarning

where __FK: Hash + Eq, for<'__a> &'__a i64: Into<Option<&'__a __FK>>, for<'__a> &'__a Task: Identifiable<Id = &'__a __FK>,

type ForeignKey = __FK

The foreign key of this struct

type ForeignKeyColumn = task_id

The database column representing the foreign key of the table this struct represents

fn foreign_key(&self) -> Option<&Self::ForeignKey>

Returns the foreign key for self

fn foreign_key_column() -> Self::ForeignKeyColumn

Returns the foreign key column of this struct’s table

impl<__FK> BelongsTo<&Task> for LogError

where __FK: Hash + Eq, for<'__a> &'__a i64: Into<Option<&'__a __FK>>, for<'__a> &'__a Task: Identifiable<Id = &'__a __FK>,

type ForeignKey = __FK

The foreign key of this struct

type ForeignKeyColumn = task_id

The database column representing the foreign key of the table this struct represents

fn foreign_key(&self) -> Option<&Self::ForeignKey>

Returns the foreign key for self

fn foreign_key_column() -> Self::ForeignKeyColumn

Returns the foreign key column of this struct’s table

impl<__FK> BelongsTo<&Task> for LogFatal

where __FK: Hash + Eq, for<'__a> &'__a i64: Into<Option<&'__a __FK>>, for<'__a> &'__a Task: Identifiable<Id = &'__a __FK>,

type ForeignKey = __FK

The foreign key of this struct

type ForeignKeyColumn = task_id

The database column representing the foreign key of the table this struct represents

fn foreign_key(&self) -> Option<&Self::ForeignKey>

Returns the foreign key for self

fn foreign_key_column() -> Self::ForeignKeyColumn

Returns the foreign key column of this struct’s table

impl<__FK> BelongsTo<&Task> for LogInvalid

where __FK: Hash + Eq, for<'__a> &'__a i64: Into<Option<&'__a __FK>>, for<'__a> &'__a Task: Identifiable<Id = &'__a __FK>,

type ForeignKey = __FK

The foreign key of this struct

type ForeignKeyColumn = task_id

The database column representing the foreign key of the table this struct represents

fn foreign_key(&self) -> Option<&Self::ForeignKey>

Returns the foreign key for self

fn foreign_key_column() -> Self::ForeignKeyColumn

Returns the foreign key column of this struct’s table

impl<__FK> BelongsTo<Corpus> for Task

where __FK: Hash + Eq, for<'__a> &'__a i32: Into<Option<&'__a __FK>>, for<'__a> &'__a Corpus: Identifiable<Id = &'__a __FK>,

type ForeignKey = __FK

The foreign key of this struct

type ForeignKeyColumn = corpus_id

The database column representing the foreign key of the table this struct represents

fn foreign_key(&self) -> Option<&Self::ForeignKey>

Returns the foreign key for self

fn foreign_key_column() -> Self::ForeignKeyColumn

Returns the foreign key column of this struct’s table

impl<__FK> BelongsTo<Service> for Task

where __FK: Hash + Eq, for<'__a> &'__a i32: Into<Option<&'__a __FK>>, for<'__a> &'__a Service: Identifiable<Id = &'__a __FK>,

type ForeignKey = __FK

The foreign key of this struct

type ForeignKeyColumn = service_id

The database column representing the foreign key of the table this struct represents

fn foreign_key(&self) -> Option<&Self::ForeignKey>

Returns the foreign key for self

fn foreign_key_column() -> Self::ForeignKeyColumn

Returns the foreign key column of this struct’s table

impl<__FK> BelongsTo<Task> for LogInfo

where __FK: Hash + Eq, for<'__a> &'__a i64: Into<Option<&'__a __FK>>, for<'__a> &'__a Task: Identifiable<Id = &'__a __FK>,

type ForeignKey = __FK

The foreign key of this struct

type ForeignKeyColumn = task_id

The database column representing the foreign key of the table this struct represents

fn foreign_key(&self) -> Option<&Self::ForeignKey>

Returns the foreign key for self

fn foreign_key_column() -> Self::ForeignKeyColumn

Returns the foreign key column of this struct’s table

impl<__FK> BelongsTo<Task> for LogWarning

where __FK: Hash + Eq, for<'__a> &'__a i64: Into<Option<&'__a __FK>>, for<'__a> &'__a Task: Identifiable<Id = &'__a __FK>,

type ForeignKey = __FK

The foreign key of this struct

type ForeignKeyColumn = task_id

The database column representing the foreign key of the table this struct represents

fn foreign_key(&self) -> Option<&Self::ForeignKey>

Returns the foreign key for self

fn foreign_key_column() -> Self::ForeignKeyColumn

Returns the foreign key column of this struct’s table

impl<__FK> BelongsTo<Task> for LogError

where __FK: Hash + Eq, for<'__a> &'__a i64: Into<Option<&'__a __FK>>, for<'__a> &'__a Task: Identifiable<Id = &'__a __FK>,

type ForeignKey = __FK

The foreign key of this struct

type ForeignKeyColumn = task_id

The database column representing the foreign key of the table this struct represents

fn foreign_key(&self) -> Option<&Self::ForeignKey>

Returns the foreign key for self

fn foreign_key_column() -> Self::ForeignKeyColumn

Returns the foreign key column of this struct’s table

impl<__FK> BelongsTo<Task> for LogFatal

where __FK: Hash + Eq, for<'__a> &'__a i64: Into<Option<&'__a __FK>>, for<'__a> &'__a Task: Identifiable<Id = &'__a __FK>,

type ForeignKey = __FK

The foreign key of this struct

type ForeignKeyColumn = task_id

The database column representing the foreign key of the table this struct represents

fn foreign_key(&self) -> Option<&Self::ForeignKey>

Returns the foreign key for self

fn foreign_key_column() -> Self::ForeignKeyColumn

Returns the foreign key column of this struct’s table

impl<__FK> BelongsTo<Task> for LogInvalid

where __FK: Hash + Eq, for<'__a> &'__a i64: Into<Option<&'__a __FK>>, for<'__a> &'__a Task: Identifiable<Id = &'__a __FK>,

type ForeignKey = __FK

The foreign key of this struct

type ForeignKeyColumn = task_id

The database column representing the foreign key of the table this struct represents

fn foreign_key(&self) -> Option<&Self::ForeignKey>

Returns the foreign key for self

fn foreign_key_column() -> Self::ForeignKeyColumn

Returns the foreign key column of this struct’s table

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 CortexDeletable for Task

fn delete_by( &self, connection: &mut PgConnection, field: &str, ) -> Result<usize, Error>

Creates a new item given a connection

impl Debug for Task

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

Formats the value using the given formatter.

impl Eq for Task

impl HasTable for Task

type Table = table

The table this type is associated with.

fn table() -> <Self as HasTable>::Table

Returns the table this type is associated with.

impl<'ident> Identifiable for &'ident Task

type Id = &'ident i64

The type of this struct’s identifier.

fn id(self) -> <Self as Identifiable>::Id

Returns the identifier for this record.

impl PartialEq for Task

fn eq(&self, other: &Task) -> bool

Tests for self and other values to be equal, and is used by ==.

fn ne(&self, other: &Rhs) -> bool

Tests for !=. The default implementation is almost always sufficient, and should not be overridden without very good reason.

impl<__DB: Backend, __ST0, __ST1, __ST2, __ST3, __ST4> Queryable<(__ST0, __ST1, __ST2, __ST3, __ST4), __DB> for Task

where (i64, i32, i32, i32, String): FromStaticSqlRow<(__ST0, __ST1, __ST2, __ST3, __ST4), __DB>,

type Row = (i64, i32, i32, i32, String)

The Rust type you’d like to map from.

fn build(row: (i64, i32, i32, i32, String)) -> Result<Self>

Construct an instance of this type

impl<__DB: Backend> QueryableByName<__DB> for Task

where i64: FromSql<SqlTypeOf<id>, __DB>, i32: FromSql<SqlTypeOf<service_id>, __DB> + FromSql<SqlTypeOf<corpus_id>, __DB> + FromSql<SqlTypeOf<status>, __DB>, String: FromSql<SqlTypeOf<entry>, __DB>,

fn build<'__a>(row: &impl NamedRow<'__a, __DB>) -> Result<Self>

Construct an instance of Self from the database row

impl StructuralPartialEq for Task