Struct SqliteTaskStore 

pub struct SqliteTaskStore { /* private fields */ }

Implementations

impl SqliteTaskStore

pub fn new(data_dir: &Path) -> Result<Self>

Open (creating if absent) the control-plane DB at <data_dir>/control_plane.db. Additive: a fresh install gets an empty DB and today’s behavior is unchanged.

pub fn new_in_memory() -> Result<Self>

In-memory store for unit tests.

pub fn count_by_agent(&self, agent: &str) -> Result<u64>

Admin enumeration — count this agent’s records (mirrors AcpSessionStore’s count_*_by_agent; used by alias-delete cascades / observability).

pub fn delete_by_agent(&self, agent: &str) -> Result<u64>

Admin enumeration — delete this agent’s records (alias-delete cascade).

Trait Implementations

impl GoalTaskRegistry for SqliteTaskStore

fn create_goal<'life0, 'async_trait>( &'life0 self, task: TaskRecord, goal: GoalTaskRecord, continuation_context: Option<TaskContinuationContext>, ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

fn latest_active_goal_for_agent<'life0, 'life1, 'async_trait>( &'life0 self, agent: &'life1 str, ) -> Pin<Box<dyn Future<Output = Result<Option<TaskRecord>>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Resolve the latest non-terminal goal task for agent directly from the canonical task table. This is a read-only resolver, not cached state.

fn latest_active_goal_for_context<'life0, 'life1, 'life2, 'life3, 'async_trait>( &'life0 self, agent: &'life1 str, originator_route: Option<&'life2 str>, principal_id: Option<&'life3 str>, ) -> Pin<Box<dyn Future<Output = Result<Option<TaskRecord>>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait, 'life3: 'async_trait,

fn latest_active_goal_id_for_context<'life0, 'life1, 'life2, 'life3, 'async_trait>( &'life0 self, agent: &'life1 str, originator_route: Option<&'life2 str>, principal_id: Option<&'life3 str>, ) -> Pin<Box<dyn Future<Output = Result<Option<String>>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait, 'life3: 'async_trait,

Resolve only the id of the latest non-terminal goal for the trusted runtime context. This is a read-only projection from tasks.id, used by hot attribution paths that do not need the full task record.

fn get_goal_task<'life0, 'life1, 'async_trait>( &'life0 self, task_id: &'life1 str, ) -> Pin<Box<dyn Future<Output = Result<Option<GoalTaskRecord>>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

fn update_goal_objective<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, task_id: &'life1 str, objective: &'life2 str, ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>

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

fn update_goal_limits<'life0, 'life1, 'async_trait>( &'life0 self, task_id: &'life1 str, token_limit: Option<u64>, cost_limit_usd: Option<f64>, ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Replace the persisted effective budget limits for a goal. These are creation/update-time policy limits only. Consumed and remaining usage stay derived from canonical usage ledger rows.

fn update_goal_pause<'life0, 'life1, 'async_trait>( &'life0 self, task_id: &'life1 str, pause: Option<GoalPauseState>, ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

fn pause_goal_task<'life0, 'life1, 'async_trait>( &'life0 self, task_id: &'life1 str, pause: GoalPauseState, ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

fn resume_goal_task<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, task_id: &'life1 str, owner_pid: u32, owner_boot_id: &'life2 str, continuation_context: Option<TaskContinuationContext>, ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>

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

fn set_continuation_context<'life0, 'life1, 'async_trait>( &'life0 self, task_id: &'life1 str, context: Option<TaskContinuationContext>, ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

fn get_continuation_context<'life0, 'life1, 'async_trait>( &'life0 self, task_id: &'life1 str, ) -> Pin<Box<dyn Future<Output = Result<Option<TaskContinuationContext>>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

impl TaskRegistry for SqliteTaskStore

fn create<'life0, 'async_trait>( &'life0 self, rec: TaskRecord, ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Register a new unit of work. Idempotent on rec.id.

fn heartbeat<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, id: &'life1 str, owner_boot_id: &'life2 str, ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>

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

Stamp a liveness beat for id from the heart-beating owner.

fn update_status<'life0, 'life1, 'async_trait>( &'life0 self, id: &'life1 str, status: TaskStatus, output: Option<String>, error: Option<String>, ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Transition id to status, optionally recording terminal output/error.

fn claim_owner<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, id: &'life1 str, owner_pid: u32, owner_boot_id: &'life2 str, ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>

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

fn get<'life0, 'life1, 'async_trait>( &'life0 self, id: &'life1 str, ) -> Pin<Box<dyn Future<Output = Result<Option<TaskRecord>>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

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

where Self: 'async_trait, 'life0: 'async_trait,

fn list_by_agent<'life0, 'life1, 'async_trait>( &'life0 self, agent: &'life1 str, ) -> Pin<Box<dyn Future<Output = Result<Vec<TaskRecord>>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

fn reconcile_lost<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, id: &'life1 str, now_boot_id: &'life2 str, ) -> Pin<Box<dyn Future<Output = Result<bool>> + Send + 'async_trait>>

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

Reaper/recovery seam: mark a record terminal-loss ONLY when this process is authoritative for it. Returns false (no write) when another live daemon owns it. See crate::control_plane::authority::is_authoritative.