Struct ReplayProvider 

pub struct ReplayProvider { /* private fields */ }

An InferenceClient that returns recorded completions in order.

Implementations

impl ReplayProvider

pub fn from_steps(run: impl Into<String>, steps: Vec<StepRecord>) -> Self

Build a replay provider from recorded steps (ordered ascending by super_step). The provider discriminant is taken from the first recorded inference (defaulting to OpenAI if none is present — irrelevant for replay since no parsing of live deltas occurs).

pub async fn load( store: &dyn StepRecordStore, workflow: &WorkflowId, run: &RunId, ) -> Result<Self>

Load recorded steps for a run from a StepRecordStore.

pub fn remaining(&self) -> usize

Number of recorded steps remaining to replay.

Trait Implementations

impl InferenceClient for ReplayProvider

fn provider(&self) -> Provider

fn run<'life0, 'async_trait>( &'life0 self, _batch: ExecuteBatch, ) -> Pin<Box<dyn Future<Output = Result<TurnResult>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,