Trait apalis_core::builder::WorkerFactory

pub trait WorkerFactory<S> {
    type Worker: Worker;

    fn build(self, service: S) -> Self::Worker;
}

Helper trait for building new Workers from WorkerBuilder

Required Associated Types

type Worker: Worker

The worker to build

Required Methods

fn build(self, service: S) -> Self::Worker

Builds a WorkerFactory using a tower service that can be used to generate new Worker actors using the build method

Arguments

• service - A tower service

Examples

Implementors

impl<T, S, M, Ser, Fut> WorkerFactory<Ser> for WorkerBuilder<T, S, M>where
    S: Storage<Output = T> + Unpin + Send + 'static + Sync,
    T: Job + Send + 'static,
    M: Layer<Ser>,
    <M as Layer<Ser>>::Service: Service<JobRequest<T>, Response = JobResult, Error = JobError, Future = Fut> + Unpin + Send + 'static,
    Fut: Future<Output = Result<JobResult, JobError>> + Send,

Available on crate feature storage only.

type Worker = StorageWorker<T, S, <M as Layer<Ser>>::Service>