Struct MemoryTaskStore 

pub struct MemoryTaskStore { /* private fields */ }

In-memory task store for testing

This store keeps all tasks in memory using a RwLock<Vec<Task>>. It is thread-safe and can be used in async contexts.

Example

use meerkat_tools::builtin::{MemoryTaskStore, TaskStore, NewTask};

let store = MemoryTaskStore::new();

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();

assert_eq!(store.list().await.unwrap().len(), 1);

Implementations

impl MemoryTaskStore

pub fn new() -> Self

Create a new empty memory store

pub fn with_tasks(tasks: Vec<Task>) -> Self

Create a memory store pre-populated with tasks

This is useful for setting up test fixtures.

pub fn len(&self) -> usize

Get the current number of tasks in the store

This is a convenience method for testing.

pub fn is_empty(&self) -> bool

Check if the store is empty

Trait Implementations

impl Default for MemoryTaskStore

fn default() -> Self

Returns the “default value” for a type.

impl TaskStore for MemoryTaskStore

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