Struct tower::balance::pool::Pool

source · 
pub struct Pool<MS, Target, Request>
where
    MS: MakeService<Target, Request>,
    MS::MakeError: Into<BoxError>,
    MS::Error: Into<BoxError>,
    Target: Clone,
{ /* private fields */ }
Available on crate feature balance only.
Expand description

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

Implementations§

source§

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,

source

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§

source§

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,

source§

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

Formats the value using the given formatter. Read more
source§

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>>>, Req> as Service<Req>>::Response

Responses given by the service.
§

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

Errors produced by the service.
§

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

The future response value.
source§

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

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

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

Process the request and return the response asynchronously. Read more

Auto Trait Implementations§

§

impl<MS, Target, Request> !Freeze for Pool<MS, Target, Request>

§

impl<MS, Target, Request> !RefUnwindSafe for Pool<MS, Target, Request>

§

impl<MS, Target, Request> Send for Pool<MS, Target, Request>
where <MS as MakeService<Target, Request>>::Error: Sized, <MS as MakeService<Target, Request>>::MakeError: Sized, Request: Send, MS: Send, Target: Send, <MS as MakeService<Target, Request>>::Future: Send, <MS as MakeService<Target, Request>>::Service: Send,

§

impl<MS, Target, Request> Sync for Pool<MS, Target, Request>
where <MS as MakeService<Target, Request>>::Error: Sized, <MS as MakeService<Target, Request>>::MakeError: Sized, Request: Sync + Send, MS: Sync, Target: Sync, <MS as MakeService<Target, Request>>::Future: Sync, <MS as MakeService<Target, Request>>::Service: Send + Sync,

§

impl<MS, Target, Request> Unpin for Pool<MS, Target, Request>
where <MS as MakeService<Target, Request>>::Error: Sized, <MS as MakeService<Target, Request>>::MakeError: Sized, Request: Unpin,

§

impl<MS, Target, Request> !UnwindSafe for Pool<MS, Target, Request>

Blanket Implementations§

source§

impl<T> Any for T
where T: 'static + ?Sized,

source§

fn type_id(&self) -> TypeId

Gets the TypeId of self. Read more
source§

impl<T> Borrow<T> for T
where T: ?Sized,

source§

fn borrow(&self) -> &T

Immutably borrows from an owned value. Read more
source§

impl<T> BorrowMut<T> for T
where T: ?Sized,

source§

fn borrow_mut(&mut self) -> &mut T

Mutably borrows from an owned value. Read more
source§

impl<T> From<T> for T

source§

fn from(t: T) -> T

Returns the argument unchanged.

source§

impl<T> Instrument for T

source§

fn instrument(self, span: Span) -> Instrumented<Self>

Instruments this type with the provided Span, returning an Instrumented wrapper. Read more
source§

fn in_current_span(self) -> Instrumented<Self>

Instruments this type with the current Span, returning an Instrumented wrapper. Read more
source§

impl<T, U> Into<U> for T
where U: From<T>,

source§

fn into(self) -> U

Calls U::from(self).

That is, this conversion is whatever the implementation of From<T> for U chooses to do.

source§

impl<M, S, Target, Request> MakeService<Target, Request> for M
where M: Service<Target, Response = S>, S: Service<Request>,

§

type Response = <S as Service<Request>>::Response

Available on crate feature make only.
Responses given by the service
§

type Error = <S as Service<Request>>::Error

Available on crate feature make only.
Errors produced by the service
§

type Service = S

Available on crate feature make only.
The Service value created by this factory
§

type MakeError = <M as Service<Target>>::Error

Available on crate feature make only.
Errors produced while building a service.
§

type Future = <M as Service<Target>>::Future

Available on crate feature make only.
The future of the Service instance.
source§

