Struct ThreadHistoryBuilder 

pub struct ThreadHistoryBuilder { /* private fields */ }

Implementations

impl ThreadHistoryBuilder

pub fn new() -> Self

pub fn reset(&mut self)

pub fn finish(self) -> Vec<Turn>

pub fn active_turn_snapshot(&self) -> Option<Turn>

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

Returns the id of the active turn without materializing its items.

pub fn turn_snapshot(&self, turn_id: &str) -> Option<Turn>

pub fn active_turn_position(&self) -> Option<usize>

Returns the index of the active turn snapshot within the finished turn list.

When a turn is still open, this is the index it will occupy after finish. When no turn is open, it is the index of the last finished turn.

pub fn has_active_turn(&self) -> bool

pub fn active_turn_id_if_explicit(&self) -> Option<String>

pub fn active_turn_start_index(&self) -> Option<usize>

pub fn handle_event(&mut self, event: &EventMsg)

Shared reducer for persisted rollout replay and in-memory current-turn tracking used by running thread resume/rejoin.

This function should handle all EventMsg variants that can be persisted in a rollout file. See should_persist_event_msg in codex-rs/core/rollout/policy.rs.

pub fn handle_rollout_item(&mut self, item: &RolloutItem)

pub fn handle_event_with_changes( &mut self, event: &EventMsg, ) -> ThreadHistoryChangeSet

Handles one event and returns the materialized items or turn metadata changed by that event.

pub fn handle_rollout_item_with_changes( &mut self, item: &RolloutItem, ) -> ThreadHistoryChangeSet

Handles a rollout item and returns the materialized items or turn metadata changed by that one append.

pub fn handle_rollout_items_with_changes( &mut self, items: &[RolloutItem], ) -> ThreadHistoryChangeSet

Handles rollout items in order and returns a coalesced end-of-batch change set. Multiple changes to the same item or turn are deduplicated so only the latest snapshot is emitted.

Trait Implementations

impl Default for ThreadHistoryBuilder

fn default() -> Self

Returns the “default value” for a type.