Struct TaskPersistenceManager 

pub struct TaskPersistenceManager { /* private fields */ }

Manages task persistence using a SQLite database

This struct provides methods for saving and loading tasks from a SQLite database, ensuring task data survives between application restarts.

Implementations

impl TaskPersistenceManager

pub async fn new<P: AsRef<Path>>( database_path: P, ) -> Result<Self, SchedulerError>

Creates a new persistence manager with the specified database

This method initializes the database connection and creates the necessary tables if they don’t exist.

Arguments

• database_path - Path to the SQLite database file

Returns

• Ok(TaskPersistenceManager) - Successfully created manager
• Err(SchedulerError) - If database initialization fails

pub async fn save_task(&self, task: &Task) -> Result<(), SchedulerError>

Saves a task to the database

This method serializes and stores a task in the database. If a task with the same ID already exists, it will be updated.

Arguments

• task - The task to save

Returns

• Ok(()) - Task was saved successfully
• Err(SchedulerError) - If the save operation fails

pub async fn get_task( &self, task_id: &str, ) -> Result<Option<PersistableTask>, SchedulerError>

Retrieves a task from the database by its ID

Arguments

• task_id - The ID of the task to retrieve

Returns

• Ok(Some(PersistableTask)) - Task found and retrieved
• Ok(None) - No task found with the given ID
• Err(SchedulerError) - If the retrieval operation fails

pub async fn list_tasks(&self) -> Result<Vec<PersistableTask>, SchedulerError>

Lists all tasks stored in the database

This method retrieves all tasks currently stored in the database.

Returns

• Ok(Vec<PersistableTask>) - List of all stored tasks
• Err(SchedulerError) - If the retrieval operation fails

pub async fn delete_task(&self, task_id: &str) -> Result<(), SchedulerError>

Deletes a task from the database

Arguments

• task_id - The ID of the task to delete

Returns

• Ok(()) - Task was deleted or didn’t exist
• Err(SchedulerError) - If the deletion operation fails

pub async fn clear_tasks(&self) -> Result<(), SchedulerError>

Removes all tasks from the database

This method deletes all stored tasks, effectively resetting the persistence store.

Returns

• Ok(()) - All tasks were cleared successfully
• Err(SchedulerError) - If the clear operation fails