Struct FileTaskStore 

pub struct FileTaskStore { /* private fields */ }

File-based task store with atomic writes

Stores tasks in a JSON file with the following features:

• Advisory file locking during read-modify-write operations
• Atomic writes via temp file + rename
• Thread-safe concurrent access via internal mutex

Example

use meerkat_tools::builtin::{FileTaskStore, TaskStore, NewTask};
use std::path::PathBuf;

let store = FileTaskStore::new(PathBuf::from("/path/to/.rkat/tasks.json"));

let task = store.create(
    NewTask {
        subject: "Test task".to_string(),
        description: "A test task".to_string(),
        priority: None,
        labels: None,
        blocks: None,
    },
    None
).await.unwrap();

Implementations

impl FileTaskStore

pub fn new(path: PathBuf) -> Self

Create a new file store at the given path

pub fn in_project(project_root: &Path) -> Self

Create a store at the default location in project’s .rkat directory

pub fn path(&self) -> &PathBuf

Get the path to the store file

Trait Implementations

impl TaskStore for FileTaskStore

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

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

List all tasks in the store

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

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

Get a single task by ID

fn create<'life0, 'life1, 'async_trait>( &'life0 self, new_task: NewTask, session_id: Option<&'life1 str>, ) -> Pin<Box<dyn Future<Output = Result<Task, TaskError>> + Send + 'async_trait>>

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

Create a new task

fn update<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, id: &'life1 TaskId, update: TaskUpdate, session_id: Option<&'life2 str>, ) -> Pin<Box<dyn Future<Output = Result<Task, TaskError>> + Send + 'async_trait>>

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

Update an existing task

fn delete<'life0, 'life1, 'async_trait>( &'life0 self, id: &'life1 TaskId, ) -> Pin<Box<dyn Future<Output = Result<(), TaskError>> + Send + 'async_trait>>

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

Delete a task by ID