Struct TowerUpstream 

pub struct TowerUpstream<S, ReqBody, ResBody> { /* private fields */ }

Adapter that implements Hitbox’s Upstream trait for Tower services.

TowerUpstream bridges the gap between Tower’s Service trait and Hitbox’s Upstream trait. It converts CacheableHttpRequest to http::Request for the service call, and wraps responses in CacheableHttpResponse.

When You’ll Encounter This

You typically don’t create this directly. It’s used internally by CacheService to call the upstream service on cache misses.

Type Parameters

• S - The Tower service being adapted
• ReqBody - Request body type
• ResBody - Response body type

Implementations

impl<S, ReqBody, ResBody> TowerUpstream<S, ReqBody, ResBody>

pub fn new(service: S) -> Self

Creates a new upstream adapter wrapping the given service.

Trait Implementations

impl<S, ReqBody, ResBody> Upstream<CacheableHttpRequest<ReqBody>> for TowerUpstream<S, ReqBody, ResBody>

where S: Service<Request<BufferedBody<ReqBody>>, Response = Response<ResBody>> + Clone + Send + 'static, S::Future: Send, S::Error: Send, ReqBody: HttpBody + Send + 'static, ReqBody::Error: Send, ResBody: HttpBody + Send + 'static,

type Response = Result<CacheableHttpResponse<ResBody>, <S as Service<Request<BufferedBody<ReqBody>>>>::Error>

The response type returned by the upstream service

type Future = TowerUpstreamFuture<<S as Service<Request<BufferedBody<ReqBody>>>>::Future, ResBody, <S as Service<Request<BufferedBody<ReqBody>>>>::Error>

The future that resolves to the response

fn call(&mut self, req: CacheableHttpRequest<ReqBody>) -> Self::Future

Call the upstream service with the given request