diff options
author | Edward Wang <[email protected]> | 2024-11-04 15:08:56 -0800 |
---|---|---|
committer | Matthew (mbg) <[email protected]> | 2024-11-08 10:14:21 -0800 |
commit | 1b430c100e9fb05b89ed4d71b7b3daa8fbc868d0 (patch) | |
tree | 879a0ce23bd0fd60e037ab05fb63759d9afe362d | |
parent | 3f564af3ae56e898478e13e71d67d095d7f5dbbd (diff) | |
download | pingora-1b430c100e9fb05b89ed4d71b7b3daa8fbc868d0.tar.gz pingora-1b430c100e9fb05b89ed4d71b7b3daa8fbc868d0.zip |
Allow errors from upstream_response_body_filter
-rw-r--r-- | .bleep | 2 | ||||
-rw-r--r-- | pingora-proxy/src/lib.rs | 2 | ||||
-rw-r--r-- | pingora-proxy/src/proxy_trait.rs | 3 |
3 files changed, 4 insertions, 3 deletions
@@ -1 +1 @@ -a76fd1ca898a9518c6aa0c7c8fa5ed845dd1bcbb
\ No newline at end of file +4a86ea20bc7d70669a7be7b3b316139cbe74e648
\ No newline at end of file diff --git a/pingora-proxy/src/lib.rs b/pingora-proxy/src/lib.rs index 5621170..f13a1f7 100644 --- a/pingora-proxy/src/lib.rs +++ b/pingora-proxy/src/lib.rs @@ -250,7 +250,7 @@ impl<SV> HttpProxy<SV> { } HttpTask::Body(data, eos) => self .inner - .upstream_response_body_filter(session, data, *eos, ctx), + .upstream_response_body_filter(session, data, *eos, ctx)?, HttpTask::Trailer(Some(trailers)) => self .inner .upstream_response_trailer_filter(session, trailers, ctx)?, diff --git a/pingora-proxy/src/proxy_trait.rs b/pingora-proxy/src/proxy_trait.rs index 4f3f627..4017789 100644 --- a/pingora-proxy/src/proxy_trait.rs +++ b/pingora-proxy/src/proxy_trait.rs @@ -267,7 +267,8 @@ pub trait ProxyHttp { _body: &mut Option<Bytes>, _end_of_stream: bool, _ctx: &mut Self::CTX, - ) { + ) -> Result<()> { + Ok(()) } /// Similar to [Self::upstream_response_filter()] but for response trailers |