Enum StreamMessage 

pub enum StreamMessage {
    Content {
        content: String,
        source: Option<String>,
        timestamp: Option<DateTime<Utc>>,
        importance: Option<f32>,
        tags: Vec<String>,
        metadata: HashMap<String, Value>,
    },
    Sensor {
        sensor_id: String,
        values: HashMap<String, f64>,
        timestamp: Option<DateTime<Utc>>,
        units: HashMap<String, String>,
    },
    Event {
        event: String,
        description: String,
        timestamp: Option<DateTime<Utc>>,
        severity: Option<String>,
        data: HashMap<String, Value>,
    },
    Flush,
    Ping,
    Close,
}

Incoming stream message types

Variants

Content

Text content for memory extraction

Fields

content: String

The actual content

source: Option<String>

Optional message source (e.g., “user”, “assistant”, “system”)

timestamp: Option<DateTime<Utc>>

Optional timestamp (defaults to now)

importance: Option<f32>

Optional explicit importance override

tags: Vec<String>

Optional tags

metadata: HashMap<String, Value>

Additional metadata

Sensor

Sensor reading (for robotics/IoT)

Fields

sensor_id: String

Sensor identifier

values: HashMap<String, f64>

Sensor value(s)

timestamp: Option<DateTime<Utc>>

Optional timestamp

units: HashMap<String, String>

Optional unit labels

Event

Discrete event

Fields

event: String

Event name/type

description: String

Event description/details

timestamp: Option<DateTime<Utc>>

Optional timestamp

severity: Option<String>

Event severity (info, warning, error)

data: HashMap<String, Value>

Additional event data

Flush

Manual flush trigger

Ping

Ping/keepalive

Close

Close stream gracefully

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

Formats the value using the given formatter.

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

fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::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::Ok, __S::Error>

where __S: Serializer,

Serialize this value into the given Serde serializer.