Struct ThinkingLogStore 

pub struct ThinkingLogStore { /* private fields */ }

Manages thinking logs per agent, backed by JSONL files on disk.

Implementations

impl ThinkingLogStore

pub fn new() -> Self

pub async fn append(&self, entry: ThinkingLogEntry) -> Result<(), String>

Append a thinking log entry. Writes to disk (JSONL) and updates the in-memory cache.

pub async fn get_logs( &self, agent_id: &str, limit: usize, offset: usize, ) -> ThinkingLogPage

Get paginated thinking logs for an agent (newest first).

pub async fn get_detail( &self, agent_id: &str, index: usize, ) -> Option<ThinkingLogEntry>

Get a single log entry by agent_id and index (0 = newest).

pub async fn search( &self, agent_id: &str, query: &str, limit: usize, status_filter: Option<&ThinkingLogStatus>, ) -> Vec<ThinkingLogEntry>

Search thinking logs for an agent by a text query. Searches in market_summary, claude_reasoning, and decision.action.

pub async fn get_all_entries(&self, agent_id: &str) -> Vec<ThinkingLogEntry>

Get all entries for an agent (loading from disk if needed). Returns entries in chronological order (oldest first).

pub async fn get_cached_agent_ids(&self) -> Vec<String>

Get all known agent IDs from the cache. Note: only returns IDs for agents that have been loaded into cache.

pub async fn filter_by_status( &self, agent_id: &str, status: &ThinkingLogStatus, limit: usize, offset: usize, ) -> ThinkingLogPage

Filter logs by status.