Enum StreamEvent 

pub enum StreamEvent {
    Values {
        ns: Vec<String>,
        data: Value,
        interrupts: Vec<Interrupt>,
    },
    Updates {
        ns: Vec<String>,
        data: Value,
        node: String,
    },
    Checkpoint {
        ns: Vec<String>,
        checkpoint_id: String,
        step: usize,
    },
    TaskStart {
        task_id: String,
        node: String,
    },
    TaskEnd {
        task_id: String,
        node: String,
        result: Value,
    },
    Debug {
        message: String,
        context: HashMap<String, Value>,
    },
    Message {
        content: String,
        metadata: HashMap<String, Value>,
    },
    Custom {
        event_type: String,
        data: Value,
    },
}

An event emitted during graph streaming execution.

Stream events provide visibility into graph execution, allowing applications to react to intermediate states, debug issues, or provide real-time feedback.

Variants

Values

The full state values at a point in execution

Fields

ns: Vec<String>

Namespace (for subgraphs)

data: Value

The state data

interrupts: Vec<Interrupt>

Any interrupts that occurred

Updates

State updates (deltas) from a step

Fields

ns: Vec<String>

Namespace

data: Value

The update data

node: String

Node that produced the update

Checkpoint

Checkpoint saved

Fields

ns: Vec<String>

Namespace

checkpoint_id: String

Checkpoint ID

step: usize

Step number

TaskStart

Task execution started

Fields

task_id: String

Task ID

node: String

Node name

TaskEnd

Task execution completed

Fields

task_id: String

Task ID

node: String

Node name

result: Value

Result data

Debug

Debug information

Fields

message: String

Debug message

context: HashMap<String, Value>

Additional context

Message

A message (for chat applications)

Fields

content: String

The message content

metadata: HashMap<String, Value>

Message metadata

Custom

Custom event

Fields

event_type: String

Event type

data: Value

Event data

Trait Implementations

impl Clone for StreamEvent

fn clone(&self) -> StreamEvent

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for StreamEvent

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

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for StreamEvent

fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Serialize for StreamEvent

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

where __S: Serializer,

Serialize this value into the given Serde serializer.