Struct RequestContext 

pub struct RequestContext {
    pub request_id: Uuid,
    pub user_id: Uuid,
    pub tenant_id: Uuid,
    pub produce_ai_key_id: Uuid,
    pub model: String,
    pub provider: Option<String>,
    pub messages: Vec<Message>,
    pub stream: bool,
    pub pricing_snapshot: PricingSnapshot,
    pub started_at: DateTime<Utc>,
    /* private fields */
}

请求上下文：贯穿全链路的唯一状态载体

设计说明

• usage 字段使用 Arc<UsageAccumulator> 实现共享状态，Clone 时会共享同一个用量累积器
• 通过 add_output_tokens() 和 set_input_tokens() 方法安全地更新用量
• 使用 usage_snapshot() 获取当前用量快照
• provider 字段在路由确定后被设置，用于精确的定价查询

Fields

request_id: Uuid

user_id: Uuid

tenant_id: Uuid

produce_ai_key_id: Uuid

model: String

provider: Option<String>

Provider 名称（路由确定后设置）

messages: Vec<Message>

stream: bool

pricing_snapshot: PricingSnapshot

started_at: DateTime<Utc>

Implementations

impl RequestContext

pub fn new( user_id: Uuid, tenant_id: Uuid, produce_ai_key_id: Uuid, model: impl Into<String>, messages: Vec<Message>, stream: bool, pricing_snapshot: PricingSnapshot, ) -> Self

pub fn set_provider(&mut self, provider: impl Into<String>)

设置 Provider（路由确定后调用）

pub fn update_pricing(&mut self, pricing: PricingSnapshot)

更新定价快照（路由后根据实际 provider 更新）

pub fn duration(&self) -> Duration

获取请求持续时间

pub fn usage_snapshot(&self) -> (u32, u32)

获取当前用量快照

pub fn add_output_tokens(&self, tokens: u32)

添加输出 token（原子更新）

pub fn set_input_tokens(&self, tokens: u32)

设置输入 token（原子更新）

Trait Implementations

impl Clone for RequestContext

fn clone(&self) -> RequestContext

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for RequestContext

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

Formats the value using the given formatter.