Struct TaskOutput 

pub struct TaskOutput<T> {
    pub value: T,
    pub metrics: Vec<(String, f64)>,
}

The output of firing a task, including named metrics for pattern detection.

Fields

value: T

The primary output value.

metrics: Vec<(String, f64)>

Named metrics extracted during firing, used by pattern detectors.

Implementations

impl<T> TaskOutput<T>

pub fn new(value: T, metrics: Vec<(String, f64)>) -> Self

Create a new task output with a value and metrics.

Examples found in repository

examples/basic.rs (lines 14-21)

    fn fire(&self) -> TaskOutput<Self::Output> {
        TaskOutput::new(
            self.value,
            vec![
                ("value".into(), self.value),
                ("abs".into(), self.value.abs()),
                ("squared".into(), self.value * self.value),
            ],
        )
    }

examples/ci_patterns.rs (lines 15-22)

    fn fire(&self) -> TaskOutput<Self::Output> {
        TaskOutput::new(
            self.duration_secs,
            vec![
                ("duration".into(), self.duration_secs),
                ("test_count".into(), self.test_count),
                ("duration_per_test".into(), self.duration_secs / self.test_count.max(1.0)),
            ],
        )
    }

examples/api_monitoring.rs (lines 16-24)

    fn fire(&self) -> TaskOutput<Self::Output> {
        TaskOutput::new(
            self.latency_ms,
            vec![
                ("latency_ms".into(), self.latency_ms),
                ("response_bytes".into(), self.response_bytes),
                ("is_error".into(), if self.status >= 400 { 1.0 } else { 0.0 }),
                ("is_slow".into(), if self.latency_ms > 200.0 { 1.0 } else { 0.0 }),
            ],
        )
    }

examples/event_stream_processor.rs (lines 32-48)

    fn fire(&self) -> TaskOutput<Self::Output> {
        TaskOutput::new(
            self.processing_time_ms,
            vec![
                ("processing_time_ms".into(),     self.processing_time_ms),
                ("throughput".into(),              self.throughput),
                ("memory_mb".into(),               self.memory_mb),
                ("error_rate".into(),              self.error_rate),
                ("records_in".into(),              self.records_in),
                ("records_out".into(),             self.records_out),
                ("cpu_temp_c".into(),              self.cpu_temp_c),
                ("latency_p99_ms".into(),          self.latency_p99_ms),
                ("consumer_lag".into(),            self.consumer_lag),
                ("gc_pause_ms".into(),             self.gc_pause_ms),
                ("event_id".into(),                self.event_id as f64),
                ("batch_id".into(),                self.batch_id as f64),
            ],
        )
    }

pub fn simple(value: T) -> Self

Create a task output with no metrics.

pub fn with_metric(self, name: impl Into<String>, value: f64) -> Self

Add a named metric.

Trait Implementations

impl<T: Clone> Clone for TaskOutput<T>

fn clone(&self) -> TaskOutput<T>

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl<T: Debug> Debug for TaskOutput<T>

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

Formats the value using the given formatter.