Enum ObserveEvent 

pub enum ObserveEvent {
    RequestStarted {
        request_id: String,
        downstream_user_agent: Option<String>,
    },
    AuthnComplete {
        principal_id: String,
        kind: PrincipalKind,
    },
    UpstreamChosen {
        upstream: Upstream,
    },
    Chunk {
        batch_index: u64,
        event_count: usize,
        total_bytes: usize,
    },
    RequestFinished {
        status: StatusCode,
        input_tokens: Option<u64>,
        output_tokens: Option<u64>,
        cache_creation_input_tokens: Option<u64>,
        cache_read_input_tokens: Option<u64>,
        duration_ms: u64,
    },
    Error {
        code: String,
        message: String,
        source: String,
    },
}

Observability events emitted by the lifecycle.

Variants

RequestStarted

Downstream request has entered the proxy.

Fields

request_id: String

Request identifier.

downstream_user_agent: Option<String>

Downstream user-agent header, when present.

AuthnComplete

Authentication completed successfully.

Fields

principal_id: String

Authenticated principal identifier.

kind: PrincipalKind

Authenticated principal kind.

UpstreamChosen

Router selected an upstream.

Fields

upstream: Upstream

Selected upstream.

Chunk

A batch of streamed events passed through the relay.

Fields

batch_index: u64

Monotonic batch index within the response stream.

event_count: usize

Number of SSE events in the batch.

total_bytes: usize

Total bytes in the batch.

RequestFinished

Request finished successfully or with an upstream HTTP error.

Fields

status: StatusCode

Final HTTP status code.

input_tokens: Option<u64>

Input token count reported by the upstream, when known.

output_tokens: Option<u64>

Output token count reported by the upstream, when known.

cache_creation_input_tokens: Option<u64>

Cache write token count reported by the upstream, when known.

cache_read_input_tokens: Option<u64>

Cache read token count reported by the upstream, when known.

duration_ms: u64

End-to-end request duration in milliseconds.

Error

Lifecycle or plugin error was observed.

Fields

code: String

Stable error code.

message: String

Redacted human-readable message.

source: String

Error source component.

Trait Implementations

impl Clone for ObserveEvent

fn clone(&self) -> ObserveEvent

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for ObserveEvent

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

Formats the value using the given formatter.

impl Eq for ObserveEvent

impl PartialEq for ObserveEvent

fn eq(&self, other: &ObserveEvent) -> 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 ObserveEvent