Struct HttpPeer

pub struct HttpPeer {
    pub _address: SocketAddr,
    pub scheme: Scheme,
    pub sni: String,
    pub proxy: Option<Proxy>,
    pub client_cert_key: Option<Arc<CertKey>>,
    pub group_key: u64,
    pub options: PeerOptions,
}

A peer representing the remote HTTP server to connect to

Fields

_address: SocketAddr

scheme: Scheme

sni: String

proxy: Option<Proxy>

client_cert_key: Option<Arc<CertKey>>

group_key: u64

a custom field to isolate connection reuse. Requests with different group keys cannot share connections with each other.

options: PeerOptions

Implementations

impl HttpPeer

pub fn is_tls(&self) -> bool

pub fn new<A: ToInetSocketAddrs>(address: A, tls: bool, sni: String) -> Self

Create a new HttpPeer with the given socket address and TLS settings.

pub fn new_uds(path: &str, tls: bool, sni: String) -> Result<Self>

Create a new HttpPeer with the given path to Unix domain socket and TLS settings.

pub fn new_proxy( next_hop: &str, ip_addr: IpAddr, port: u16, tls: bool, sni: &str, headers: BTreeMap<String, Vec<u8>>, ) -> Self

Create a new HttpPeer that uses a proxy to connect to the upstream IP and port combination.

Trait Implementations

impl Clone for HttpPeer

fn clone(&self) -> HttpPeer

Returns a copy of the value.

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

Performs copy-assignment from source.

impl Debug for HttpPeer

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

Formats the value using the given formatter.

impl Display for HttpPeer

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

Formats the value using the given formatter.

impl Hash for HttpPeer

fn hash<H: Hasher>(&self, state: &mut H)

Feeds this value into the given Hasher.

fn hash_slice<H>(data: &[Self], state: &mut H)

where H: Hasher, Self: Sized,

Feeds a slice of this type into the given Hasher.

impl Peer for HttpPeer

fn address(&self) -> &SocketAddr

The remote address to connect to

fn tls(&self) -> bool

If TLS should be used;

fn sni(&self) -> &str

The SNI to send, if TLS is used

fn reuse_hash(&self) -> u64

To decide whether a Peer can use the connection established by another Peer.

fn get_peer_options(&self) -> Option<&PeerOptions>

Get the additional options to connect to the peer.

fn get_mut_peer_options(&mut self) -> Option<&mut PeerOptions>

Get the additional options for modification.

fn get_proxy(&self) -> Option<&Proxy>

Get the proxy setting to connect to the remote server

fn matches_fd<V: AsRawFd>(&self, fd: V) -> bool

fn get_client_cert_key(&self) -> Option<&Arc<CertKey>>

Get the client cert and key for mutual TLS if any

fn get_tracer(&self) -> Option<Tracer>

fn verify_cert(&self) -> bool

Whether the TLS handshake should validate the cert of the server.

fn verify_hostname(&self) -> bool

Whether the TLS handshake should verify that the server cert matches the SNI.

fn alternative_cn(&self) -> Option<&String>

The alternative common name to use to verify the server cert.

fn bind_to(&self) -> Option<&BindTo>

Information about the local source address this connection should be bound to.

fn connection_timeout(&self) -> Option<Duration>

How long connect() call should be wait before it returns a timeout error.

fn total_connection_timeout(&self) -> Option<Duration>

How long the overall connection establishment should take before a timeout error is returned.

fn idle_timeout(&self) -> Option<Duration>

If the connection can be reused, how long the connection should wait to be reused before it shuts down.

fn get_alpn(&self) -> Option<&ALPN>

Get the ALPN preference.

fn get_ca(&self) -> Option<&Arc<CaType>>

Get the CA cert to use to validate the server cert.

fn tcp_keepalive(&self) -> Option<&TcpKeepalive>

The TCP keepalive setting that should be applied to this connection

fn h2_ping_interval(&self) -> Option<Duration>

The interval H2 pings to send to the server if any

fn tcp_recv_buf(&self) -> Option<usize>

The size of the TCP receive buffer should be limited to. See SO_RCVBUF for more details.

fn dscp(&self) -> Option<u8>

The DSCP value that should be applied to the send side of this connection. See the RFC for more details.

fn tcp_fast_open(&self) -> bool

Whether to enable TCP fast open.