pub struct HttpUpstreamConnector { /* private fields */ }Expand description
Connects through an HTTP upstream proxy (no TLS to the proxy itself).
Implementations§
Source§impl HttpUpstreamConnector
impl HttpUpstreamConnector
pub async fn new(config: &UpstreamProxyConfig) -> Result<Self, UpstreamError>
Trait Implementations§
Source§impl OutboundConnector for HttpUpstreamConnector
impl OutboundConnector for HttpUpstreamConnector
fn send_request<'life0, 'life1, 'life2, 'async_trait>(
&'life0 self,
req: Request<HttpBody>,
target_host: &'life1 str,
target_port: u16,
_flow: &'life2 mut Flow,
) -> Pin<Box<dyn Future<Output = Result<Response<Incoming>, UpstreamError>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
'life1: 'async_trait,
'life2: 'async_trait,
Source§fn upstream_proxy_url(&self) -> Option<&str>
fn upstream_proxy_url(&self) -> Option<&str>
Returns the upstream proxy URL if this connector routes through one.
Used for circuit breaker keying and status reporting.
Auto Trait Implementations§
impl !RefUnwindSafe for HttpUpstreamConnector
impl !UnwindSafe for HttpUpstreamConnector
impl Freeze for HttpUpstreamConnector
impl Send for HttpUpstreamConnector
impl Sync for HttpUpstreamConnector
impl Unpin for HttpUpstreamConnector
impl UnsafeUnpin for HttpUpstreamConnector
Blanket Implementations§
Source§impl<'a, T, E> AsTaggedExplicit<'a, E> for Twhere
T: 'a,
impl<'a, T, E> AsTaggedExplicit<'a, E> for Twhere
T: 'a,
Source§impl<'a, T, E> AsTaggedImplicit<'a, E> for Twhere
T: 'a,
impl<'a, T, E> AsTaggedImplicit<'a, E> for Twhere
T: 'a,
Source§impl<T> BorrowMut<T> for Twhere
T: ?Sized,
impl<T> BorrowMut<T> for Twhere
T: ?Sized,
Source§fn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
Mutably borrows from an owned value. Read more