Struct LibsqlTraceStorage 

pub struct LibsqlTraceStorage { /* private fields */ }

libsql-based trace storage.

Implementations

impl LibsqlTraceStorage

pub async fn new( config: StorageConfig, ) -> Result<LibsqlTraceStorage, TracingError>

Create storage from a configuration.

pub async fn new_memory() -> Result<LibsqlTraceStorage, TracingError>

Create an in-memory storage.

pub async fn new_file(path: &str) -> Result<LibsqlTraceStorage, TracingError>

Create a file-based storage.

Trait Implementations

impl TraceStorage for LibsqlTraceStorage

fn initialize<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<(), TracingError>> + Send + 'async_trait>>

where 'life0: 'async_trait, LibsqlTraceStorage: 'async_trait,

Initialize the storage backend (create tables, etc.).

fn close<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<(), TracingError>> + Send + 'async_trait>>

where 'life0: 'async_trait, LibsqlTraceStorage: 'async_trait,

Close the storage connection.

fn ensure_session<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, session_id: &'life1 str, created_at: DateTime<Utc>, metadata: &'life2 Value, ) -> Pin<Box<dyn Future<Output = Result<(), TracingError>> + Send + 'async_trait>>

where 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait, LibsqlTraceStorage: 'async_trait,

Ensure a session exists (create if not present).

fn get_session<'life0, 'life1, 'async_trait>( &'life0 self, session_id: &'life1 str, ) -> Pin<Box<dyn Future<Output = Result<Option<SessionTrace>, TracingError>> + Send + 'async_trait>>

where 'life0: 'async_trait, 'life1: 'async_trait, LibsqlTraceStorage: 'async_trait,

Get a session trace by ID.

fn delete_session<'life0, 'life1, 'async_trait>( &'life0 self, session_id: &'life1 str, ) -> Pin<Box<dyn Future<Output = Result<bool, TracingError>> + Send + 'async_trait>>

where 'life0: 'async_trait, 'life1: 'async_trait, LibsqlTraceStorage: 'async_trait,

Delete a session and all related data.

fn ensure_timestep<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, session_id: &'life1 str, step: &'life2 SessionTimeStep, ) -> Pin<Box<dyn Future<Output = Result<i64, TracingError>> + Send + 'async_trait>>

where 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait, LibsqlTraceStorage: 'async_trait,

Ensure a timestep exists and return its database ID.

fn update_timestep<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, session_id: &'life1 str, step_id: &'life2 str, completed_at: Option<DateTime<Utc>>, ) -> Pin<Box<dyn Future<Output = Result<(), TracingError>> + Send + 'async_trait>>

where 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait, LibsqlTraceStorage: 'async_trait,

Update a timestep (e.g., mark as completed).

fn insert_event<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, session_id: &'life1 str, timestep_db_id: Option<i64>, event: &'life2 TracingEvent, ) -> Pin<Box<dyn Future<Output = Result<i64, TracingError>> + Send + 'async_trait>>

where 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait, LibsqlTraceStorage: 'async_trait,

Insert an event and return its database ID.

fn insert_message<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, session_id: &'life1 str, timestep_db_id: Option<i64>, msg: &'life2 MarkovBlanketMessage, ) -> Pin<Box<dyn Future<Output = Result<i64, TracingError>> + Send + 'async_trait>>

where 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait, LibsqlTraceStorage: 'async_trait,

Insert a message and return its database ID.

fn insert_outcome_reward<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, session_id: &'life1 str, reward: &'life2 OutcomeReward, ) -> Pin<Box<dyn Future<Output = Result<i64, TracingError>> + Send + 'async_trait>>

where 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait, LibsqlTraceStorage: 'async_trait,

Insert an outcome (session-level) reward.

fn insert_event_reward<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, session_id: &'life1 str, event_id: i64, message_id: Option<i64>, turn_number: Option<i32>, reward: &'life2 EventReward, ) -> Pin<Box<dyn Future<Output = Result<i64, TracingError>> + Send + 'async_trait>>

where 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait, LibsqlTraceStorage: 'async_trait,

Insert an event-level reward.

fn query<'life0, 'life1, 'async_trait>( &'life0 self, sql: &'life1 str, params: QueryParams, ) -> Pin<Box<dyn Future<Output = Result<Vec<Value>, TracingError>> + Send + 'async_trait>>

where 'life0: 'async_trait, 'life1: 'async_trait, LibsqlTraceStorage: 'async_trait,

Execute a raw SQL query and return results as JSON values.

fn update_session_counts<'life0, 'life1, 'async_trait>( &'life0 self, session_id: &'life1 str, ) -> Pin<Box<dyn Future<Output = Result<(), TracingError>> + Send + 'async_trait>>

where 'life0: 'async_trait, 'life1: 'async_trait, LibsqlTraceStorage: 'async_trait,

Update session counts (num_timesteps, num_events, num_messages).