Struct cortex::models::NewWorkerMetadata

pub struct NewWorkerMetadata {
    pub service_id: i32,
    pub last_dispatched_task_id: i64,
    pub last_returned_task_id: Option<i64>,
    pub total_dispatched: i32,
    pub total_returned: i32,
    pub first_seen: SystemTime,
    pub session_seen: Option<SystemTime>,
    pub time_last_dispatch: SystemTime,
    pub time_last_return: Option<SystemTime>,
    pub name: String,
}

Metadata collection for workers, updated by the dispatcher upon zmq transactions

Fields

service_id: i32

associated service for this worker metadata set

last_dispatched_task_id: i64

time of last ventilator dispatch to the service

last_returned_task_id: Option<i64>

time of last sink job received from the service

total_dispatched: i32

dispatch totals

total_returned: i32

return totals

first_seen: SystemTime

first registered ventilator request for this worker, coincides with insertion in DB

session_seen: Option<SystemTime>

first time seen in the current dispatcher session

time_last_dispatch: SystemTime

time of last dispatched task

time_last_return: Option<SystemTime>

time of last returned job result

name: String

identity of this worker, usually hostname:pid

Trait Implementations

impl Debug for NewWorkerMetadata

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

Formats the value using the given formatter.

impl<'insert> Insertable<table> for NewWorkerMetadata

type Values = <(Option<Eq<service_id, i32>>, Option<Eq<last_dispatched_task_id, i64>>, Option<Eq<last_returned_task_id, i64>>, Option<Eq<total_dispatched, i32>>, Option<Eq<total_returned, i32>>, Option<Eq<first_seen, SystemTime>>, Option<Eq<session_seen, SystemTime>>, Option<Eq<time_last_dispatch, SystemTime>>, Option<Eq<time_last_return, SystemTime>>, Option<Eq<name, String>>) as Insertable<table>>::Values

The VALUES clause to insert these records

fn values(self) -> Self::Values

Construct Self::Values

fn insert_into(
    self,
    table: T
) -> InsertStatement<T, Self::Values, Insert, NoReturningClause>

Insert self into a given table.

impl<'insert> Insertable<table> for &'insert NewWorkerMetadata

type Values = <(Option<Eq<service_id, &'insert i32>>, Option<Eq<last_dispatched_task_id, &'insert i64>>, Option<Eq<last_returned_task_id, &'insert i64>>, Option<Eq<total_dispatched, &'insert i32>>, Option<Eq<total_returned, &'insert i32>>, Option<Eq<first_seen, &'insert SystemTime>>, Option<Eq<session_seen, &'insert SystemTime>>, Option<Eq<time_last_dispatch, &'insert SystemTime>>, Option<Eq<time_last_return, &'insert SystemTime>>, Option<Eq<name, &'insert String>>) as Insertable<table>>::Values

The VALUES clause to insert these records

fn values(self) -> Self::Values

Construct Self::Values

fn insert_into(
    self,
    table: T
) -> InsertStatement<T, Self::Values, Insert, NoReturningClause>

Insert self into a given table.

impl<'insert> UndecoratedInsertRecord<table> for NewWorkerMetadata