Struct apalis_core::worker::Worker

pub struct Worker<T> { /* private fields */ }

Represents a generic Worker that can be in many different states

Implementations

impl<T> Worker<T>

pub fn new(id: WorkerId, state: T) -> Self

Create a new worker instance

pub fn inner(&self) -> &T

Get the inner state

pub fn id(&self) -> &WorkerId

Get the worker id

impl<E: Executor + Clone + Send + 'static> Worker<Context<E>>

pub async fn run(self)

Start a worker

impl<S, P> Worker<Ready<S, P>>

pub fn with_executor<E, J>(self, executor: E) -> Worker<Context<E>>

where S: Service<Request<J>> + Send + 'static + Clone, P: Backend<Request<J>> + 'static, J: Send + 'static + Sync, S::Future: Send, S::Response: 'static, S::Error: Send + Sync + 'static + Into<BoxDynError>, <P as Backend<Request<J>>>::Stream: Unpin + Send + 'static, E: Executor + Clone + Send + 'static + Sync,

Start a worker with a custom executor

pub fn with_monitor<E, J>(self, monitor: &Monitor<E>) -> Worker<Context<E>>

where S: Service<Request<J>> + Send + 'static + Clone, P: Backend<Request<J>> + 'static, J: Send + 'static + Sync, S::Future: Send, S::Response: 'static, S::Error: Send + Sync + 'static + Into<BoxDynError>, <P as Backend<Request<J>>>::Stream: Unpin + Send + 'static, E: Executor + Clone + Send + 'static + Sync,

Run as a monitored worker

pub fn with_monitor_instances<E, J>( self, instances: usize, monitor: &Monitor<E>, ) -> Vec<Worker<Context<E>>>

where S: Service<Request<J>> + Send + 'static + Clone, P: Backend<Request<J>> + 'static, J: Send + 'static + Sync, S::Future: Send, S::Response: 'static, S::Error: Send + Sync + 'static + Into<BoxDynError>, <P as Backend<Request<J>>>::Stream: Unpin + Send + 'static, E: Executor + Clone + Send + 'static + Sync,

Run a specified amounts of instances

pub fn with_executor_instances<E, J>( self, instances: usize, executor: E, ) -> Vec<Worker<Context<E>>>

where S: Service<Request<J>> + Send + 'static + Clone, P: Backend<Request<J>> + 'static, J: Send + 'static + Sync, S::Future: Send, S::Response: 'static, S::Error: Send + Sync + 'static + Into<BoxDynError>, <P as Backend<Request<J>>>::Stream: Unpin + Send + 'static, E: Executor + Clone + Send + 'static + Sync,

Run specified worker instances via a specific executor

Trait Implementations

impl<T: Clone> Clone for Worker<T>

fn clone(&self) -> Worker<T>

Returns a copy of the value.

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

Performs copy-assignment from source.

impl<T: Debug> Debug for Worker<T>

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl<T> Deref for Worker<T>

type Target = T

The resulting type after dereferencing.

fn deref(&self) -> &Self::Target

Dereferences the value.

impl<T> DerefMut for Worker<T>

fn deref_mut(&mut self) -> &mut Self::Target

Mutably dereferences the value.