Struct InventoryRecord 

pub struct InventoryRecord {
    pub shared_resource_id: String,
    pub app_feature: String,
    pub op_type: OpType,
    pub record_id: String,
    pub timestamp: i64,
    pub sample_rate: f64,
    pub size: Option<u64>,
    pub expiration_time: Option<i64>,
    pub organization_id: Option<u64>,
    pub project_id: Option<u64>,
}

A single inventory change event.

Construct these through InventoryTracker rather than directly.

Fields

shared_resource_id: String

Identifies the shared resource this record belongs to.

This is meant to match a label on a provisioned storage backend so that downstream consumers can join the change stream dataset with, for instance, billing info.

app_feature: String

The product feature this record is attributed to.

op_type: OpType

The type of operation that occurred.

record_id: String

Opaque stable identifier, unique within shared_resource_id.

A hash of the caller’s storage key, derived by InventoryTracker. The raw key is never emitted.

timestamp: i64

When the operation occurred, as Unix epoch microseconds.

sample_rate: f64

Fraction of records the producer is emitting for this resource, in [0, 1].

InventoryTracker will not emit messages for records that are sampled out so the consumer doesn’t need to do any filtering. The reason the sample rate is included on messages is so that the consumer or downstream pipelines can apply a 1 / sample_rate weight when calculating aggregates to account for changes to the sample rate.

size: Option<u64>

Stored size in bytes. Always set for OpType::Write.

expiration_time: Option<i64>

When this record is set to expire, in Unix epoch microseconds if known.

organization_id: Option<u64>

ID of the organization that owns the record, if known.

project_id: Option<u64>

ID of the project that owns the record, if known.

Trait Implementations

impl Clone for InventoryRecord

fn clone(&self) -> InventoryRecord

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for InventoryRecord

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

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for InventoryRecord

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

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Serialize for InventoryRecord

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

where __S: Serializer,

Serialize this value into the given Serde serializer.