Struct FeatureUsage 

pub struct FeatureUsage {
    pub id: Uuid,
    pub org_id: Uuid,
    pub user_id: Option<Uuid>,
    pub feature: FeatureType,
    pub metadata: Option<Value>,
    pub created_at: DateTime<Utc>,
}

Feature usage event

Fields

id: Uuid

org_id: Uuid

user_id: Option<Uuid>

feature: FeatureType

metadata: Option<Value>

created_at: DateTime<Utc>

Implementations

impl FeatureUsage

pub async fn record( pool: &Pool<Postgres>, org_id: Uuid, user_id: Option<Uuid>, feature: FeatureType, metadata: Option<Value>, ) -> Result<(), Error>

Record a feature usage event

pub async fn count_by_org( pool: &Pool<Postgres>, org_id: Uuid, feature: FeatureType, days: i64, ) -> Result<i64, Error>

Count feature usage for an org in a time period

pub async fn get_global_stats( pool: &Pool<Postgres>, feature: FeatureType, days: i64, ) -> Result<(i64, i64), Error>

Get feature usage stats across all orgs

pub async fn get_adoption_timeline( pool: &Pool<Postgres>, feature: FeatureType, days: i64, ) -> Result<Vec<(NaiveDate, i64)>, Error>

Get feature adoption timeline (daily counts)

pub async fn cleanup_old(pool: &Pool<Postgres>, days: i64) -> Result<u64, Error>

Clean up old feature usage events (older than N days)

pub async fn aggregate_plugin_invoke_ms_by_deployment( pool: &Pool<Postgres>, org_id: Uuid, deployment_id: Uuid, since: DateTime<Utc>, ) -> Result<Vec<PluginInvokeAggregateRow>, Error>

Aggregate plugin_invoke_ms rows for a deployment within a time window, grouped by attachment.

Each plugin_invoke_ms row is a bucket emitted by the OTLP aggregator (see migration 20250101000074); its metadata JSONB is expected to carry:

{
  "deployment_id":   "uuid",
  "attachment_id":   "uuid",
  "plugin_id":       "uuid",
  "plugin_name":     "string",
  "plugin_version":  "string",
  "invoke_ms":       12345,
  "memory_peak_mb":  42        // optional
}

SUMs invoke_ms, MAXes memory_peak_mb (peak across buckets), and ORDERs by total invoke_ms descending so the heaviest plugin surfaces first in the UI. Returns an empty Vec when the OTLP pipeline hasn’t populated any rows yet.

Trait Implementations

impl Clone for FeatureUsage

fn clone(&self) -> FeatureUsage

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for FeatureUsage

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

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for FeatureUsage

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

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl<'a, R> FromRow<'a, R> for FeatureUsage

where R: Row, &'a str: ColumnIndex<R>, Uuid: Decode<'a, <R as Row>::Database> + Type<<R as Row>::Database>, Option<Uuid>: Decode<'a, <R as Row>::Database> + Type<<R as Row>::Database>, FeatureType: Decode<'a, <R as Row>::Database> + Type<<R as Row>::Database>, Option<Value>: Decode<'a, <R as Row>::Database> + Type<<R as Row>::Database>, DateTime<Utc>: Decode<'a, <R as Row>::Database> + Type<<R as Row>::Database>,

fn from_row(__row: &'a R) -> Result<FeatureUsage, Error>

impl Serialize for FeatureUsage

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.