Enum ForwardEvent 

pub enum ForwardEvent {
    RequestStarted {
        meta: EventMeta,
        request_id: String,
        endpoint: String,
        model: String,
        is_stream: bool,
    },
    RequestCompleted {
        meta: EventMeta,
        request_id: String,
        status_code: u16,
        status: ForwardStatus,
        usage: Option<TokenUsage>,
        latency_ms: u64,
        error: Option<String>,
    },
}

Events emitted when forwarding requests to upstream APIs.

These events track HTTP proxy operations when the system forwards requests to external API providers like OpenAI, Anthropic, or other LLM services. They enable monitoring of API usage, costs, and performance.

Event Lifecycle

A typical forward operation produces events in this order:

1. RequestStarted - When a request is initiated to the upstream API
2. RequestCompleted - When the response is received (or an error occurs)

Use Cases

These events support:

• API cost tracking via token consumption
• Performance monitoring (latency, success rates)
• Error rate analysis per endpoint
• Load balancing and capacity planning
• Compliance and audit logging

Variants

RequestStarted

Emitted when a request is initiated to an upstream API.

This marks the beginning of a forwarded HTTP request to an external service provider.

Fields

meta: EventMeta

Event metadata including unique ID and timestamp

request_id: String

Unique identifier for this forwarded request

endpoint: String

Endpoint identifier (e.g., “openai.chat_completions” or “anthropic.messages”)

model: String

The AI model being requested (e.g., “gpt-4”, “claude-3-opus”)

is_stream: bool

Whether this is a streaming request (SSE) or regular request

RequestCompleted

Emitted when a forwarded request completes or fails.

Contains comprehensive information about the request outcome, including HTTP status, token usage, latency, and any errors.

Fields

meta: EventMeta

Event metadata including unique ID and timestamp

request_id: String

Unique identifier for the request that completed

status_code: u16

HTTP status code returned by the upstream API

status: ForwardStatus

Status classification (success, error, or timeout)

usage: Option<TokenUsage>

Token usage if available from the API response

latency_ms: u64

Total time for the request in milliseconds

error: Option<String>

Error message if the request failed, None on success

Trait Implementations

impl Clone for ForwardEvent

fn clone(&self) -> ForwardEvent

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for ForwardEvent

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

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for ForwardEvent

fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Serialize for ForwardEvent

fn serialize<__S>(&self, __serializer: __S) -> Result<__S::Ok, __S::Error>

where __S: Serializer,

Serialize this value into the given Serde serializer.