Struct apalis_core::monitor::Monitor

pub struct Monitor<E> { /* private fields */ }

A monitor for coordinating and managing a collection of workers.

Implementations

impl<E: Executor + Clone + Send + 'static + Sync> Monitor<E>

pub fn register<J: Send + Sync + 'static, S: Service<Request<J>> + Send + 'static + Clone, P: Backend<Request<J>> + 'static>( self, worker: Worker<Ready<S, P>> ) -> Self

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

Registers a single instance of a Worker

pub fn register_with_count<J: Send + Sync + 'static, S: Service<Request<J>> + Send + 'static + Clone, P: Backend<Request<J>> + 'static>( self, count: usize, worker: Worker<Ready<S, P>> ) -> Self

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

Registers multiple workers with the monitor.

Arguments

• count - The number of workers to register.
• worker - A Worker that is ready for running.

Returns

The monitor instance, with all workers added to the collection.

pub async fn run_with_signal<S: Future<Output = Result<()>>>( self, signal: S ) -> Result<()>

where E: Executor + Clone + Send + 'static,

Runs the monitor and all its registered workers until they have all completed or a shutdown signal is received.

Arguments

• signal - A Future that resolves when a shutdown signal is received.

Errors

If the monitor fails to shutdown gracefully, an std::io::Error will be returned.

pub async fn run(self) -> Result<()>

where E: Executor + Clone + Send + 'static,

Runs the monitor and all its registered workers until they have all completed.

Errors

If the monitor fails to shutdown gracefully, an std::io::Error will be returned.

Remarks

If a timeout has been set using the shutdown_timeout method, the monitor will wait for all workers to complete up to the timeout duration before exiting. If the timeout is reached and workers have not completed, the monitor will log a warning message and exit forcefully.

pub fn on_event<F: Fn(Worker<Event>) + Send + Sync + 'static>( self, f: F ) -> Self

Handles events emitted

pub fn executor(&self) -> &E

Get the current executor

impl<E> Monitor<E>

pub fn new() -> Self

where E: Default,

Creates a new monitor instance.

Returns

A new monitor instance, with an empty collection of workers.

pub fn new_with_executor(executor: E) -> Self

Creates a new monitor instance with an executor

Returns

A new monitor instance, with an empty collection of workers.

pub fn set_executor<NE: Executor>(self, executor: NE) -> Monitor<NE>

Sets a custom executor for the monitor, allowing the usage of another runtime apart from Tokio. The executor must implement the Executor trait.

Trait Implementations

impl<E> Debug for Monitor<E>

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

Formats the value using the given formatter.

impl<E: Default> Default for Monitor<E>

fn default() -> Self

Returns the “default value” for a type.