Struct JsonRequestRewrite 

pub struct JsonRequestRewrite<S, H> { /* private fields */ }

Available on crate features http and std only.

Rewrites JSON request bodies before they reach the underlying service, using rama’s streaming JsonRewriter.

See the module docs for details. Construct it directly with new or via JsonRequestRewriteLayer.

Implementations

impl<S, H> JsonRequestRewrite<S, H>

pub fn new( inner: S, selectors: impl IntoIterator<Item = JsonPath>, handler: H, ) -> JsonRequestRewrite<S, H>

Creates a new JsonRequestRewrite service.

The selector index passed to the handler is the index into selectors; keep the two aligned.

pub fn with_rewrite_policy( self, policy: impl Fn(&HeaderMap, &Extensions) -> bool + Send + Sync + 'static, ) -> JsonRequestRewrite<S, H>

Sets a custom request rewrite policy.

The predicate receives the request headers and extensions and can narrow rewriting beyond the built-in Content-Encoding guard.

pub fn set_rewrite_policy( &mut self, policy: impl Fn(&HeaderMap, &Extensions) -> bool + Send + Sync + 'static, ) -> &mut JsonRequestRewrite<S, H>

Sets a custom request rewrite policy.

The predicate receives the request headers and extensions and can narrow rewriting beyond the built-in Content-Encoding guard.

pub fn with_max_buffered_bytes( self, max_buffered_bytes: usize, ) -> JsonRequestRewrite<S, H>

Sets the tokenizer buffered-input limit for each rewritten body.

pub fn set_max_buffered_bytes( &mut self, max_buffered_bytes: usize, ) -> &mut JsonRequestRewrite<S, H>

Sets the tokenizer buffered-input limit for each rewritten body.

pub fn get_ref(&self) -> &S

Gets a reference to the underlying service.

pub fn into_inner(self) -> S

Consumes self, returning the underlying service.

Trait Implementations

impl<S, H> Clone for JsonRequestRewrite<S, H>

where S: Clone, H: Clone,

fn clone(&self) -> JsonRequestRewrite<S, H>

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl<S, H> Debug for JsonRequestRewrite<S, H>

where S: Debug,

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

Formats the value using the given formatter.

impl<S, H, ReqBody> Service<Request<ReqBody>> for JsonRequestRewrite<S, H>

where S: Service<Request<JsonRewriteBody<ReqBody, H>>>, ReqBody: Body + Send + 'static, <ReqBody as Body>::Data: Send + 'static, <ReqBody as Body>::Error: Into<Box<dyn Error + Sync + Send>> + Send + 'static, H: JsonValueHandler + Clone + Send + Sync + 'static,

type Output = <S as Service<Request<JsonRewriteBody<ReqBody, H>>>>::Output

The type of the output returned by the service.

type Error = <S as Service<Request<JsonRewriteBody<ReqBody, H>>>>::Error

The type of error returned by the service.

async fn serve( &self, req: Request<ReqBody>, ) -> Result<<JsonRequestRewrite<S, H> as Service<Request<ReqBody>>>::Output, <JsonRequestRewrite<S, H> as Service<Request<ReqBody>>>::Error>

Serve an output or an error for the given input

fn boxed(self) -> BoxService<Input, Self::Output, Self::Error>

Box this service to allow for dynamic dispatch.