Struct ClosureSpawnHandler 

pub struct ClosureSpawnHandler<F, DB: Database> { /* private fields */ }

A spawn handler that creates jobs based on a simple closure.

Implementations

impl<F, DB> ClosureSpawnHandler<F, DB>

where F: Fn(SpawnContext<DB>) -> Result<Vec<Job>> + Send + Sync, DB: Database + Send + Sync,

pub fn new(handler: F) -> Self

Create a new closure-based spawn handler.

Trait Implementations

impl<F, DB> SpawnHandler<DB> for ClosureSpawnHandler<F, DB>

where F: Fn(SpawnContext<DB>) -> Result<Vec<Job>> + Send + Sync, DB: Database + Send + Sync,

fn spawn_jobs<'life0, 'async_trait>( &'life0 self, context: SpawnContext<DB>, ) -> Pin<Box<dyn Future<Output = Result<Vec<Job>>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Generate child jobs based on the parent job’s context.

fn validate_spawn<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, _parent_job: &'life1 Job, _config: &'life2 SpawnConfig, ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait,

Optional validation method called before spawning jobs.

fn on_spawn_complete<'life0, 'life1, 'async_trait>( &'life0 self, _result: &'life1 SpawnResult, ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Optional post-spawn callback called after child jobs are enqueued.