Struct gaffer::Builder

pub struct Builder<J: Job + 'static> { /* fields omitted */ }

Builder of JobRunner

Implementations

impl<J: Job + Send + 'static> Builder<J>

pub fn enable_merge(self, f: fn(_: J, _: &mut J) -> MergeResult<J>) -> Self

Enable merging of Jobs in the queue, if a merge function is provided here, it will be tried with each job added to the queue against each job already in the queue

impl<J: Job + Send + RecurrableJob + 'static> Builder<J>

pub fn set_recurring(
    self,
    interval: Duration,
    last_enqueue: Instant,
    job: J
) -> Self

Set a job as recurring, the job will be enqueued every time interval passes since the last_enqueue of a matching job

impl<J: Job + Send + 'static> Builder<J>

pub fn limit_concurrency(
    self,
    concurrency_limit: impl Fn(<J as Job>::Priority) -> Option<u8> + Send + Sync + 'static
) -> Self

Function determining, for each priority, how many threads can be allocated to jobs of this priority, any remaining threads will be left idle to service higher-priority jobs. None means parallelism won’t be limited

pub fn build(self, thread_num: usize) -> JobRunner<J>

Build the JobRunner, spawning thread_num threads as workers

Trait Implementations

impl<J: Job + Send + 'static> Default for Builder<J>

fn default() -> Self

Returns the “default value” for a type.