Struct cortex::models::WorkerMetadata

pub struct WorkerMetadata {
    pub id: i32,
    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

id: i32

task primary key, auto-incremented by postgresql

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

Implementations

impl WorkerMetadata

pub fn record_dispatched(
    name: String,
    service_id: i32,
    last_dispatched_task_id: i64,
    backend_address: String
) -> Result<(), Error>

Update the metadata for a worker which was just dispatched to

pub fn record_received(
    identity: String,
    service_id: i32,
    last_returned_task_id: i64,
    backend_address: String
) -> Result<(), Error>

Update the metadata for a worker which was just received from

pub fn find_by_name(
    identity: &str,
    sid: i32,
    connection: &PgConnection
) -> Result<WorkerMetadata, Error>

Load worker metadata record by identity and service id

Trait Implementations

impl Clone for WorkerMetadata

fn clone(&self) -> WorkerMetadata

Returns a copy of the value.

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

Performs copy-assignment from source.

impl Debug for WorkerMetadata

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

Formats the value using the given formatter.

impl From<WorkerMetadata> for HashMap<String, String>

fn from(worker: WorkerMetadata) -> HashMap<String, String>

Performs the conversion.

impl HasTable for WorkerMetadata

type Table = table

The table this type is associated with.

fn table() -> Self::Table

Returns the table this type is associated with.

impl<'ident> Identifiable for &'ident WorkerMetadata

type Id = &'ident i32

The type of this struct's identifier.

fn id(self) -> Self::Id

Returns the identifier for this record.

impl<__DB: Backend, __ST> Queryable<__ST, __DB> for WorkerMetadata where
    (i32, i32, i64, Option<i64>, i32, i32, SystemTime, Option<SystemTime>, SystemTime, Option<SystemTime>, String): Queryable<__ST, __DB>, 

type Row = <(i32, i32, i64, Option<i64>, i32, i32, SystemTime, Option<SystemTime>, SystemTime, Option<SystemTime>, String) as Queryable<__ST, __DB>>::Row

The Rust type you'd like to map from.

fn build(row: Self::Row) -> Self

Construct an instance of this type

impl Serialize for WorkerMetadata

fn serialize<__S>(&self, __serializer: __S) -> Result<__S::Ok, __S::Error> where
    __S: Serializer, 

Serialize this value into the given Serde serializer.