Struct CacheEvent 

pub struct CacheEvent {

    pub timestamp: SystemTime,
    pub event_type: CacheEventType,
    pub request_id: RequestId,
    pub key: String,
    pub method: Option<Method>,
    pub uri: Option<Uri>,
    pub version: Option<Version>,
    pub status: Option<StatusCode>,
    pub hit: bool,
    pub latency_us: Option<u64>,
    pub size_bytes: Option<usize>,
    pub ttl_seconds: Option<u64>,
    pub tags: Option<Vec<String>>,
    pub tier: Option<String>,
    pub promoted: bool,
    pub metadata: Value,
}

Structured cache event for ML training. Structured cache event, emitted as JSON.

Requires the serde feature: the metadata field is a serde_json::Value and the payload is emitted as JSON.

Fields

timestamp: SystemTime

Timestamp of the event

event_type: CacheEventType

Type of cache event

request_id: RequestId

Request ID for correlation

key: String

Cache key (may be hashed)

method: Option<Method>

Request method

uri: Option<Uri>

Request URI

version: Option<Version>

HTTP version

status: Option<StatusCode>

Response status code

hit: bool

Whether this was a cache hit

latency_us: Option<u64>

Operation latency in microseconds

size_bytes: Option<usize>

Response size in bytes

ttl_seconds: Option<u64>

TTL in seconds

tags: Option<Vec<String>>

Cache tags associated with this entry

tier: Option<String>

Tier information (l1, l2, or None)

promoted: bool

Whether entry was promoted between tiers

metadata: Value

Additional metadata

Implementations

impl CacheEvent

pub fn new( event_type: CacheEventType, request_id: RequestId, key: String, ) -> Self

Creates a new cache event.

pub fn with_method(self, method: Method) -> Self

Sets the HTTP method.

pub fn with_uri(self, uri: Uri) -> Self

Sets the request URI.

pub fn with_version(self, version: Version) -> Self

Sets the HTTP version.

pub fn with_status(self, status: StatusCode) -> Self

Sets the response status.

pub fn with_hit(self, hit: bool) -> Self

Sets whether this was a cache hit.

pub fn with_latency(self, latency: Duration) -> Self

Sets the operation latency.

pub fn with_size(self, size: usize) -> Self

Sets the response size.

pub fn with_ttl(self, ttl: Duration) -> Self

Sets the TTL.

pub fn with_tags(self, tags: Vec<String>) -> Self

Sets the cache tags.

pub fn with_tier(self, tier: impl Into<String>) -> Self

Sets the tier information.

pub fn with_promoted(self, promoted: bool) -> Self

Sets whether the entry was promoted.

pub fn with_metadata(self, metadata: Value) -> Self

Adds custom metadata.

pub fn log(&self, config: &MLLoggingConfig)

Logs this event using the provided configuration.

Trait Implementations

impl Clone for CacheEvent

fn clone(&self) -> CacheEvent

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for CacheEvent

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

Formats the value using the given formatter.