Skip to main content

TaskItemQueryRepository

agent_orchestrator::task_repository

Trait TaskItemQueryRepository 

Source 
pub trait TaskItemQueryRepository {
    // Required methods
    fn first_task_item_id(&self, task_id: &str) -> Result<Option<String>>;
    fn list_task_items_for_cycle(
        &self,
        task_id: &str,
    ) -> Result<Vec<TaskItemRow>>;
    fn count_unresolved_items(&self, task_id: &str) -> Result<i64>;
    fn count_stale_pending_items(&self, task_id: &str) -> Result<i64>;
    fn count_recent_heartbeats_for_items(
        &self,
        task_id: &str,
        item_ids: &[String],
        cutoff_ts: &str,
    ) -> Result<i64>;
}
Expand description

Task item enumeration and health-check queries.

Required Methods§

Source

fn first_task_item_id(&self, task_id: &str) -> Result<Option<String>>

Returns the first task-item identifier for a task, if any.

Source

fn list_task_items_for_cycle(&self, task_id: &str) -> Result<Vec<TaskItemRow>>

Lists task items participating in the current cycle.

Source

fn count_unresolved_items(&self, task_id: &str) -> Result<i64>

Counts unresolved items for the task.

Source

fn count_stale_pending_items(&self, task_id: &str) -> Result<i64>

Counts stale pending items (FR-038).

Source

fn count_recent_heartbeats_for_items( &self, task_id: &str, item_ids: &[String], cutoff_ts: &str, ) -> Result<i64>

Counts recent heartbeat events for specified item IDs since cutoff (FR-052).

Implementors§