Struct InstrumentedSendRequest 

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

A reusable wrapper around hyper SendRequest that records client spans for each request sent through the connection.

Implementations

impl<B: Body + 'static> InstrumentedSendRequest<SendRequest<B>>

pub fn poll_ready(&mut self, cx: &mut TaskContext<'_>) -> Poll<Result<()>>

Polls until the underlying sender is ready to send a request.

pub async fn ready(&mut self) -> Result<()>

Waits until the underlying sender is ready to send a request.

pub fn is_ready(&self) -> bool

Returns whether the underlying sender appears ready.

pub fn is_closed(&self) -> bool

Returns whether the underlying connection has closed.

pub fn send_request( &mut self, request: Request<B>, ) -> impl Future<Output = Result<Response<Incoming>>> + '_

Sends a request and records an outbound HTTP client span around it.

impl<B: Body + 'static> InstrumentedSendRequest<SendRequest<B>>

pub fn poll_ready(&mut self, cx: &mut TaskContext<'_>) -> Poll<Result<()>>

Polls until the underlying sender is ready to send a request.

pub async fn ready(&mut self) -> Result<()>

Waits until the underlying sender is ready to send a request.

pub fn is_ready(&self) -> bool

Returns whether the underlying sender appears ready.

pub fn is_closed(&self) -> bool

Returns whether the underlying connection has closed.

pub fn send_request( &mut self, request: Request<B>, ) -> impl Future<Output = Result<Response<Incoming>>> + '_

Sends a request and records an outbound HTTP client span around it.

impl<S> InstrumentedSendRequest<S>

pub fn new(inner: S) -> Self

Creates a new instrumented hyper sender.

pub fn context(self, context: &Context) -> Self

Sets the OpenTelemetry context for requests sent by this wrapper.

pub fn set_context(self, context: Option<&Context>) -> Self

Sets the optional OpenTelemetry context for requests sent by this wrapper.

pub fn into_inner(self) -> S

Returns the wrapped hyper sender.

Trait Implementations

impl<S> Clone for InstrumentedSendRequest<S>

where S: Clone,

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.