Struct SharedTaskQueue 

pub struct SharedTaskQueue { /* private fields */ }

Thread-safe wrapper for TaskQueue for use in parallel sync

Implementations

impl SharedTaskQueue

pub fn new(queue: TaskQueue) -> Self

Create a new shared task queue

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

Get the next pending task (thread-safe)

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

Get the next pending task using round-robin scheduling (thread-safe)

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

Get the next pending task for a specific pipeline (thread-safe)

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

Get the next pending task using round-robin for a pipeline (thread-safe)

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

Add a task to the queue (thread-safe)

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

Mark a task as in progress (thread-safe)

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

Mark a task as completed (thread-safe)

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

Mark a task as failed with retry (thread-safe)

pub async fn pending_count(&self) -> Result<u32>

Get count of pending tasks (thread-safe)

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

Get count of pending tasks for a pipeline (thread-safe)

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

Update the profile scope for queue operations (thread-safe)

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

Update the pipeline scope for queue operations (thread-safe)

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

Get task counts by status (thread-safe)

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

Recover tasks that were in progress (crashed) (thread-safe)

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

Clear completed tasks older than given days (thread-safe)

Trait Implementations

impl Clone for SharedTaskQueue

fn clone(&self) -> Self

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.