Struct TaskQueue 

pub struct TaskQueue { /* private fields */ }

Task queue backed by SQLite for persistence

Implementations

impl TaskQueue

pub fn new( sync_db: SyncDb, profile_id: i32, pipeline: Option<SyncPipeline>, ) -> 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 pop_with_pipeline( &self, pipeline: Option<SyncPipeline>, ) -> Result<Option<SyncTask>>

Get the next pending task for a specific pipeline

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

Pop the next task using round-robin across primary task types

pub fn pop_round_robin_with_pipeline( &mut self, pipeline: Option<SyncPipeline>, ) -> Result<Option<SyncTask>>

Pop the next task using round-robin across primary task types for a pipeline

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<u32>

Get count of pending tasks

pub fn pending_count_with_pipeline( &self, pipeline: Option<SyncPipeline>, ) -> Result<u32>

Get count of pending tasks for a pipeline

pub fn set_profile_id(&mut self, profile_id: i32)

Update the profile scope for queue operations

pub fn set_pipeline(&mut self, pipeline: Option<SyncPipeline>)

Update the pipeline scope for queue operations

pub fn count_by_status(&self) -> Result<(u32, u32, u32, u32)>

Get task counts by status

pub fn count_by_type(&self) -> Result<(u32, u32, u32, u32)>

Get task counts by type (activities, gpx, health, performance)

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

Clear completed tasks older than given days

pub fn sync_db(&self) -> &SyncDb

Get the sync database (for sync state operations)

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

Reset all failed tasks to pending

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

Clear all pending and failed tasks