Struct ResponsesContinuationStore 

pub struct ResponsesContinuationStore { /* private fields */ }

Session-scoped store of provider continuation chains.

One owner for the chain key, response-id, and history semantics so the interactive runloop and the headless runner cannot drift apart.

Implementations

impl ResponsesContinuationStore

pub fn get( &self, provider: &str, model: &str, ) -> Option<&ResponsesContinuationState>

The recorded chain for a provider and model, if any.

pub fn set( &mut self, provider: &str, model: &str, response_id: Option<&str>, messages: Arc<Vec<Message>>, )

Record a chain, or drop the existing one when the response id is empty.

pub fn clear_for(&mut self, provider: &str, model: &str)

Drop the chain recorded for one provider and model.

pub fn clear(&mut self)

Drop every recorded chain.

pub fn is_empty(&self) -> bool

Whether no chain is recorded.

pub fn prepare_request_messages<'a>( &mut self, provider_name: &str, provider_supports_responses_compaction: bool, model: &str, messages: &'a [Message], ) -> (Cow<'a, [Message]>, Option<String>)

Prepare request messages for a continuation-aware provider.

A stale chain that the provider rejects is dropped here so the next request starts from the full history.

Trait Implementations

impl Clone for ResponsesContinuationStore

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for ResponsesContinuationStore

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

Formats the value using the given formatter.

impl Default for ResponsesContinuationStore

fn default() -> Self

Returns the “default value” for a type.