Struct YoAgentStateAdapter 

pub struct YoAgentStateAdapter<S: EventStore> { /* private fields */ }

Implementations

impl<S: EventStore> YoAgentStateAdapter<S>

pub fn new(state: YoAgentState<S>, actor: ActorRef) -> Self

Examples found in repository

examples/yoagent_integration.rs (line 11)

async fn main() -> Result<(), Box<dyn std::error::Error>> {
    let state = YoAgentState::load(MemoryEventStore::new()).await?;
    let sink = YoAgentStateAdapter::new(state.clone(), ActorRef::agent("yoagent"));
    let run_id = RunId::new("run_demo");

    sink.on_run_started(YoAgentRunStarted {
        run_id: run_id.clone(),
        task: "Investigate retry timeout".to_string(),
        metadata: json!({}),
    })
    .await?;
    sink.on_model_called(YoAgentModelCalled {
        run_id: run_id.clone(),
        model: "example-model".to_string(),
        prompt_summary: "Find likely retry failure cause".to_string(),
    })
    .await?;
    sink.on_model_finished(YoAgentModelFinished {
        run_id: run_id.clone(),
        model: "example-model".to_string(),
        output_summary: "Retry state appears scoped too narrowly".to_string(),
    })
    .await?;
    sink.on_tool_called(YoAgentToolCalled {
        run_id: run_id.clone(),
        tool: "cargo test".to_string(),
        input_summary: "tool_retry_survives_timeout".to_string(),
    })
    .await?;
    sink.on_tool_finished(YoAgentToolFinished {
        run_id: run_id.clone(),
        tool: "cargo test".to_string(),
        output_summary: "test passed".to_string(),
        success: true,
    })
    .await?;
    sink.on_run_finished(YoAgentRunFinished {
        run_id,
        outcome: "patch ready for review".to_string(),
        metadata: json!({}),
    })
    .await?;

    println!(
        "{}",
        serde_json::to_string_pretty(&state.store().scan().await?)?
    );
    Ok(())
}

Trait Implementations

impl<S: Clone + EventStore> Clone for YoAgentStateAdapter<S>

fn clone(&self) -> YoAgentStateAdapter<S>

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl<S: Debug + EventStore> Debug for YoAgentStateAdapter<S>

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

Formats the value using the given formatter.

impl<S: EventStore> YoAgentStateSink for YoAgentStateAdapter<S>

fn on_run_started<'life0, 'async_trait>( &'life0 self, event: YoAgentRunStarted, ) -> Pin<Box<dyn Future<Output = Result<EventId, StateError>> + Send + 'async_trait>>

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

fn on_run_finished<'life0, 'async_trait>( &'life0 self, event: YoAgentRunFinished, ) -> Pin<Box<dyn Future<Output = Result<EventId, StateError>> + Send + 'async_trait>>

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

fn on_model_called<'life0, 'async_trait>( &'life0 self, event: YoAgentModelCalled, ) -> Pin<Box<dyn Future<Output = Result<EventId, StateError>> + Send + 'async_trait>>

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

fn on_model_finished<'life0, 'async_trait>( &'life0 self, event: YoAgentModelFinished, ) -> Pin<Box<dyn Future<Output = Result<EventId, StateError>> + Send + 'async_trait>>

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

fn on_tool_called<'life0, 'async_trait>( &'life0 self, event: YoAgentToolCalled, ) -> Pin<Box<dyn Future<Output = Result<EventId, StateError>> + Send + 'async_trait>>

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

fn on_tool_finished<'life0, 'async_trait>( &'life0 self, event: YoAgentToolFinished, ) -> Pin<Box<dyn Future<Output = Result<EventId, StateError>> + Send + 'async_trait>>

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