Struct tower::balance::pool::Pool

pub struct Pool<MS, Target, Request>where
    MS: MakeService<Target, Request>,
    MS::MakeError: Into<BoxError>,
    MS::Error: Into<BoxError>,
    Target: Clone,{ /* private fields */ }

A dynamically sized, load-balanced pool of Service instances.

Implementations

impl<MS, Target, Request> Pool<MS, Target, Request>where MS: MakeService<Target, Request>, MS::Service: Load, <MS::Service as Load>::Metric: Debug, MS::MakeError: Into<BoxError>, MS::Error: Into<BoxError>, Target: Clone,

pub fn new(make_service: MS, target: Target) -> Self

Construct a new dynamically sized Pool.

If many calls to poll_ready return Pending, new_service is used to construct another Service that is then added to the load-balanced pool. If many calls to poll_ready succeed, the most recently added Service is dropped from the pool.

Trait Implementations

impl<MS, Target, Request> Debug for Pool<MS, Target, Request>where MS: MakeService<Target, Request> + Debug, MS::MakeError: Into<BoxError>, MS::Error: Into<BoxError>, Target: Clone + Debug, MS::Service: Debug,

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

Formats the value using the given formatter.

impl<MS, Target, Req> Service<Req> for Pool<MS, Target, Req>where MS: MakeService<Target, Req>, MS::Service: Load, <MS::Service as Load>::Metric: Debug, MS::MakeError: Into<BoxError>, MS::Error: Into<BoxError>, Target: Clone,

type Response = <Balance<Pin<Box<PoolDiscoverer<MS, Target, Req>, Global>>, Req> as Service<Req>>::Response

Responses given by the service.

type Error = <Balance<Pin<Box<PoolDiscoverer<MS, Target, Req>, Global>>, Req> as Service<Req>>::Error

Errors produced by the service.

type Future = <Balance<Pin<Box<PoolDiscoverer<MS, Target, Req>, Global>>, Req> as Service<Req>>::Future

The future response value.

fn poll_ready(&mut self, cx: &mut Context<'_>) -> Poll<Result<(), Self::Error>>

Returns Poll::Ready(Ok(())) when the service is able to process requests.

fn call(&mut self, req: Req) -> Self::Future

Process the request and return the response asynchronously.