stasis-rs 0.2.0

Durable AI orchestration framework with runtime jobs, lineage, and memory integration
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23

use async_trait::async_trait;
use chrono::{DateTime, Utc};

use crate::domain::errors::Result;
use crate::domain::runtime::thread::{
    NewThread, NewThreadEvent, ThreadEvent, ThreadSnapshot,
};

#[async_trait]
pub trait ThreadStore: Send + Sync {
    async fn create_thread(&self, thread: NewThread) -> Result<ThreadSnapshot>;
    async fn get_thread(&self, thread_id: &str) -> Result<Option<ThreadSnapshot>>;
    async fn append_event(&self, event: NewThreadEvent) -> Result<ThreadEvent>;
    async fn list_events(&self, thread_id: &str) -> Result<Vec<ThreadEvent>>;
    async fn fork_thread(
        &self,
        parent_thread_id: &str,
        child_thread_id: &str,
        branch_label: Option<String>,
        created_at: DateTime<Utc>,
    ) -> Result<ThreadSnapshot>;
    async fn list_lineage(&self, thread_id: &str) -> Result<Vec<ThreadSnapshot>>;
}