fn poll_ready( &mut self, cx: &mut Context<'_>, ) -> Poll<Result<(), <M as MakeService<Target, Request>>::MakeError>>

Available on crate feature make only.
Returns Poll::Ready when the factory is able to create more services. Read more
source§

fn make_service( &mut self, target: Target, ) -> <M as MakeService<Target, Request>>::Future

Available on crate feature make only.
Create and return a new service value asynchronously.
source§

fn into_service(self) -> IntoService<Self, Request>
where Self: Sized,

Available on crate feature make only.
Consume this MakeService and convert it into a Service. Read more
source§

fn as_service(&mut self) -> AsService<'_, Self, Request>
where Self: Sized,

Available on crate feature make only.
Convert this MakeService into a Service without consuming the original MakeService. Read more
source§

impl<T, Request> ServiceExt<Request> for T
where T: Service<Request> + ?Sized,

source§

fn ready(&mut self) -> Ready<'_, Self, Request> ⓘ
where Self: Sized,

Available on crate feature util only.
Yields a mutable reference to the service when it is ready to accept a request.
source§

fn ready_and(&mut self) -> ReadyAnd<'_, Self, Request>
where Self: Sized,

👎Deprecated since 0.4.6: please use the ServiceExt::ready method instead
Available on crate feature util only.
Yields a mutable reference to the service when it is ready to accept a request.
source§

fn ready_oneshot(self) -> ReadyOneshot<Self, Request> ⓘ
where Self: Sized,

Available on crate feature util only.
Yields the service when it is ready to accept a request.
source§

fn oneshot(self, req: Request) -> Oneshot<Self, Request> ⓘ
where Self: Sized,

Available on crate feature util only.
Consume this Service, calling with the providing request once it is ready.
source§

fn call_all<S>(self, reqs: S) -> CallAll<Self, S>
where Self: Sized, Self::Error: Into<BoxError>, S: Stream<Item = Request>,

Available on crate feature util only.
Process all requests from the given Stream, and produce a Stream of their responses. Read more
source§

fn and_then<F>(self, f: F) -> AndThen<Self, F>
where Self: Sized, F: Clone,

Available on crate feature util only.
Executes a new future after this service’s future resolves. This does not alter the behaviour of the poll_ready method. Read more
source§

fn map_response<F, Response>(self, f: F) -> MapResponse<Self, F>
where Self: Sized, F: FnOnce(Self::Response) -> Response + Clone,

Available on crate feature util only.
Maps this service’s response value to a different value. This does not alter the behaviour of the poll_ready method. Read more
source§

fn map_err<F, Error>(self, f: F) -> MapErr<Self, F>
where Self: Sized, F: FnOnce(Self::Error) -> Error + Clone,

Available on crate feature util only.
Maps this service’s error value to a different value. This does not alter the behaviour of the poll_ready method. Read more
source§

fn map_result<F, Response, Error>(self, f: F) -> MapResult<Self, F>
where Self: Sized, Error: From<Self::Error>, F: FnOnce(Result<Self::Response, Self::Error>) -> Result<Response, Error> + Clone,

Available on crate feature util only.
Maps this service’s result type (Result<Self::Response, Self::Error>) to a different value, regardless of whether the future succeeds or fails. Read more
source§

fn map_request<F, NewRequest>(self, f: F) -> MapRequest<Self, F>
where Self: Sized, F: FnMut(NewRequest) -> Request,

Available on crate feature util only.
Composes a function in front of the service. Read more
source§

fn filter<F, NewRequest>(self, filter: F) -> Filter<Self, F>
where Self: Sized, F: Predicate<NewRequest>,

Available on crate features util and filter only.
Composes this service with a Filter that conditionally accepts or rejects requests based on a predicate. Read more
source§

fn filter_async<F, NewRequest>(self, filter: F) -> AsyncFilter<Self, F>
where Self: Sized, F: AsyncPredicate<NewRequest>,

Available on crate features util and filter only.
Composes this service with an AsyncFilter that conditionally accepts or rejects requests based on an [async predicate]. Read more
source§

fn then<F, Response, Error, Fut>(self, f: F) -> Then<Self, F>
where Self: Sized, Error: From<Self::Error>, F: FnOnce(Result<Self::Response, Self::Error>) -> Fut + Clone, Fut: Future<Output = Result<Response, Error>>,

Available on crate feature util only.
Composes an asynchronous function after this service. Read more
source§

fn map_future<F, Fut, Response, Error>(self, f: F) -> MapFuture<Self, F>
where Self: Sized, F: FnMut(Self::Future) -> Fut, Error: From<Self::Error>, Fut: Future<Output = Result<Response, Error>>,

Available on crate feature util only.
Composes a function that transforms futures produced by the service. Read more
source§

fn boxed(self) -> BoxService<Request, Self::Response, Self::Error>
where Self: Sized + Send + 'static, Self::Future: Send + 'static,

Available on crate feature util only.
Convert the service into a Service + Send trait object. Read more
source§

fn boxed_clone(self) -> BoxCloneService<Request, Self::Response, Self::Error>
where Self: Clone + Sized + Send + 'static, Self::Future: Send + 'static,

Available on crate feature util only.
Convert the service into a Service + Clone + Send trait object. Read more
source§

impl<T, U> TryFrom<U> for T
where U: Into<T>,

§

type Error = Infallible

The type returned in the event of a conversion error.
source§

fn try_from(value: U) -> Result<T, <T as TryFrom<U>>::Error>

Performs the conversion.
source§

impl<T, U> TryInto<U> for T
where U: TryFrom<T>,

§

type Error = <U as TryFrom<T>>::Error

The type returned in the event of a conversion error.
source§

fn try_into(self) -> Result<U, <U as TryFrom<T>>::Error>

Performs the conversion.
source§

impl<V, T> VZip<V> for T
where V: MultiLane<T>,

source§

fn vzip(self) -> V

source§

impl<T> WithSubscriber for T

source§

fn with_subscriber<S>(self, subscriber: S) -> WithDispatch<Self>
where S: Into<Dispatch>,

Attaches the provided Subscriber to this type, returning a WithDispatch wrapper. Read more
source§

fn with_current_subscriber(self) -> WithDispatch<Self>

Attaches the current default Subscriber to this type, returning a WithDispatch wrapper. Read more

Layout§

Note: Most layout information is completely unstable and may even differ between compilations. The only exception is types with certain repr(...) attributes. Please see the Rust Reference's “Type Layout” chapter for details on type layout guarantees.

Size: 280 bytes