Struct StreamCheckpoint 

pub struct StreamCheckpoint {
    pub run_id: String,
    pub thread_id: String,
    pub upstream_model: String,
    pub partial_text: String,
    pub completed_tool_calls: Vec<ToolCall>,
    pub in_flight_tool: Option<InFlightTool>,
    pub updated_at_ms: u64,
}

A persisted snapshot of in-flight stream accumulator state for a run.

Fields

run_id: String

Identifier of the run this checkpoint belongs to. Uniquely keys the checkpoint in storage.

thread_id: String

Identifier of the containing thread. Carried for operator inspection and for scoped bulk deletion (per-thread cleanup).

upstream_model: String

Upstream model the interrupted attempt targeted.

partial_text: String

Text content accumulated before interruption.

completed_tool_calls: Vec<ToolCall>

Tool calls whose arguments parsed cleanly before interruption. On resume these are replayed as completed; the model does not re-emit them.

in_flight_tool: Option<InFlightTool>

The open tool whose arguments had not finished arriving. Used to surface a cancelled-tool hint on resume, same as R2.

updated_at_ms: u64

Wall-clock millis when the writer last updated the checkpoint. Used to bound staleness on read.

Trait Implementations

impl Clone for StreamCheckpoint

fn clone(&self) -> StreamCheckpoint

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for StreamCheckpoint

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

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for StreamCheckpoint

fn deserialize<__D>( __deserializer: __D, ) -> Result<StreamCheckpoint, <__D as Deserializer<'de>>::Error>

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Serialize for StreamCheckpoint

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

where __S: Serializer,

Serialize this value into the given Serde serializer.