Struct Service 

pub struct Service {
    pub id: i32,
    pub name: String,
    pub version: f32,
    pub inputformat: String,
    pub outputformat: String,
    pub inputconverter: Option<String>,
    pub complex: bool,
    pub description: String,
    pub public_id: Uuid,
    pub lease_timeout_seconds: Option<i32>,
}

A CorTeX processing service

Fields

id: i32

auto-incremented postgres id

name: String

a human-readable name

version: f32

a floating-point number to mark the current version (e.g. 0.01)

inputformat: String

the expected input format (e.g. tex)

outputformat: String

the produced output format (e.g. html)

inputconverter: Option<String>

prerequisite input conversion service, if any

complex: bool

is this service requiring more than the main textual content of a document? mark “true” if unsure

description: String

a human-readable description

public_id: Uuid

Stable external handle (UUIDv7, DB-generated), independent of the mutable name — for public/API references that must survive a rename. Immutable once assigned (Arm 3 / D8).

lease_timeout_seconds: Option<i32>

Per-service lease / visibility-timeout override in seconds (D-17). None ⇒ use the global dispatcher.lease_timeout_seconds. Lets one dispatcher serve fast (latexml-oxide, short lease) and slow (Perl LaTeXML, long lease) worker classes without false reaps or delayed dead-worker recovery. Captured into TaskProgress at dispatch time, so a config change never re-times an already-leased task.

Implementations

impl Service

pub fn find_by_name( name_query: &str, connection: &mut PgConnection, ) -> Result<Service, Error>

ORM-like until diesel.rs introduces finders for more fields

pub fn all(connection: &mut PgConnection) -> Result<Vec<Self>, Error>

Returns all registered services, ordered by name (the service registry). Includes the magic init (id 1) and import (id 2) services alongside the real conversion services (id > 2).

pub fn set_lease_timeout( &self, seconds: Option<i32>, connection: &mut PgConnection, ) -> Result<usize, Error>

Sets (or clears, with None) this service’s per-service lease / visibility-timeout override (D-17). None ⇒ fall back to the global dispatcher.lease_timeout_seconds. Captured into TaskProgress only at lease time, so a change takes effect on the next dispatch and never re-times an already-leased task. Returns the rows updated (1, or 0 if the service vanished).

pub fn to_hash(&self) -> HashMap<String, String>

Returns a hash representation of the Service, usually for frontend reports

pub fn select_workers( &self, connection: &mut PgConnection, ) -> Result<Vec<WorkerMetadata>, Error>

Return the dispatcher’s registered workers for this service

pub fn task_count_for_corpus( &self, corpus: &Corpus, connection: &mut PgConnection, ) -> Result<i64, Error>

Counts this service’s tasks on a given corpus — the size of what Self::deactivate_from_corpus would delete. Used to preview the blast radius of a destructive deactivation before executing.

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

Counts this service’s tasks across every corpus — the size of what Self::destroy would delete. Used to preview the blast radius of a registry-wide service deletion before executing.

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

Deactivates (retires) this service from a single corpus: deletes the (corpus, service) pair’s tasks and their log_* rows in one transaction, returning the number of tasks removed. The service definition and its work on other corpora are untouched. The log_* tables have no FK to tasks, so their rows are deleted explicitly before the tasks or they orphan (the same hazard closed in super::Corpus::destroy); transactional so a crash can’t half-delete. historical_runs tallies survive (no FK to tasks), while per-task historical_tasks snapshots cascade away with the tasks — the same semantics as deleting a corpus.

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

Permanently deletes this service and all of its work across every corpus — the log_* messages and tasks of every (*, service) pair, then the services row itself — consuming the object and returning the number of rows the final services delete removed. One transaction, so a crash can’t leave the service half-deleted (crash-consistency, docs/DESIGN_PRINCIPLES.md). The log_* tables have no FK to tasks, so their rows are deleted explicitly before the tasks or they orphan — the hazard closed in super::Corpus::destroy and the reason this is one primitive rather than a bare DELETE FROM services (which is exactly the latent delete_service_by_name orphan bug, R-6). historical_runs tallies survive (no FK to tasks), while per-task historical_tasks snapshots cascade away with the tasks — the same semantics as Self::deactivate_from_corpus and corpus deletion.

