Struct WorkerPool 

pub struct WorkerPool { /* private fields */ }

Server builder

Implementations

impl WorkerPool

pub fn new() -> Self

Create new Server builder instance

pub fn name<T: AsRef<str>>(self, name: T) -> Self

Set workers name.

Name is used for worker thread name

pub fn workers(self, num: usize) -> Self

Set number of workers to start.

By default server uses number of available logical cpu as workers count.

pub fn stop_runtime(self) -> Self

Stop current ntex runtime when manager get dropped.

By default “stop runtime” is disabled.

pub fn stop_on_panic(self) -> Self

Stops the server when one of the workers panics.

By default, “stop on panic” is disabled.

pub fn disable_signals(self) -> Self

Disable signal handling.

By default, signal handling is enabled.

pub fn graceful_shutdown(self) -> Self

Graceful shutdown.

Gracefully shuts down on SIGTERM, SIGSEGV, or SIGQUIT. By default, graceful shutdown is disabled.

pub fn shutdown_timeout<T: Into<Millis>>(self, timeout: T) -> Self

Timeout for graceful worker shutdown.

After receiving a stop signal, workers have this much time to finish serving requests. Workers that are still alive after the timeout are forcefully dropped.

By default, the shutdown timeout is set to 30 seconds.

pub fn enable_affinity(self) -> Self

Enable cpu affinity.

By default, affinity is disabled.

pub fn run<F: ServerConfiguration>(self, factory: F) -> Server<F::Item>

Starts processing incoming items and return server controller.

Trait Implementations

impl Clone for WorkerPool

fn clone(&self) -> WorkerPool

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for WorkerPool

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

Formats the value using the given formatter.

impl Default for WorkerPool

fn default() -> Self

Returns the “default value” for a type.