Struct IngressRequest 

pub struct IngressRequest {
    pub method: HttpMethod,
    pub protocol: Protocol,
    pub path: String,
    pub endpoint: EndpointKind,
    pub logical_index: String,
    pub doc_id: Option<String>,
    pub headers: Vec<(String, String)>,
    pub body: Vec<u8>,
    pub query: Option<String>,
    pub client_cert_subject: Option<String>,
    pub secure: bool,
}

A parsed, owned client request ready for the pipeline.

Fields

method: HttpMethod

The HTTP method.

protocol: Protocol

The wire protocol the request arrived on (HTTP/1.1, HTTP/2, or gRPC). The auto ingress builder negotiates h1/h2 per connection; the engine records it for tracing and may select the upstream protocol from it (docs/04 §7).

path: String

The raw request path (used to route proxy admin endpoints such as /debug/explain/{id} that are not OpenSearch paths).

endpoint: EndpointKind

The endpoint classification derived from method + path.

logical_index: String

The logical index from the path (pre-rewrite), empty if the path has none.

doc_id: Option<String>

The document id from the path, if the endpoint carries one (_doc/{id}).

headers: Vec<(String, String)>

The request headers, in arrival order.

body: Vec<u8>

The request body.

query: Option<String>

The raw URL query string (without the ?), if any. The engine forwards only an allow-list of cursor params (scroll/keep_alive) upstream, query-affecting params are never forwarded, so the body partition filter cannot be bypassed (NFR-S4).

client_cert_subject: Option<String>

The verified client-certificate identity, if the connection was mutually authenticated (mTLS). A stable id derived from the cert, never the raw certificate material.

secure: bool

Whether the request arrived over a TLS-terminated connection. The handler refuses to mutate a request body over cleartext, since the proxy must terminate TLS to rewrite the stream (NFR-S1).

Trait Implementations

impl Clone for IngressRequest

fn clone(&self) -> IngressRequest

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for IngressRequest

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

Formats the value using the given formatter.

impl Eq for IngressRequest

impl PartialEq for IngressRequest

fn eq(&self, other: &IngressRequest) -> bool

Tests for self and other values to be equal, and is used by ==.

fn ne(&self, other: &Rhs) -> bool

Tests for !=. The default implementation is almost always sufficient, and should not be overridden without very good reason.

impl StructuralPartialEq for IngressRequest