Struct JobDispatcher 

pub struct JobDispatcher { /* private fields */ }

Dispatches jobs to the queue.

Implementations

impl JobDispatcher

pub fn new(queue: JobQueue, registry: JobRegistry) -> Self

Create a new job dispatcher.

pub async fn dispatch<J: ForgeJob>( &self, args: J::Args, ) -> Result<Uuid, ForgeError>

where J::Args: Serialize,

Dispatch a job immediately.

pub async fn dispatch_in<J: ForgeJob>( &self, delay: Duration, args: J::Args, ) -> Result<Uuid, ForgeError>

where J::Args: Serialize,

Dispatch a job with a delay.

pub async fn dispatch_at<J: ForgeJob>( &self, at: DateTime<Utc>, args: J::Args, ) -> Result<Uuid, ForgeError>

where J::Args: Serialize,

Dispatch a job at a specific time.

pub async fn dispatch_by_name( &self, job_type: &str, args: Value, ) -> Result<Uuid, ForgeError>

Dispatch job by name (dynamic).

pub async fn dispatch_idempotent<J: ForgeJob>( &self, idempotency_key: impl Into<String>, args: J::Args, ) -> Result<Uuid, ForgeError>

where J::Args: Serialize,

Dispatch job with idempotency key.

pub async fn dispatch_with_priority<J: ForgeJob>( &self, priority: JobPriority, args: J::Args, ) -> Result<Uuid, ForgeError>

where J::Args: Serialize,

Dispatch job with custom priority.

Trait Implementations

impl Clone for JobDispatcher

fn clone(&self) -> JobDispatcher

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl JobDispatch for JobDispatcher

fn dispatch_by_name( &self, job_type: &str, args: Value, ) -> Pin<Box<dyn Future<Output = Result<Uuid>> + Send + '_>>

Dispatch a job by its registered name.