Struct RequestContext 

pub struct RequestContext { /* private fields */ }

Request context maintained throughout the request lifecycle.

This struct uses a hybrid approach:

• Immutable fields (start_time) are private with getters
• Mutable fields are public(crate) for efficient access within the proxy module

Implementations

impl RequestContext

pub fn new() -> Self

Create a new empty request context with the current timestamp.

pub fn start_time(&self) -> Instant

Get the request start time.

pub fn elapsed(&self) -> Duration

Get elapsed duration since request start.

pub fn correlation_id(&self) -> &str

Get trace_id (alias for backwards compatibility with correlation_id usage).

pub fn trace_id(&self) -> &str

Get the trace ID.

pub fn route_id(&self) -> Option<&str>

Get the route ID, if set.

pub fn upstream(&self) -> Option<&str>

Get the upstream ID, if set.

pub fn selected_upstream_address(&self) -> Option<&str>

Get the selected upstream peer address (IP:port), if set.

pub fn route_config(&self) -> Option<&Arc<RouteConfig>>

Get the cached route configuration, if set.

pub fn global_config(&self) -> Option<&Arc<Config>>

Get the cached global configuration, if set.

pub fn service_type(&self) -> Option<ServiceType>

Get the service type from cached route config.

pub fn upstream_attempts(&self) -> u32

Get the number of upstream attempts.

pub fn method(&self) -> &str

Get the HTTP method.

pub fn path(&self) -> &str

Get the request path.

pub fn query(&self) -> Option<&str>

Get the query string, if present.

pub fn client_ip(&self) -> &str

Get the client IP address.

pub fn user_agent(&self) -> Option<&str>

Get the User-Agent header, if present.

pub fn referer(&self) -> Option<&str>

Get the Referer header, if present.

pub fn host(&self) -> Option<&str>

Get the Host header, if present.

pub fn response_bytes(&self) -> u64

Get the response body size in bytes.

pub fn geo_country_code(&self) -> Option<&str>

Get the GeoIP country code, if determined.

pub fn geo_lookup_performed(&self) -> bool

Check if a geo lookup was performed for this request.

pub fn traceparent(&self) -> Option<String>

Get traceparent header value for distributed tracing.

Returns the W3C Trace Context traceparent header value if tracing is enabled. Format: {version}-{trace-id}-{span-id}-{trace-flags}

pub fn set_trace_id(&mut self, trace_id: impl Into<String>)

Set the trace ID.

pub fn set_route_id(&mut self, route_id: impl Into<String>)

Set the route ID.

pub fn set_upstream(&mut self, upstream: impl Into<String>)

Set the upstream ID.

pub fn set_selected_upstream_address(&mut self, address: impl Into<String>)

Set the selected upstream peer address (IP:port).

pub fn inc_upstream_attempts(&mut self)

Increment upstream attempt counter.

pub fn set_response_bytes(&mut self, bytes: u64)

Set response bytes.

pub fn fallback_attempt(&self) -> u32

Get the current fallback attempt number (0 = primary).

pub fn tried_upstreams(&self) -> &[String]

Get the list of upstreams that have been tried.

pub fn fallback_reason(&self) -> Option<&FallbackReason>

Get the fallback reason, if fallback was triggered.

pub fn original_upstream(&self) -> Option<&str>

Get the original upstream ID (before fallback).

pub fn model_mapping_applied(&self) -> Option<&(String, String)>

Get the model mapping that was applied: (original, mapped).

pub fn used_fallback(&self) -> bool

Check if fallback was used for this request.

pub fn record_fallback(&mut self, reason: FallbackReason, new_upstream: &str)

Record that a fallback attempt is being made.

pub fn record_model_mapping(&mut self, original: String, mapped: String)

Record model mapping applied during fallback.

pub fn used_model_routing(&self) -> bool

Check if model-based routing was used to select the upstream.

pub fn inference_provider_override(&self) -> Option<InferenceProvider>

Get the provider override from model-based routing (if any).

pub fn record_model_routing( &mut self, upstream: &str, model: Option<String>, provider_override: Option<InferenceProvider>, )

Record model-based routing result.

Called when model-based routing selects an upstream based on the model name.

Trait Implementations

impl Default for RequestContext

fn default() -> Self

Returns the “default value” for a type.