Struct HostPool 

pub struct HostPool {
    pub name: String,
    /* private fields */
}

The HostPool initializes a number of workers for the passed WapcHost factory function.

Fields

name: String

The name of the HostPool (for debugging purposes).

Implementations

impl HostPool

pub fn new<N, F>( name: N, factory: F, min_threads: usize, max_threads: usize, max_wait: Duration, max_idle: Duration, ) -> Self

where N: AsRef<str>, F: Fn() -> WapcHost + Send + Sync + 'static,

Instantiate a new HostPool.

pub fn num_active_workers(&self) -> usize

Get the current number of active workers.

pub async fn call<T: AsRef<str> + Sync + Send>( &self, op: T, payload: Vec<u8>, ) -> Result<Vec<u8>, Error>

Call an operation on one of the workers.

pub fn shutdown(&mut self) -> Result<(), Error>

Shut down the host pool.

Trait Implementations

impl Debug for HostPool

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

Formats the value using the given formatter.