Struct FrameMapper 

pub struct FrameMapper { /* private fields */ }

The writer’s row→event mapper. STATEFUL: head rows (the tool_response / request_message_tool / request_vector_choice metadata carriers) produce NO frame — they feed the maps below, and their payload rides every subsequent content event of their block (tool_call_id on the event’s boundary fields; the choice’s voting key per part). The writer emits each head strictly before its contents, so a lookup miss means a torn iterator — that content frame is skipped (reconnecting clients replay DB truth).

Implementations

impl FrameMapper

pub fn map(&mut self, value: &RowValue<'_>, created_at: i64) -> Option<TeeFrame>

Map one row the writer is about to write into its typed event frame. created_at is the same timestamp the SQL will bind. None for head rows (memory only) and for content rows whose head never registered.

Trait Implementations

impl Default for FrameMapper

fn default() -> FrameMapper

Returns the “default value” for a type.