Struct Metering 

pub struct Metering {
    pub function: String,
    pub invocations: u64,
    pub successes: u64,
    pub failures: u64,
    pub duration_ms_total: u64,
    pub bytes_in_total: u64,
    pub bytes_out_total: u64,
    pub window_start: u64,
    pub window_count: u64,
    pub updated: u64,
}

Host-side usage aggregate for one function (FA-4), tenant-isolated under keys::metering. It also carries the fixed-window rate-limit counter so metering + quota share a single read-modify-write.

Fields

function: String

The function these counters belong to.

invocations: u64

Total invocations metered (sync + drained async).

successes: u64

Invocations whose guest produced a response.

failures: u64

Invocations that failed to deliver (engine error / dead-lettered).

duration_ms_total: u64

Summed wall-clock duration, milliseconds.

bytes_in_total: u64

Summed request bytes.

bytes_out_total: u64

Summed response bytes.

window_start: u64

The current rate-limit window’s start (unix seconds).

window_count: u64

Invocations admitted in the current window.

updated: u64

Last update (unix seconds).

Implementations

impl Metering

pub fn new(function: impl Into<String>) -> Metering

A fresh aggregate for function.

pub fn record(&mut self, sample: &MeteringSample, now: u64)

Fold one invocation’s cost into the usage counters.

pub fn admit(&mut self, quota: &FunctionQuota, now: u64) -> bool

Admit one invocation against the fixed-window rate limit, rolling the window over when it has elapsed. Returns true if admitted (and records the admission), false if the window is already at max (⇒ the caller fails closed with 429). An unset cap always admits.

Trait Implementations

impl Clone for Metering

fn clone(&self) -> Metering

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for Metering

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

Formats the value using the given formatter.

impl Default for Metering

fn default() -> Metering

Returns the “default value” for a type.

impl<'de> Deserialize<'de> for Metering

where Metering: Default,

fn deserialize<__D>( __deserializer: __D, ) -> Result<Metering, <__D as Deserializer<'de>>::Error>

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Eq for Metering

impl PartialEq for Metering

fn eq(&self, other: &Metering) -> bool

Equality operator ==.

fn ne(&self, other: &Rhs) -> bool

Inequality operator !=.

impl Serialize for Metering

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

where __S: Serializer,

Serialize this value into the given Serde serializer.

impl StructuralPartialEq for Metering