Struct Request

pub struct Request<T> { /* private fields */ }

A hRPC request.

Implementations

impl<T> Request<T>

pub fn header_map(&self) -> Option<&HeaderMap>

Get an immutable reference to the header map.

pub fn header_map_mut(&mut self) -> Option<&mut HeaderMap>

Get a mutable reference to the header map.

pub fn get_or_insert_header_map(&mut self) -> &mut HeaderMap

Get a mutable reference to the header map, inserting a new one if it doesn’t already exist.

pub fn http_extensions(&self) -> Option<&Extensions>

Get an immutable reference to the HTTP extensions.

pub fn http_extensions_mut(&mut self) -> Option<&mut Extensions>

Get a mutable reference to the HTTP extensions.

pub fn get_or_insert_http_extensions(&mut self) -> &mut Extensions

Get a mutable reference to the HTTP extensions, inserting a new one if it doesn’t already exist.

impl<T> Request<T>

pub fn http_method(&self) -> Option<&Method>

Get an immutable reference to the HTTP method.

pub fn http_version(&self) -> Option<&Version>

Get an immutable reference to the HTTP version.

pub fn http_uri(&self) -> Option<&Uri>

Get an immutable reference to the HTTP URI.

impl Request<()>

pub fn empty() -> Request<()>

Create a request with an empty body.

This is useful for hRPC socket requests, since they don’t send any messages.

impl<T> Request<T>

pub fn new_with_body(body: Body) -> Self

Creates a new request using the provided body.

pub fn extensions_mut(&mut self) -> &mut Extensions

Get a mutable reference to the extensions of this response.

pub fn extensions(&self) -> &Extensions

Get an immutable reference to the extensions of this response.

pub fn endpoint_mut(&mut self) -> &mut Cow<'static, str>

Get a mutable reference to the endpoint of this response.

pub fn endpoint(&self) -> &str

Get an immutable reference to the endpoint of this response.

impl<T: PbMsg> Request<T>

pub fn new(msg: &T) -> Self

Create a new request with the specified message.

impl<T: PbMsg + Default> Request<T>

pub async fn into_message(self) -> Result<T, DecodeBodyError>

Extract the body from the request and decode it into the message.

Trait Implementations

impl<T> Debug for Request<T>

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

Formats the value using the given formatter.

impl<T> From<Parts> for Request<T>

fn from(parts: Parts) -> Self

Converts to this type from the input type.

impl<T> From<Request<T>> for Parts

fn from(req: Request<T>) -> Self

Converts to this type from the input type.

impl<T> IntoRequest<T> for Request<T>

fn into_request(self) -> Request<T>

Convert this to a hRPC request.

impl<S, Err> Service<Request<()>> for Backoff<S>

where S: Service<BoxRequest, Error = TransportError<Err>> + Clone,

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

Responses given by the service.

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

Errors produced by the service.

type Future = BackoffFuture<Err, S>

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: BoxRequest) -> Self::Future

Process the request and return the response asynchronously.

impl Service<Request<()>> for BoxedTransport

type Response = Response<()>

Responses given by the service.

type Error = TransportError<BoxedTransportError>

Errors produced by the service.

type Future = Pin<Box<dyn Future<Output = Result<<BoxedTransport as Service<Request<()>>>::Response, <BoxedTransport as Service<Request<()>>>::Error>> + Send>>

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: BoxRequest) -> Self::Future

Process the request and return the response asynchronously.

impl<ToStatus, S> Service<Request<()>> for ErrorIdentifierToStatus<ToStatus, S>

where S: Service<BoxRequest, Response = BoxResponse>, ToStatus: Fn(&str) -> Option<StatusCode> + Clone,

type Response = Response<()>

Responses given by the service.

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

Errors produced by the service.

type Future = ErrorIdentifierToStatusFuture<ToStatus, <S as Service<Request<()>>>::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: BoxRequest) -> Self::Future

Process the request and return the response asynchronously.

impl Service<Request<()>> for HrpcService

type Response = Response<()>

Responses given by the service.

type Error = Infallible

Errors produced by the service.

type Future = Pin<Box<dyn Future<Output = Result<Response<()>, Infallible>> + Send>>

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: BoxRequest) -> Self::Future

Process the request and return the response asynchronously.

impl Service<Request<()>> for Hyper

type Response = Response<()>

Responses given by the service.

type Error = TransportError<HyperError>

Errors produced by the service.

type Future = HyperCallFuture

The future response value.

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

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

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

Process the request and return the response asynchronously.

impl Service<Request<()>> for Mock

type Response = Response<()>

Responses given by the service.

type Error = TransportError<MockError>

Errors produced by the service.

type Future = MockCallFuture

The future response value.

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

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

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

Process the request and return the response asynchronously.

impl<ModifyReq, ModifyResp, S> Service<Request<()>> for Modify<ModifyReq, ModifyResp, S>

where S: Service<BoxRequest, Response = BoxResponse>, ModifyReq: Fn(&mut BoxRequest), ModifyResp: Fn(&mut BoxResponse) + Clone,

type Response = Response<()>

Responses given by the service.

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

Errors produced by the service.

type Future = ModifyFuture<ModifyResp, <S as Service<Request<()>>>::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: BoxRequest) -> Self::Future

Process the request and return the response asynchronously.

impl<S, ExtractKey, BypassForKey, Key> Service<Request<()>> for RateLimit<S, ExtractKey, BypassForKey, Key>

where S: Service<BoxRequest, Response = BoxResponse, Error = Infallible>, ExtractKey: Fn(&mut BoxRequest) -> Option<Key>, BypassForKey: Fn(&Key) -> bool, Key: Eq + Hash,

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

Responses given by the service.

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

Errors produced by the service.

type Future = RateLimitFuture<<S as Service<Request<()>>>::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, request: BoxRequest) -> Self::Future

Process the request and return the response asynchronously.

impl Service<Request<()>> for RoutesFinalized

type Response = Response<()>

Responses given by the service.

type Error = Infallible

Errors produced by the service.

type Future = Pin<Box<dyn Future<Output = Result<Response<()>, Infallible>> + Send>>

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: BoxRequest) -> Self::Future

Process the request and return the response asynchronously.

impl<S, SpanFn, OnRequestFn, OnSuccessFn, OnErrorFn> Service<Request<()>> for Trace<S, SpanFn, OnRequestFn, OnSuccessFn, OnErrorFn>

where S: Service<BoxRequest, Response = BoxResponse>, SpanFn: Fn(&BoxRequest) -> Span, OnRequestFn: Fn(&BoxRequest, &Span), OnSuccessFn: Fn(&BoxResponse, &Span) + Clone, OnErrorFn: Fn(&BoxResponse, &Span, &Error) + Clone,

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

Responses given by the service.

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

Errors produced by the service.

type Future = TraceFuture<<S as Service<Request<()>>>::Future, OnSuccessFn, OnErrorFn>

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: BoxRequest) -> Self::Future

Process the request and return the response asynchronously.

impl Service<Request<()>> for Wasm

type Response = Response<()>

Responses given by the service.

type Error = TransportError<WasmError>

Errors produced by the service.

type Future = CallFuture

The future response value.

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

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

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

Process the request and return the response asynchronously.