Enum WriterItem 

pub enum WriterItem<'a> {
    Row(RowValue<'a>),
    Usage {
        agent_instance_hierarchy: &'a str,
        total_tokens: u64,
    },
    Error {
        agent_instance_hierarchy: &'a str,
        response_id: &'a str,
        error: &'a ResponseError,
    },
}

One item from a top-level chunk walk: either a streaming-content RowValue or a per-AIH agent-completion token-usage snapshot. Usage rides the SAME single traversal as the content rows — the walk already descends into every nested agent completion, so the writer never re-walks the chunk tree for usage.

Variants

Row(RowValue<'a>)

Usage

Fields

agent_instance_hierarchy: &'a str

total_tokens: u64

Error

An in-band completion error: the agent completion ITSELF carries error (an upstream/API failure delivered as part of the response, not a transport failure). The writer persists it as an error log row — once per (aih, response_id); the cumulative accumulator re-yields it every tick.

Fields

agent_instance_hierarchy: &'a str

response_id: &'a str

error: &'a ResponseError

Trait Implementations

impl<'a> Debug for WriterItem<'a>

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

Formats the value using the given formatter.