Struct ConnectIpRequestBuilder 

pub struct ConnectIpRequestBuilder { /* private fields */ }

Available on crate feature masque only.

Prepare a CONNECT-IP handshake from a configured endpoint and typed scope.

Headers and extensions remain available for authentication and HTTP layers. The method, URI, version and protocol are prepared together by the template. No tunnel bytes are sent before the response is validated.

Implementations

impl ConnectIpRequestBuilder

pub fn new( template: &ConnectIpTemplate, scope: &ConnectIpScope, version: Version, config: ConnectIpSessionConfig, ) -> Result<ConnectIpRequestBuilder, ConnectIpRequestError>

Prepare an empty HTTP request for this endpoint, scope and HTTP version.

pub fn try_from_request( template: &ConnectIpTemplate, request: Request, config: ConnectIpSessionConfig, ) -> Result<ConnectIpRequestBuilder, ConnectIpRequestError>

Recover a request passed through a low-level HTTP connection establishment.

This escape hatch validates the complete handshake against the configured endpoint, including its scope, before it can be sent. Prefer Self::new when using an HTTP client service directly.

pub fn headers_mut(&mut self) -> &mut HeaderMap

Add authentication or application headers.

pub fn extensions(&self) -> &Extensions

Metadata consumed by HTTP client layers.

pub fn with_open_timeout(self, timeout: Duration) -> ConnectIpRequestBuilder

Total handshake deadline, independent of packet write timeouts. A zero timeout refuses an opening that cannot complete immediately.

pub fn set_open_timeout( &mut self, timeout: Duration, ) -> &mut ConnectIpRequestBuilder

Total handshake deadline, independent of packet write timeouts. A zero timeout refuses an opening that cannot complete immediately.

pub async fn connect<S, B>( self, client: &S, ) -> Result<ConnectIpSession, Box<dyn Error + Send + Sync>>

where S: Service<Request, Output = Response<B>>, <S as Service<Request>>::Error: Into<Box<dyn Error + Send + Sync>>, B: Send + 'static,

Open the session with an existing Rama HTTP client.

The client must honor the HTTPS URI and requested HTTP version. Response bodies remain generic: packet I/O comes from the HTTP upgrade extension.

Trait Implementations

impl Debug for ConnectIpRequestBuilder

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

Formats the value using the given formatter.

impl<S, B> Service<ConnectIpRequestBuilder> for ConnectIpConnector<S>

where S: Service<Request, Output = Response<B>>, <S as Service<Request>>::Error: Into<Box<dyn Error + Send + Sync>>, B: Send + 'static,

type Output = ConnectIpSession

The type of the output returned by the service.

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

The type of error returned by the service.

async fn serve( &self, request: ConnectIpRequestBuilder, ) -> Result<<ConnectIpConnector<S> as Service<ConnectIpRequestBuilder>>::Output, <ConnectIpConnector<S> as Service<ConnectIpRequestBuilder>>::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.