Method append_api_behavior_events

crates/store/src/lancedb_api.rs:424–463

(
        &self,
        inputs: Vec<NewApiBehaviorEventInput>,
    )

    }

    pub async fn append_api_behavior_events(
        &self,
        inputs: Vec<NewApiBehaviorEventInput>,
    ) -> Result<()> {
        if inputs.is_empty() {
            return Ok(());
        }
        let _guard = self.api_behavior_gate.read().await;
        let _file_guard =
            acquire_table_access_file_lock(&self.api_behavior_table, TableAccessMode::Shared)
                .await?;
        let table = self.api_behavior_table().await?;
        let now_ms = Utc::now().timestamp_millis();
        let records: Vec<ApiBehaviorRecord> = inputs
            .into_iter()
            .map(|input| ApiBehaviorRecord {
                event_id: normalize_required_text(input.event_id, 96, "evt"),
                occurred_at: input.occurred_at,
                client_source: normalize_required_text(input.client_source, 24, "unknown"),
                method: normalize_required_text(input.method, 16, "GET"),
                path: normalize_required_text(input.path, 512, "/"),
                query: normalize_text(input.query, 2048),
                page_path: normalize_required_text(input.page_path, 512, "unknown"),
                referrer: normalize_optional_text(input.referrer, 1024),
                status_code: input.status_code.max(0),
                latency_ms: input.latency_ms.max(0),
                client_ip: normalize_required_text(input.client_ip, 64, "unknown"),
                ip_region: normalize_required_text(input.ip_region, 128, "Unknown"),
                ua_raw: normalize_optional_text(input.ua_raw, 1024),
                device_type: normalize_required_text(input.device_type, 24, "unknown"),
                os_family: normalize_required_text(input.os_family, 48, "unknown"),
                browser_family: normalize_required_text(input.browser_family, 48, "unknown"),
                request_id: normalize_required_text(input.request_id, 128, "unknown"),
                trace_id: normalize_required_text(input.trace_id, 128, "unknown"),
                created_at: now_ms,
                updated_at: now_ms,
            })
            .collect();
        append_api_behavior_records(&table, &records).await
    }

    pub async fn list_api_behavior_events(
        &self,