Struct JobQueue 

pub struct JobQueue { /* private fields */ }

Main job queue manager

Implementations

impl JobQueue

pub fn new<B: JobBackend + 'static>(backend: B) -> Self

Create a new job queue with a backend

pub async fn register_job<J: Job + Clone>(&self, job: J)

Register a job handler

pub async fn enqueue<J: Job>(&self, data: J::Data) -> Result<String>

Enqueue a job

pub async fn enqueue_opts<J: Job>( &self, data: J::Data, opts: EnqueueOptions, ) -> Result<String>

Enqueue a job with options

pub async fn process_one(&self) -> Result<bool>

Process a single job (for testing or manual control)

pub async fn start_worker(&self) -> Result<()>

Start a worker loop

Trait Implementations

impl Clone for JobQueue

fn clone(&self) -> JobQueue

Returns a duplicate of the value.

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

Performs copy-assignment from source.