Caller’s contract: the magic init (1) and import (2) services are infrastructure and must never be destroyed; this method does not itself guard them (mirroring super::Corpus::destroy, which guards nothing). crate::backend’s destroy_service_by_name enforces the guard, and the frontend rejects them with 403 before ever reaching here.

Trait Implementations

impl AsChangeset for Service

type Target = table

The table which Self::Changeset will be updating

type Changeset = <(Grouped<Eq<name, <String as AsExpression<<name as Expression>::SqlType>>::Expression>>, Grouped<Eq<version, <f32 as AsExpression<<version as Expression>::SqlType>>::Expression>>, Grouped<Eq<inputformat, <String as AsExpression<<inputformat as Expression>::SqlType>>::Expression>>, Grouped<Eq<outputformat, <String as AsExpression<<outputformat as Expression>::SqlType>>::Expression>>, Option<Grouped<Eq<inputconverter, <String as AsExpression<<inputconverter as Expression>::SqlType>>::Expression>>>, Grouped<Eq<complex, <bool as AsExpression<<complex as Expression>::SqlType>>::Expression>>, Grouped<Eq<description, <String as AsExpression<<description as Expression>::SqlType>>::Expression>>, Grouped<Eq<public_id, <Uuid as AsExpression<<public_id as Expression>::SqlType>>::Expression>>, Option<Grouped<Eq<lease_timeout_seconds, <i32 as AsExpression<<lease_timeout_seconds 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 Service

where (Eq<name, &'update String>, Eq<version, &'update f32>, Eq<inputformat, &'update String>, Eq<outputformat, &'update String>, Option<Eq<inputconverter, &'update String>>, Eq<complex, &'update bool>, Eq<description, &'update String>, Eq<public_id, &'update Uuid>, Option<Eq<lease_timeout_seconds, &'update i32>>): AsChangeset,

type Target = table

The table which Self::Changeset will be updating

type Changeset = <(Grouped<Eq<name, <&'update String as AsExpression<<name as Expression>::SqlType>>::Expression>>, Grouped<Eq<version, <&'update f32 as AsExpression<<version as Expression>::SqlType>>::Expression>>, Grouped<Eq<inputformat, <&'update String as AsExpression<<inputformat as Expression>::SqlType>>::Expression>>, Grouped<Eq<outputformat, <&'update String as AsExpression<<outputformat as Expression>::SqlType>>::Expression>>, Option<Grouped<Eq<inputconverter, <&'update String as AsExpression<<inputconverter as Expression>::SqlType>>::Expression>>>, Grouped<Eq<complex, <&'update bool as AsExpression<<complex as Expression>::SqlType>>::Expression>>, Grouped<Eq<description, <&'update String as AsExpression<<description as Expression>::SqlType>>::Expression>>, Grouped<Eq<public_id, <&'update Uuid as AsExpression<<public_id as Expression>::SqlType>>::Expression>>, Option<Grouped<Eq<lease_timeout_seconds, <&'update i32 as AsExpression<<lease_timeout_seconds 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<&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<&Service> for WorkerMetadata

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<&Service> for HistoricalRun

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<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<Service> for WorkerMetadata

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<Service> for HistoricalRun

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 Clone for Service

fn clone(&self) -> Service

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for Service

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

Formats the value using the given formatter.

impl From<Service> for ServiceDto

fn from(service: Service) -> ServiceDto

Converts to this type from the input type.

impl HasTable for Service

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 Service

type Id = &'ident i32

The type of this struct’s identifier.

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

Returns the identifier for this record.

impl<__DB: Backend, __ST0, __ST1, __ST2, __ST3, __ST4, __ST5, __ST6, __ST7, __ST8, __ST9> Queryable<(__ST0, __ST1, __ST2, __ST3, __ST4, __ST5, __ST6, __ST7, __ST8, __ST9), __DB> for Service

where (i32, String, f32, String, String, Option<String>, bool, String, Uuid, Option<i32>): FromStaticSqlRow<(__ST0, __ST1, __ST2, __ST3, __ST4, __ST5, __ST6, __ST7, __ST8, __ST9), __DB>,

type Row = (i32, String, f32, String, String, Option<String>, bool, String, Uuid, Option<i32>)

The Rust type you’d like to map from.

fn build( row: (i32, String, f32, String, String, Option<String>, bool, String, Uuid, Option<i32>), ) -> Result<Self>

Construct an instance of this type