Struct ProxyGetRequest

source

pub struct ProxyGetRequest<S> { /* private fields */ }

Expand description

Proxy GET /path requests to the specified RPC method calls.

§Request

The GET /path requests are modified into valid POST requests for calling the RPC method. This middleware adds appropriate headers to the request, and completely modifies the request BODY.

§Response

The response of the RPC method is stripped down to contain only the method’s response, removing any RPC 2.0 spec logic regarding the response’ body.

Struct ProxyGetRequestCopy item path

§Request

§Response

Implementations§

impl<S> ProxyGetRequest<S>

pub fn new(inner: S, path: &str, method: &str) -> Result<Self, InvalidPath>

Trait Implementations§

impl<S: Clone> Clone for ProxyGetRequest<S>

fn clone(&self) -> ProxyGetRequest<S>

fn clone_from(&mut self, source: &Self)

impl<S: Debug> Debug for ProxyGetRequest<S>

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

impl<S, B> Service<Request<B>> for ProxyGetRequest<S>where S: Service<HttpRequest, Response = HttpResponse>, S::Response: 'static, S::Error: Into<BoxError> + 'static, S::Future: Send + 'static, B: Body<Data = Bytes> + Send + 'static, B::Data: Send, B::Error: Into<BoxError>,

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

type Error = Box<dyn Error + Send + Sync>

type Future = Pin<Box<dyn Future<Output = Result<<ProxyGetRequest<S> as Service<Request<B>>>::Response, <ProxyGetRequest<S> as Service<Request<B>>>::Error>> + Send>>

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

fn call(&mut self, req: HttpRequest<B>) -> Self::Future

Auto Trait Implementations§

impl<S> Freeze for ProxyGetRequest<S>where S: Freeze,

impl<S> RefUnwindSafe for ProxyGetRequest<S>where S: RefUnwindSafe,

impl<S> Send for ProxyGetRequest<S>where S: Send,

impl<S> Sync for ProxyGetRequest<S>where S: Sync,

impl<S> Unpin for ProxyGetRequest<S>where S: Unpin,

impl<S> UnwindSafe for ProxyGetRequest<S>where S: UnwindSafe,

Blanket Implementations§

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

fn type_id(&self) -> TypeId

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

fn borrow(&self) -> &T

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

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

impl<T> CloneToUninit for Twhere T: Clone,

unsafe fn clone_to_uninit(&self, dst: *mut T)

impl<T> From<T> for T

fn from(t: T) -> T

impl<T> Instrument for T

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

fn in_current_span(self) -> Instrumented<Self>

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

fn into(self) -> U

impl<T> Same for T

type Output = T

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

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

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

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

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

fn call_all<S>(self, reqs: S) -> CallAll<Self, S>where Self: Sized, Self::Error: Into<Box<dyn Error + Send + Sync>>, S: Stream<Item = Request>,

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

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

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

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,

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

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>>,

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>>,

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

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

impl<T> ToOwned for Twhere T: Clone,

type Owned = T

fn to_owned(&self) -> T

fn clone_into(&self, target: &mut T)

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

type Error = Infallible

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

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

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

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

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

fn vzip(self) -> V

impl<T> WithSubscriber for T

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

fn with_current_subscriber(self) -> WithDispatch<Self>

Struct ProxyGetRequest

impl<S, B> Service<Request<B>> for ProxyGetRequest<S>
where S: Service<HttpRequest, Response = HttpResponse>, S::Response: 'static, S::Error: Into<BoxError> + 'static, S::Future: Send + 'static, B: Body<Data = Bytes> + Send + 'static, B::Data: Send, B::Error: Into<BoxError>,

impl<S> Freeze for ProxyGetRequest<S>
where S: Freeze,

impl<S> RefUnwindSafe for ProxyGetRequest<S>
where S: RefUnwindSafe,

impl<S> Send for ProxyGetRequest<S>
where S: Send,

impl<S> Sync for ProxyGetRequest<S>
where S: Sync,

impl<S> Unpin for ProxyGetRequest<S>
where S: Unpin,

impl<S> UnwindSafe for ProxyGetRequest<S>
where S: UnwindSafe,

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

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

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

impl<T> CloneToUninit for T
where T: Clone,

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

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

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

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

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

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

fn call_all<S>(self, reqs: S) -> CallAll<Self, S>
where Self: Sized, Self::Error: Into<Box<dyn Error + Send + Sync>>, S: Stream<Item = Request>,

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

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

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

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,

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

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>>,

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>>,

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

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

impl<T> ToOwned for T
where T: Clone,

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

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

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

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