Enum ObserveEvent 

pub enum ObserveEvent {
    RequestStarted {
        request_id: Box<str>,
        downstream_user_agent: Option<Box<str>>,
    },
    AuthnComplete {
        principal_id: Box<str>,
        principal_kind: Box<str>,
    },
    UpstreamChosen {
        upstream: Upstream,
    },
    Chunk {
        batch_index: u64,
        event_count: u64,
        total_bytes: u64,
    },
    RequestFinished {
        status: u16,
        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: Box<str>,
        message: Box<str>,
        source: Box<str>,
    },
}

Lifecycle event delivered to the observe hook. rkyv mirror of cc_lb_plugin_api::ObserveEvent.

Variants

RequestStarted

Fields

request_id: Box<str>

downstream_user_agent: Option<Box<str>>

AuthnComplete

Fields

principal_id: Box<str>

principal_kind: Box<str>

UpstreamChosen

Fields

upstream: Upstream

Chunk

Fields

batch_index: u64

event_count: u64

total_bytes: u64

RequestFinished

Fields

status: u16

input_tokens: Option<u64>

output_tokens: Option<u64>

cache_creation_input_tokens: Option<u64>

cache_read_input_tokens: Option<u64>

duration_ms: u64

Error

Fields

code: Box<str>

message: Box<str>

source: Box<str>

Trait Implementations

impl Archive for ObserveEvent

where Box<str>: Archive, Option<Box<str>>: Archive, Upstream: Archive, u64: Archive, u16: Archive, Option<u64>: Archive,

type Archived = ArchivedObserveEvent

The archived representation of this type.

type Resolver = ObserveEventResolver

The resolver for this type. It must contain all the additional information from serializing needed to make the archived type from the normal type.

fn resolve( &self, resolver: <Self as Archive>::Resolver, out: Place<<Self as Archive>::Archived>, )

Creates the archived version of this value at the given position and writes it to the given output.

const COPY_OPTIMIZATION: CopyOptimization<Self> = _

An optimization flag that allows the bytes of this type to be copied directly to a writer instead of calling serialize.

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<__D: Fallible + ?Sized> Deserialize<ObserveEvent, __D> for Archived<ObserveEvent>

where Box<str>: Archive, <Box<str> as Archive>::Archived: Deserialize<Box<str>, __D>, Option<Box<str>>: Archive, <Option<Box<str>> as Archive>::Archived: Deserialize<Option<Box<str>>, __D>, Upstream: Archive, <Upstream as Archive>::Archived: Deserialize<Upstream, __D>, u64: Archive, <u64 as Archive>::Archived: Deserialize<u64, __D>, u16: Archive, <u16 as Archive>::Archived: Deserialize<u16, __D>, Option<u64>: Archive, <Option<u64> as Archive>::Archived: Deserialize<Option<u64>, __D>,

fn deserialize( &self, deserializer: &mut __D, ) -> Result<ObserveEvent, <__D as Fallible>::Error>

Deserializes using the given deserializer

impl<__S: Fallible + ?Sized> Serialize<__S> for ObserveEvent

where Box<str>: Serialize<__S>, Option<Box<str>>: Serialize<__S>, Upstream: Serialize<__S>, u64: Serialize<__S>, u16: Serialize<__S>, Option<u64>: Serialize<__S>,

fn serialize( &self, serializer: &mut __S, ) -> Result<<Self as Archive>::Resolver, <__S as Fallible>::Error>

Writes the dependencies for the object and returns a resolver that can create the archived type.

impl WireSchema for ObserveEvent

const FINGERPRINT: [u8; 32]

const DESCRIPTOR: &'static str = "ObserveEvent[RequestStarted{request_id:Box<str>,downstream_user_agent:Option<Box<str>>},AuthnComplete{principal_id:Box<str>,principal_kind:Box<str>},UpstreamChosen{upstream:Upstream},Chunk{batch_index:u64,event_count:u64,total_bytes:u64},RequestFinished{status:u16,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:Box<str>,message:Box<str>,source:Box<str>}]"