Struct StreamMessage 

pub struct StreamMessage {
    pub stream_type: StreamType,
    pub timestamp: String,
    pub job_id: String,
    pub data: Value,
    pub seq: Option<i64>,
    pub step: Option<i64>,
    pub phase: Option<String>,
    pub event_type: Option<String>,
    pub level: Option<String>,
}

A message from a job stream.

Fields

stream_type: StreamType

Type of stream this message came from.

timestamp: String

ISO 8601 timestamp.

job_id: String

Job ID this message belongs to.

data: Value

Message payload.

seq: Option<i64>

Sequence number (for events).

step: Option<i64>

Step/iteration number (for metrics).

phase: Option<String>

Phase name (for timeline).

event_type: Option<String>

Event type string (for events).

level: Option<String>

Log level (for events).

Implementations

impl StreamMessage

pub fn new( stream_type: StreamType, job_id: impl Into<String>, data: Value, ) -> StreamMessage

Create a new stream message.

pub fn status(job_id: impl Into<String>, data: Value) -> StreamMessage

Create a status message.

pub fn event(job_id: impl Into<String>, data: Value, seq: i64) -> StreamMessage

Create an event message.

pub fn metrics( job_id: impl Into<String>, data: Value, step: i64, ) -> StreamMessage

Create a metrics message.

pub fn timeline( job_id: impl Into<String>, phase: impl Into<String>, data: Value, ) -> StreamMessage

Create a timeline message.

pub fn key(&self) -> String

Generate a unique key for deduplication.

pub fn is_error(&self) -> bool

Check if this is an error event.

pub fn is_warning(&self) -> bool

Check if this is a warning event.

pub fn message(&self) -> Option<&str>

Get the message text if present.

pub fn get(&self, key: &str) -> Option<&Value>

Get a field from the data payload.

pub fn get_str(&self, key: &str) -> Option<&str>

Get a string field from the data payload.

pub fn get_i64(&self, key: &str) -> Option<i64>

Get an i64 field from the data payload.

pub fn get_f64(&self, key: &str) -> Option<f64>

Get an f64 field from the data payload.

Trait Implementations

impl Clone for StreamMessage

fn clone(&self) -> StreamMessage

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for StreamMessage

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

Formats the value using the given formatter.

impl Default for StreamMessage

fn default() -> StreamMessage

Returns the “default value” for a type.

impl<'de> Deserialize<'de> for StreamMessage

fn deserialize<__D>( __deserializer: __D, ) -> Result<StreamMessage, <__D as Deserializer<'de>>::Error>

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Serialize for StreamMessage

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

where __S: Serializer,

Serialize this value into the given Serde serializer.