Struct HttpListener 

pub struct HttpListener { /* private fields */ }

Cleartext HTTP/1.x listener.

HTTP/2 over cleartext (h2c) is NOT supported

RFC 7540 §3.2 specified an Upgrade: h2c mechanism to negotiate HTTP/2 over a cleartext TCP connection, with a companion prior-knowledge variant in §3.4. Both paths are intentionally absent from this listener:

• No Upgrade: h2c handler: the HTTP/1.1 state machine forwards Upgrade headers to the backend but never responds 101 Switching Protocols with an HTTP/2 connection preface.
• No prior-knowledge detection: the listener does not sniff the 24-byte PRI * HTTP/2.0\r\n\r\nSM\r\n\r\n magic string; a client that opens a TCP connection and immediately sends the preface will be interpreted as a malformed HTTP/1 request and rejected with 400.

RFC 9113 (the current HTTP/2 RFC, obsoleting 7540) formally deprecates the Upgrade: h2c mechanism. Clients that want HTTP/2 MUST use the TLS ALPN path (HttpsListener, selector h2) instead. This is consistent with the industry consensus (nginx, envoy, cloudflare) and removes an entire class of cleartext-preface smuggling primitives.

Implementations

impl HttpListener

pub fn new( config: HttpListenerConfig, token: Token, ) -> Result<HttpListener, ListenerError>

pub fn activate( &mut self, registry: &Registry, tcp_listener: Option<MioTcpListener>, ) -> Result<Token, ListenerError>

pub fn update_config( &mut self, patch: &UpdateHttpListenerConfig, ) -> Result<(), ListenerError>

Apply a partial-update patch to this listener’s live configuration.

Fields absent in the patch (i.e. None) are preserved unchanged. If http_answers is present only the listener-default templates are replaced; per-cluster overrides in cluster_custom_answers are kept.

pub fn add_http_front( &mut self, http_front: HttpFrontend, ) -> Result<(), ListenerError>

pub fn remove_http_front( &mut self, http_front: HttpFrontend, ) -> Result<(), ListenerError>

Trait Implementations

impl L7ListenerHandler for HttpListener

fn get_sticky_name(&self) -> &str

fn get_sozu_id_header(&self) -> &str

Name of the correlation header Sozu injects into every request and response body. Default: "Sozu-Id". Operators can rebrand via the sozu_id_header listener config knob.

fn get_connect_timeout(&self) -> u32

fn frontend_from_request( &self, host: &str, uri: &str, method: &Method, ) -> Result<RouteResult, FrontendFromRequestError>

retrieve a frontend by parsing a request’s hostname, uri and method

fn get_answers(&self) -> &Rc<RefCell<HttpAnswers>>

retrieve the listener’s configured HTTP answers (templates)

fn get_h2_flood_config(&self) -> H2FloodConfig

H2 flood detection thresholds from the listener config. Returns the default config when the listener does not provide custom values.

fn get_h2_connection_config(&self) -> H2ConnectionConfig

H2 connection tuning from the listener config. Returns the default config when the listener does not provide custom values.

fn get_h2_stream_idle_timeout(&self) -> Duration

Per-stream idle timeout for H2 connections. An open stream that makes no forward progress for this duration is cancelled (RST_STREAM / CANCEL). Mitigates slow-multiplex Slowloris where a client keeps connection-level activity high (resetting the connection idle timer on every frame) while pinning streams for the full nominal connection timeout.

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

Wall-clock budget granted to in-flight H2 streams after soft-stop sent the initial GOAWAY(NO_ERROR). Once the deadline elapses the mux transitions to a forced close (final GOAWAY + session teardown).

fn get_elide_x_real_ip(&self) -> bool

Whether to strip any client-supplied X-Real-IP header from forwarded requests (anti-spoofing).

fn get_send_x_real_ip(&self) -> bool

Whether to append a proxy-generated X-Real-IP header carrying the connection peer IP (post-PROXY-v2 unwrap, i.e. the original client IP) to every forwarded request.

fn get_strict_sni_binding(&self) -> bool

Whether requests must have their :authority / Host exact-match the TLS SNI negotiated at handshake (CWE-346 / CWE-444).

impl ListenerHandler for HttpListener

fn get_addr(&self) -> &SocketAddr

fn get_tags(&self, key: &str) -> Option<&CachedTags>

fn set_tags(&mut self, key: String, tags: Option<BTreeMap<String, String>>)

fn protocol(&self) -> Protocol

fn public_address(&self) -> SocketAddr

fn get_concatenated_tags(&self, key: &str) -> Option<&str>