zagens-runtime-orchestrator 0.8.0

Runtime thread/turn persist layer for Zagens sidecar (D16 E1-b)
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23

//! Turn execution port for background tasks (D16 E1-b phase 5).

use anyhow::Result;
use async_trait::async_trait;

use super::types::{RuntimeEventRecord, ThreadRecord, TurnRecord};
use super::{CreateThreadRequest, StartTurnRequest};

/// Minimal runtime surface for durable background task workers.
#[async_trait]
pub trait RuntimeThreadTaskPort: Send + Sync {
    async fn create_thread(&self, req: CreateThreadRequest) -> Result<ThreadRecord>;

    async fn start_turn(&self, thread_id: &str, req: StartTurnRequest) -> Result<TurnRecord>;

    async fn interrupt_turn(&self, thread_id: &str, turn_id: &str) -> Result<TurnRecord>;

    async fn events_since_async(
        &self,
        thread_id: &str,
        since_seq: Option<u64>,
    ) -> Result<Vec<RuntimeEventRecord>>;
}