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,
}Expand description
Metadata collection for workers, updated by the dispatcher upon zmq transactions
Fields§
§service_id: i32associated service for this worker metadata set
last_dispatched_task_id: i64time of last ventilator dispatch to the service
last_returned_task_id: Option<i64>time of last sink job received from the service
total_dispatched: i32dispatch totals
total_returned: i32return totals
first_seen: SystemTimefirst 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: SystemTimetime of last dispatched task
time_last_return: Option<SystemTime>time of last returned job result
name: Stringidentity of this worker, usually hostname:pid
Trait Implementations§
Source§impl Debug for NewWorkerMetadata
impl Debug for NewWorkerMetadata
Source§impl Insertable<table> for NewWorkerMetadatawhere
i32: AsExpression<<service_id as Expression>::SqlType> + AsExpression<<total_dispatched as Expression>::SqlType> + AsExpression<<total_returned as Expression>::SqlType>,
i64: AsExpression<<last_dispatched_task_id as Expression>::SqlType> + AsExpression<<last_returned_task_id as Expression>::SqlType>,
SystemTime: AsExpression<<first_seen as Expression>::SqlType> + AsExpression<<session_seen as Expression>::SqlType> + AsExpression<<time_last_dispatch as Expression>::SqlType> + AsExpression<<time_last_return as Expression>::SqlType>,
String: AsExpression<<name as Expression>::SqlType>,
impl Insertable<table> for NewWorkerMetadatawhere
i32: AsExpression<<service_id as Expression>::SqlType> + AsExpression<<total_dispatched as Expression>::SqlType> + AsExpression<<total_returned as Expression>::SqlType>,
i64: AsExpression<<last_dispatched_task_id as Expression>::SqlType> + AsExpression<<last_returned_task_id as Expression>::SqlType>,
SystemTime: AsExpression<<first_seen as Expression>::SqlType> + AsExpression<<session_seen as Expression>::SqlType> + AsExpression<<time_last_dispatch as Expression>::SqlType> + AsExpression<<time_last_return as Expression>::SqlType>,
String: AsExpression<<name as Expression>::SqlType>,
Source§type Values = <(Option<Grouped<Eq<service_id, <i32 as AsExpression<<service_id as Expression>::SqlType>>::Expression>>>, Option<Grouped<Eq<last_dispatched_task_id, <i64 as AsExpression<<last_dispatched_task_id as Expression>::SqlType>>::Expression>>>, Option<Grouped<Eq<last_returned_task_id, <i64 as AsExpression<<last_returned_task_id as Expression>::SqlType>>::Expression>>>, Option<Grouped<Eq<total_dispatched, <i32 as AsExpression<<total_dispatched as Expression>::SqlType>>::Expression>>>, Option<Grouped<Eq<total_returned, <i32 as AsExpression<<total_returned as Expression>::SqlType>>::Expression>>>, Option<Grouped<Eq<first_seen, <SystemTime as AsExpression<<first_seen as Expression>::SqlType>>::Expression>>>, Option<Grouped<Eq<session_seen, <SystemTime as AsExpression<<session_seen as Expression>::SqlType>>::Expression>>>, Option<Grouped<Eq<time_last_dispatch, <SystemTime as AsExpression<<time_last_dispatch as Expression>::SqlType>>::Expression>>>, Option<Grouped<Eq<time_last_return, <SystemTime as AsExpression<<time_last_return as Expression>::SqlType>>::Expression>>>, Option<Grouped<Eq<name, <String as AsExpression<<name as Expression>::SqlType>>::Expression>>>) as Insertable<table>>::Values
type Values = <(Option<Grouped<Eq<service_id, <i32 as AsExpression<<service_id as Expression>::SqlType>>::Expression>>>, Option<Grouped<Eq<last_dispatched_task_id, <i64 as AsExpression<<last_dispatched_task_id as Expression>::SqlType>>::Expression>>>, Option<Grouped<Eq<last_returned_task_id, <i64 as AsExpression<<last_returned_task_id as Expression>::SqlType>>::Expression>>>, Option<Grouped<Eq<total_dispatched, <i32 as AsExpression<<total_dispatched as Expression>::SqlType>>::Expression>>>, Option<Grouped<Eq<total_returned, <i32 as AsExpression<<total_returned as Expression>::SqlType>>::Expression>>>, Option<Grouped<Eq<first_seen, <SystemTime as AsExpression<<first_seen as Expression>::SqlType>>::Expression>>>, Option<Grouped<Eq<session_seen, <SystemTime as AsExpression<<session_seen as Expression>::SqlType>>::Expression>>>, Option<Grouped<Eq<time_last_dispatch, <SystemTime as AsExpression<<time_last_dispatch as Expression>::SqlType>>::Expression>>>, Option<Grouped<Eq<time_last_return, <SystemTime as AsExpression<<time_last_return as Expression>::SqlType>>::Expression>>>, Option<Grouped<Eq<name, <String as AsExpression<<name as Expression>::SqlType>>::Expression>>>) as Insertable<table>>::Values
VALUES clause to insert these records Read moreSource§fn values(
self,
) -> <(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
fn values( self, ) -> <(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
Self::Values Read more§fn insert_into(self, table: T) -> InsertStatement<T, Self::Values>where
T: Table,
Self: Sized,
fn insert_into(self, table: T) -> InsertStatement<T, Self::Values>where
T: Table,
Self: Sized,
self into a given table. Read moreSource§impl<'insert> Insertable<table> for &'insert NewWorkerMetadatawhere
&'insert i32: AsExpression<<service_id as Expression>::SqlType> + AsExpression<<total_dispatched as Expression>::SqlType> + AsExpression<<total_returned as Expression>::SqlType>,
&'insert i64: AsExpression<<last_dispatched_task_id as Expression>::SqlType> + AsExpression<<last_returned_task_id as Expression>::SqlType>,
&'insert SystemTime: AsExpression<<first_seen as Expression>::SqlType> + AsExpression<<session_seen as Expression>::SqlType> + AsExpression<<time_last_dispatch as Expression>::SqlType> + AsExpression<<time_last_return as Expression>::SqlType>,
&'insert String: AsExpression<<name as Expression>::SqlType>,
impl<'insert> Insertable<table> for &'insert NewWorkerMetadatawhere
&'insert i32: AsExpression<<service_id as Expression>::SqlType> + AsExpression<<total_dispatched as Expression>::SqlType> + AsExpression<<total_returned as Expression>::SqlType>,
&'insert i64: AsExpression<<last_dispatched_task_id as Expression>::SqlType> + AsExpression<<last_returned_task_id as Expression>::SqlType>,
&'insert SystemTime: AsExpression<<first_seen as Expression>::SqlType> + AsExpression<<session_seen as Expression>::SqlType> + AsExpression<<time_last_dispatch as Expression>::SqlType> + AsExpression<<time_last_return as Expression>::SqlType>,
&'insert String: AsExpression<<name as Expression>::SqlType>,
Source§type Values = <(Option<Grouped<Eq<service_id, <&'insert i32 as AsExpression<<service_id as Expression>::SqlType>>::Expression>>>, Option<Grouped<Eq<last_dispatched_task_id, <&'insert i64 as AsExpression<<last_dispatched_task_id as Expression>::SqlType>>::Expression>>>, Option<Grouped<Eq<last_returned_task_id, <&'insert i64 as AsExpression<<last_returned_task_id as Expression>::SqlType>>::Expression>>>, Option<Grouped<Eq<total_dispatched, <&'insert i32 as AsExpression<<total_dispatched as Expression>::SqlType>>::Expression>>>, Option<Grouped<Eq<total_returned, <&'insert i32 as AsExpression<<total_returned as Expression>::SqlType>>::Expression>>>, Option<Grouped<Eq<first_seen, <&'insert SystemTime as AsExpression<<first_seen as Expression>::SqlType>>::Expression>>>, Option<Grouped<Eq<session_seen, <&'insert SystemTime as AsExpression<<session_seen as Expression>::SqlType>>::Expression>>>, Option<Grouped<Eq<time_last_dispatch, <&'insert SystemTime as AsExpression<<time_last_dispatch as Expression>::SqlType>>::Expression>>>, Option<Grouped<Eq<time_last_return, <&'insert SystemTime as AsExpression<<time_last_return as Expression>::SqlType>>::Expression>>>, Option<Grouped<Eq<name, <&'insert String as AsExpression<<name as Expression>::SqlType>>::Expression>>>) as Insertable<table>>::Values
type Values = <(Option<Grouped<Eq<service_id, <&'insert i32 as AsExpression<<service_id as Expression>::SqlType>>::Expression>>>, Option<Grouped<Eq<last_dispatched_task_id, <&'insert i64 as AsExpression<<last_dispatched_task_id as Expression>::SqlType>>::Expression>>>, Option<Grouped<Eq<last_returned_task_id, <&'insert i64 as AsExpression<<last_returned_task_id as Expression>::SqlType>>::Expression>>>, Option<Grouped<Eq<total_dispatched, <&'insert i32 as AsExpression<<total_dispatched as Expression>::SqlType>>::Expression>>>, Option<Grouped<Eq<total_returned, <&'insert i32 as AsExpression<<total_returned as Expression>::SqlType>>::Expression>>>, Option<Grouped<Eq<first_seen, <&'insert SystemTime as AsExpression<<first_seen as Expression>::SqlType>>::Expression>>>, Option<Grouped<Eq<session_seen, <&'insert SystemTime as AsExpression<<session_seen as Expression>::SqlType>>::Expression>>>, Option<Grouped<Eq<time_last_dispatch, <&'insert SystemTime as AsExpression<<time_last_dispatch as Expression>::SqlType>>::Expression>>>, Option<Grouped<Eq<time_last_return, <&'insert SystemTime as AsExpression<<time_last_return as Expression>::SqlType>>::Expression>>>, Option<Grouped<Eq<name, <&'insert String as AsExpression<<name as Expression>::SqlType>>::Expression>>>) as Insertable<table>>::Values
VALUES clause to insert these records Read moreSource§fn values(
self,
) -> <(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
fn values( self, ) -> <(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
Self::Values Read more§fn insert_into(self, table: T) -> InsertStatement<T, Self::Values>where
T: Table,
Self: Sized,
fn insert_into(self, table: T) -> InsertStatement<T, Self::Values>where
T: Table,
Self: Sized,
self into a given table. Read moreimpl UndecoratedInsertRecord<table> for NewWorkerMetadata
Auto Trait Implementations§
impl Freeze for NewWorkerMetadata
impl RefUnwindSafe for NewWorkerMetadata
impl Send for NewWorkerMetadata
impl Sync for NewWorkerMetadata
impl Unpin for NewWorkerMetadata
impl UnsafeUnpin for NewWorkerMetadata
impl UnwindSafe for NewWorkerMetadata
Blanket Implementations§
§impl<T> AggregateExpressionMethods for T
impl<T> AggregateExpressionMethods for T
§fn aggregate_distinct(self) -> Self::Outputwhere
Self: DistinctDsl,
fn aggregate_distinct(self) -> Self::Outputwhere
Self: DistinctDsl,
DISTINCT modifier for aggregate functions Read more§fn aggregate_all(self) -> Self::Outputwhere
Self: AllDsl,
fn aggregate_all(self) -> Self::Outputwhere
Self: AllDsl,
ALL modifier for aggregate functions Read more§fn aggregate_filter<P>(self, f: P) -> Self::Outputwhere
P: AsExpression<Bool>,
Self: FilterDsl<<P as AsExpression<Bool>>::Expression>,
fn aggregate_filter<P>(self, f: P) -> Self::Outputwhere
P: AsExpression<Bool>,
Self: FilterDsl<<P as AsExpression<Bool>>::Expression>,
§fn aggregate_order<O>(self, o: O) -> Self::Outputwhere
Self: OrderAggregateDsl<O>,
fn aggregate_order<O>(self, o: O) -> Self::Outputwhere
Self: OrderAggregateDsl<O>,
§impl<'a, T, E> AsTaggedExplicit<'a, E> for Twhere
T: 'a,
impl<'a, T, E> AsTaggedExplicit<'a, E> for Twhere
T: 'a,
§impl<'a, T, E> AsTaggedImplicit<'a, E> for Twhere
T: 'a,
impl<'a, T, E> AsTaggedImplicit<'a, E> for Twhere
T: 'a,
Source§impl<T> BorrowMut<T> for Twhere
T: ?Sized,
impl<T> BorrowMut<T> for Twhere
T: ?Sized,
Source§fn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
impl<ST, DT> CastableFrom<ST, Initialized, Initialized> for DT
impl<ST, DT> CastableFrom<ST, Uninit, Uninit> for DT
§impl<T> Downcast for Twhere
T: Any,
impl<T> Downcast for Twhere
T: Any,
§fn into_any(self: Box<T>) -> Box<dyn Any>
fn into_any(self: Box<T>) -> Box<dyn Any>
Box<dyn Trait> (where Trait: Downcast) to Box<dyn Any>, which can then be
downcast into Box<dyn ConcreteType> where ConcreteType implements Trait.§fn into_any_rc(self: Rc<T>) -> Rc<dyn Any>
fn into_any_rc(self: Rc<T>) -> Rc<dyn Any>
Rc<Trait> (where Trait: Downcast) to Rc<Any>, which can then be further
downcast into Rc<ConcreteType> where ConcreteType implements Trait.§fn as_any(&self) -> &(dyn Any + 'static)
fn as_any(&self) -> &(dyn Any + 'static)
&Trait (where Trait: Downcast) to &Any. This is needed since Rust cannot
generate &Any’s vtable from &Trait’s.§fn as_any_mut(&mut self) -> &mut (dyn Any + 'static)
fn as_any_mut(&mut self) -> &mut (dyn Any + 'static)
&mut Trait (where Trait: Downcast) to &Any. This is needed since Rust cannot
generate &mut Any’s vtable from &mut Trait’s.§impl<T> DowncastSend for T
impl<T> DowncastSend for T
§impl<T> DowncastSync for T
impl<T> DowncastSync for T
§impl<T> Instrument for T
impl<T> Instrument for T
§fn instrument(self, span: Span) -> Instrumented<Self>
fn instrument(self, span: Span) -> Instrumented<Self>
§fn in_current_span(self) -> Instrumented<Self>
fn in_current_span(self) -> Instrumented<Self>
§impl<T> IntoCollection<T> for T
impl<T> IntoCollection<T> for T
§fn into_collection<A>(self) -> SmallVec<A>where
A: Array<Item = T>,
fn into_collection<A>(self) -> SmallVec<A>where
A: Array<Item = T>,
self into a collection.fn mapped<U, F, A>(self, f: F) -> SmallVec<A>where
F: FnMut(T) -> U,
A: Array<Item = U>,
Source§impl<T> IntoEither for T
impl<T> IntoEither for T
Source§fn into_either(self, into_left: bool) -> Either<Self, Self>
fn into_either(self, into_left: bool) -> Either<Self, Self>
self into a Left variant of Either<Self, Self>
if into_left is true.
Converts self into a Right variant of Either<Self, Self>
otherwise. Read moreSource§fn into_either_with<F>(self, into_left: F) -> Either<Self, Self>
fn into_either_with<F>(self, into_left: F) -> Either<Self, Self>
self into a Left variant of Either<Self, Self>
if into_left(&self) returns true.
Converts self into a Right variant of Either<Self, Self>
otherwise. Read more§impl<T> IntoSql for T
impl<T> IntoSql for T
§impl<T> Paint for Twhere
T: ?Sized,
impl<T> Paint for Twhere
T: ?Sized,
§fn fg(&self, value: Color) -> Painted<&T>
fn fg(&self, value: Color) -> Painted<&T>
Returns a styled value derived from self with the foreground set to
value.
This method should be used rarely. Instead, prefer to use color-specific
builder methods like red() and
green(), which have the same functionality but are
pithier.
§Example
Set foreground color to white using fg():
use yansi::{Paint, Color};
painted.fg(Color::White);Set foreground color to white using white().
use yansi::Paint;
painted.white();§fn bright_black(&self) -> Painted<&T>
fn bright_black(&self) -> Painted<&T>
§fn bright_red(&self) -> Painted<&T>
fn bright_red(&self) -> Painted<&T>
§fn bright_green(&self) -> Painted<&T>
fn bright_green(&self) -> Painted<&T>
§fn bright_yellow(&self) -> Painted<&T>
fn bright_yellow(&self) -> Painted<&T>
§fn bright_blue(&self) -> Painted<&T>
fn bright_blue(&self) -> Painted<&T>
§fn bright_magenta(&self) -> Painted<&T>
fn bright_magenta(&self) -> Painted<&T>
§fn bright_cyan(&self) -> Painted<&T>
fn bright_cyan(&self) -> Painted<&T>
§fn bright_white(&self) -> Painted<&T>
fn bright_white(&self) -> Painted<&T>
§fn bg(&self, value: Color) -> Painted<&T>
fn bg(&self, value: Color) -> Painted<&T>
Returns a styled value derived from self with the background set to
value.
This method should be used rarely. Instead, prefer to use color-specific
builder methods like on_red() and
on_green(), which have the same functionality but
are pithier.
§Example
Set background color to red using fg():
use yansi::{Paint, Color};
painted.bg(Color::Red);Set background color to red using on_red().
use yansi::Paint;
painted.on_red();§fn on_primary(&self) -> Painted<&T>
fn on_primary(&self) -> Painted<&T>
§fn on_magenta(&self) -> Painted<&T>
fn on_magenta(&self) -> Painted<&T>
§fn on_bright_black(&self) -> Painted<&T>
fn on_bright_black(&self) -> Painted<&T>
§fn on_bright_red(&self) -> Painted<&T>
fn on_bright_red(&self) -> Painted<&T>
§fn on_bright_green(&self) -> Painted<&T>
fn on_bright_green(&self) -> Painted<&T>
§fn on_bright_yellow(&self) -> Painted<&T>
fn on_bright_yellow(&self) -> Painted<&T>
§fn on_bright_blue(&self) -> Painted<&T>
fn on_bright_blue(&self) -> Painted<&T>
§fn on_bright_magenta(&self) -> Painted<&T>
fn on_bright_magenta(&self) -> Painted<&T>
§fn on_bright_cyan(&self) -> Painted<&T>
fn on_bright_cyan(&self) -> Painted<&T>
§fn on_bright_white(&self) -> Painted<&T>
fn on_bright_white(&self) -> Painted<&T>
§fn attr(&self, value: Attribute) -> Painted<&T>
fn attr(&self, value: Attribute) -> Painted<&T>
Enables the styling [Attribute] value.
This method should be used rarely. Instead, prefer to use
attribute-specific builder methods like bold() and
underline(), which have the same functionality
but are pithier.
§Example
Make text bold using attr():
use yansi::{Paint, Attribute};
painted.attr(Attribute::Bold);Make text bold using using bold().
use yansi::Paint;
painted.bold();§fn rapid_blink(&self) -> Painted<&T>
fn rapid_blink(&self) -> Painted<&T>
§fn quirk(&self, value: Quirk) -> Painted<&T>
fn quirk(&self, value: Quirk) -> Painted<&T>
Enables the yansi [Quirk] value.
This method should be used rarely. Instead, prefer to use quirk-specific
builder methods like mask() and
wrap(), which have the same functionality but are
pithier.
§Example
Enable wrapping using .quirk():
use yansi::{Paint, Quirk};
painted.quirk(Quirk::Wrap);Enable wrapping using wrap().
use yansi::Paint;
painted.wrap();§fn clear(&self) -> Painted<&T>
👎Deprecated since 1.0.1: renamed to resetting() due to conflicts with Vec::clear().
The clear() method will be removed in a future release.
fn clear(&self) -> Painted<&T>
renamed to resetting() due to conflicts with Vec::clear().
The clear() method will be removed in a future release.
§fn whenever(&self, value: Condition) -> Painted<&T>
fn whenever(&self, value: Condition) -> Painted<&T>
Conditionally enable styling based on whether the [Condition] value
applies. Replaces any previous condition.
See the crate level docs for more details.
§Example
Enable styling painted only when both stdout and stderr are TTYs:
use yansi::{Paint, Condition};
painted.red().on_yellow().whenever(Condition::STDOUTERR_ARE_TTY);