Struct Cluster 

pub struct Cluster { /* private fields */ }

A server running across several threads, as Server::run returns it.

Dropping this leaves the workers running; call Cluster::close to wind them down.

Implementations

impl Cluster

pub fn cores() -> usize

How many threads the machine can run at once, or 1 if that cannot be found.

Useful as the worker count for Server::run.

pub fn new( shutdown: Sender<Option<f64>>, threads: Vec<JoinHandle<()>>, addresses: Vec<SocketAddr>, ) -> Self

A cluster over already-started workers.

pub fn address(&self) -> Option<SocketAddr>

The first bound address, if any port has one.

pub fn addresses(&self) -> &[SocketAddr]

Every bound address.

pub fn workers(&self) -> usize

How many worker threads are running.

pub fn close(self, timeout: Option<f64>)

Stops every worker and waits for the threads to finish.

timeout is passed to each worker’s ServerHandle::close, bounding how long it waits for its connections. This blocks, so do not call it from inside an async context.