Enum st2_logformat::ActivityType

pub enum ActivityType {
    Scheduling,
    Processing,
    Spinning,
    Serialization,
    Deserialization,
    ControlMessage,
    DataMessage,
    Waiting,
    Busy,
}

The various types of activity that can happen in a dataflow. Unknown et al. shouldn't be emitted by instrumentation. Instead, they might be inserted as helpers during PAG construction.

Variants

Scheduling

Operator scheduled. Used as temporary state for LogRecords where it's still unclear whether they were only spinning or also did some work

Processing

Operator actually doing work

Spinning

Operator scheduled, but not doing any work

Serialization

Data serialization

Deserialization

Data deserialization

ControlMessage

remote control messages, e.g. about progress

DataMessage

remote data messages, e.g. moving tuples around

Waiting

Waiting for unblocking. In particular, operator might wait for external input. (not emitted by profiling)

Busy

Waiting where next activity is actively prepared, e.g. in-between a ScheduleEnd and consecutive ScheduleStart. In particular, operator doesn't depend on external input. (not emitted by profiling)

Trait Implementations

impl Clone for ActivityType

fn clone(&self) -> ActivityType

Returns a copy of the value.

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

Performs copy-assignment from source.

impl Ord for ActivityType

fn cmp(&self, other: &ActivityType) -> Ordering

This method returns an Ordering between self and other.

fn max(self, other: Self) -> Self

Compares and returns the maximum of two values.

fn min(self, other: Self) -> Self

Compares and returns the minimum of two values.

fn clamp(self, min: Self, max: Self) -> Self

🔬 This is a nightly-only experimental API. (clamp)

Restrict a value to a certain interval.

impl PartialOrd<ActivityType> for ActivityType

fn partial_cmp(&self, other: &ActivityType) -> Option<Ordering>

This method returns an ordering between self and other values if one exists.

#[must_use] fn lt(&self, other: &Rhs) -> bool

This method tests less than (for self and other) and is used by the < operator.

#[must_use] fn le(&self, other: &Rhs) -> bool

This method tests less than or equal to (for self and other) and is used by the <= operator.

#[must_use] fn gt(&self, other: &Rhs) -> bool

This method tests greater than (for self and other) and is used by the > operator.

#[must_use] fn ge(&self, other: &Rhs) -> bool

This method tests greater than or equal to (for self and other) and is used by the >= operator.

impl PartialEq<ActivityType> for ActivityType

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

This method tests for self and other values to be equal, and is used by ==.

#[must_use] fn ne(&self, other: &Rhs) -> bool

This method tests for !=.

impl Copy for ActivityType

impl Eq for ActivityType

impl Debug for ActivityType

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

Formats the value using the given formatter.

impl Hash for ActivityType

fn hash<__H: Hasher>(&self, state: &mut __H)

Feeds this value into the given [Hasher].

fn hash_slice<H>(data: &[Self], state: &mut H) where
    H: Hasher, 

Feeds a slice of this type into the given [Hasher].

impl Abomonation for ActivityType

unsafe fn entomb<W: Write>(&self, _write: &mut W) -> Result<()>

Write any additional information about &self beyond its binary representation.

fn extent(&self) -> usize

Reports the number of further bytes required to entomb self.

unsafe fn exhume<'a, 'b>(
    &'a mut self,
    bytes: &'b mut [u8]
) -> Option<&'b mut [u8]>

Recover any information for &mut self not evident from its binary representation.