Struct TaskStore 

pub struct TaskStore {
    pub tasks: Vec<Task>,
    pub updated_at: Option<DateTime<Utc>>,
    /* private fields */
}

Fields

tasks: Vec<Task>

updated_at: Option<DateTime<Utc>>

Implementations

impl TaskStore

pub fn default_path() -> Result<PathBuf>

pub fn load() -> Result<Self>

Snapshot of the default store, read under the store lock so it never observes a writer’s half-applied update. Read-modify-write callers use Self::mutate_locked; a load → change → Self::save sequence overwrites concurrent updates.

pub fn save(&self) -> Result<()>

Overwrite the default store with this snapshot. Prefer Self::mutate_locked for read-modify-write updates.

pub fn scoped_path(project_root: &str) -> Result<PathBuf>

pub fn read_locked<R>(path: &Path, read: impl FnOnce(&Self) -> R) -> Result<R>

pub fn mutate_locked<R, E>( path: &Path, mutate: impl FnOnce(&mut Self) -> Result<R, E>, ) -> Result<R, E>

where E: From<Error>,

pub fn mutate_locked_within<R, E>( path: &Path, wait: Duration, mutate: impl FnOnce(&mut Self) -> Result<R, E>, ) -> Result<R, E>

where E: From<Error>,

Self::mutate_locked that waits up to wait for the store lock. Within this process callers queue in arrival order; another process is held off only by the polled file lock, so a caller that runs once per request (such as ctx_agent export) can still be kept out past the default timeout by another process taking the lock back to back.

pub fn create_task(&mut self, from: &str, to: &str, description: &str) -> String

pub fn materialize_remote_task( path: &Path, descriptor: &TaskDescriptorV1, ) -> Result<RemoteTaskMaterialization>

Durably materialize an already-authorized remote task descriptor.

The description is admitted for the store like any new caller text: a descriptor whose description is restricted or withheld is refused with PermissionDenied and a content-free message, and neither a task nor an idempotency record is written.

The idempotency ledger lives in the same file as the tasks and is written under the same lock and atomic rename, so a delivery is either visible with its ledger entry after a restart or not at all — never acknowledged without being stored.

Callers MUST verify TaskDescriptorV1::verify_authority first; this re-validates shape only, and cannot re-derive authority on its own.

pub fn get_task(&self, task_id: &str) -> Option<&Task>

pub fn get_task_mut(&mut self, task_id: &str) -> Option<&mut Task>

pub fn tasks_for_agent(&self, agent_id: &str) -> Vec<&Task>

pub fn pending_tasks_for(&self, agent_id: &str) -> Vec<&Task>

pub fn cleanup_old(&mut self, max_age_hours: u64)

Trait Implementations

impl Clone for TaskStore

fn clone(&self) -> Self

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for TaskStore

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl Default for TaskStore

fn default() -> Self

Returns the “default value” for a type.

impl<'de> Deserialize<'de> for TaskStore

fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Serialize for TaskStore

fn serialize<__S>(&self, __serializer: __S) -> Result<__S::Ok, __S::Error>

where __S: Serializer,

Serialize this value into the given Serde serializer.