Struct SessionStore 

pub struct SessionStore { /* private fields */ }

Implementations

impl SessionStore

pub fn ephemeral() -> SessionStore

pub fn open(path: &Path) -> Result<SessionStore, DaemonError>

pub fn create( &mut self, parent: Option<u64>, params: GenParams, ) -> Result<u64, DaemonError>

pub fn fork( &mut self, parent: u64, fork_at: u64, params: Option<GenParams>, ) -> Result<u64, DaemonError>

pub fn append( &mut self, session: u64, text: Option<String>, span: Vec<u32>, ) -> Result<CommittedEvent, DaemonError>

pub fn append_message( &mut self, session: u64, role: u32, text: String, span: Vec<u32>, ) -> Result<CommittedEvent, DaemonError>

pub fn commit_generation_prompt( &mut self, session: u64, span: Vec<u32>, ) -> Result<CommittedEvent, DaemonError>

pub fn commit_tool_use( &mut self, session: u64, name: String, arguments: String, ) -> Result<CommittedEvent, DaemonError>

pub fn commit_tool_result( &mut self, session: u64, call_id: u64, content: String, span: Vec<u32>, ) -> Result<CommittedEvent, DaemonError>

pub fn commit_generated( &mut self, session: u64, span: Vec<u32>, text: String, channel: u32, finish: u32, ) -> Result<CommittedEvent, DaemonError>

pub fn commit_generation_fingerprint( &mut self, session: u64, digest: u64, ) -> Result<Option<CommittedEvent>, DaemonError>

pub fn commit_tool_parse_failure( &mut self, session: u64, raw: String, ) -> Result<CommittedEvent, DaemonError>

pub fn store_id(&self) -> StoreId

pub fn wal_version(&self) -> u8

pub fn bus(&self) -> Arc<SessionBus>

pub fn session(&self, id: u64) -> Result<&SessionState, DaemonError>

pub fn tombstone(&self, id: u64) -> Option<&SessionState>

pub fn read( &self, id: u64, cursor: u64, ) -> Result<&[CommittedEvent], DaemonError>

pub fn drop_session(&mut self, id: u64) -> Result<(), DaemonError>

pub fn session_ids(&self) -> Vec<u64>

pub fn set_meta( &mut self, session: u64, expected_version: u64, title: Option<String>, archived: Option<bool>, ) -> Result<u64, DaemonError>

pub fn set_pin( &mut self, session: u64, deadline_unix_ms: u64, ) -> Result<CommittedEvent, DaemonError>

pub fn set_qos( &mut self, session: u64, class: u8, batch_invariant: bool, ) -> Result<CommittedEvent, DaemonError>

pub fn rebase_branch( &mut self, parent: u64, fork_at: u64, params: Option<GenParams>, edits: Vec<RebaseEdit>, ) -> Result<u64, DaemonError>

pub fn commit_block( &mut self, session: u64, role: u32, kind: u32, payload: String, span: Vec<u32>, visibility_version: u32, ) -> Result<CommittedEvent, DaemonError>

pub fn commit_permission_request( &mut self, session: u64, call_id: u64, text: String, ) -> Result<CommittedEvent, DaemonError>

pub fn commit_permission_response( &mut self, session: u64, request_id: u64, granted: bool, ) -> Result<CommittedEvent, DaemonError>

pub fn commit_tool_cancel_request( &mut self, session: u64, call_id: u64, ) -> Result<CommittedEvent, DaemonError>

pub fn commit_tool_outcome( &mut self, session: u64, call_id: u64, outcome: u8, note: String, ) -> Result<CommittedEvent, DaemonError>

pub fn commit_tool_reconciliation( &mut self, session: u64, call_id: u64, note: String, ) -> Result<CommittedEvent, DaemonError>

pub fn commit_tool_lease( &mut self, session: u64, call_id: u64, deadline_unix_ms: u64, ) -> Result<CommittedEvent, DaemonError>

pub fn expire_tool_call( &mut self, session: u64, call_id: u64, reason: &str, ) -> Result<CommittedEvent, DaemonError>

pub fn children_of(&self, session: u64) -> Vec<u64>

pub fn descendants_of(&self, session: u64) -> Vec<u64>

pub fn purge( &mut self, session: u64, expected_generation: u64, mode: PurgeMode, ) -> Result<Vec<u64>, DaemonError>