Struct TaskStore 

pub struct TaskStore { /* private fields */ }

Implementations

impl TaskStore

pub async fn open(path: &Path) -> Result<Self, StoreError>

Open (or create) the per-camp task-runs database at path.

pub async fn insert_run(&self, meta: &TaskRunMeta) -> Result<(), StoreError>

pub async fn update_beholder_status( &self, id: &TaskRunId, status: &BeholderStatus, ) -> Result<(), StoreError>

pub async fn update_status( &self, id: &TaskRunId, status: &RunStatus, ) -> Result<(), StoreError>

pub async fn append_chunk( &self, run_id: &TaskRunId, offset_ms: u32, stream: Stream, bytes: &[u8], ) -> Result<u32, StoreError>

Append an output chunk. Returns the assigned seq number.

pub async fn get_run( &self, id: &TaskRunId, ) -> Result<Option<TaskRunMeta>, StoreError>

pub async fn chunk_count(&self, run_id: &TaskRunId) -> Result<u32, StoreError>

pub async fn list_runs( &self, filter: &RunFilter, ) -> Result<Vec<TaskRunMeta>, StoreError>

pub async fn archive_run(&self, id: &TaskRunId) -> Result<(), StoreError>

pub async fn pin_run( &self, id: &TaskRunId, pinned: bool, ) -> Result<(), StoreError>

pub async fn gc_sweep(&self, config: &GcConfig) -> Result<GcResult, StoreError>

pub async fn get_chunks( &self, run_id: &TaskRunId, filter: &ChunkFilter, ) -> Result<Vec<OutputChunk>, StoreError>

pub async fn append_event( &self, run_id: &TaskRunId, offset_ms: u32, level: Level, target: &str, msg: &str, fields: &Value, anchor_seq: Option<u32>, source: &EventSource, ) -> Result<u32, StoreError>

pub async fn query_events( &self, run_id: &TaskRunId, filter: &EventFilter, ) -> Result<Vec<Event>, StoreError>

pub async fn event_count( &self, run_id: &TaskRunId, min_level: Option<Level>, ) -> Result<u64, StoreError>

pub async fn query_diagnostics( &self, run_id: &TaskRunId, ) -> Result<Vec<Diagnostic>, StoreError>

pub async fn ensure_field_index( &self, field_path: &str, ) -> Result<(), StoreError>

pub async fn timeline_ticks( &self, run_id: &TaskRunId, since_offset_ms: Option<u32>, limit: Option<usize>, ) -> Result<Vec<TimelineTick>, StoreError>

pub async fn aggregate_events( &self, filter: &AggregateFilter, ) -> Result<Vec<AggregateBucket>, StoreError>

pub async fn upsert_triage(&self, triage: &Triage) -> Result<(), StoreError>

pub async fn get_triage( &self, run_id: &TaskRunId, ) -> Result<Option<Triage>, StoreError>

pub async fn list_field_indexes( &self, ) -> Result<Vec<FieldIndexInfo>, StoreError>