Struct TaskQueue 

pub struct TaskQueue { /* private fields */ }

Task queue backed by DuckDB for persistence

Implementations

impl TaskQueue

pub fn new(db: Database) -> Self

Create a new task queue

pub fn push(&self, task: SyncTask) -> Result<i64>

Add a task to the queue

pub fn pop(&self) -> Result<Option<SyncTask>>

Get the next pending task

pub fn mark_in_progress(&self, task_id: i64) -> Result<()>

Mark a task as in progress

pub fn mark_completed(&self, task_id: i64) -> Result<()>

Mark a task as completed

pub fn mark_failed( &self, task_id: i64, error: &str, retry_after: Duration, ) -> Result<()>

Mark a task as failed with retry

pub fn recover_in_progress(&self) -> Result<u32>

Recover tasks that were in progress (crashed)

pub fn pending_count(&self) -> Result<i64>

Get count of pending tasks

pub fn cleanup(&self, days: i32) -> Result<u32>

Clear completed tasks older than given days

pub fn reset_failed(&self) -> Result<u32>

Reset all failed tasks to pending (clear retry delays)

pub fn clear_pending(&self) -> Result<u32>

Clear all pending and failed tasks