systemprompt-runtime 0.56.0

Application runtime for systemprompt.io AI governance infrastructure. AppContext, lifecycle builder, extension registry, and module wiring for the MCP governance pipeline.
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21

//! Reporting bootstrap state and durable queue lag.
//!
//! Copyright (c) systemprompt.io — Business Source License 1.1.
//! See <https://systemprompt.io> for licensing details.

use systemprompt_analytics::AnalyticsError;
use systemprompt_analytics::projection::{self, REPORTING_CONSUMER};
use systemprompt_database::DbPool;

use crate::RuntimeResult;

pub type ReportingStatus = projection::ProjectionStatus;

pub async fn status(db: &DbPool) -> RuntimeResult<ReportingStatus> {
    let pool = db.write_pool_arc()?;
    from_pool(&pool).await.map_err(Into::into)
}

pub(super) async fn from_pool(pool: &sqlx::PgPool) -> Result<ReportingStatus, AnalyticsError> {
    projection::status(pool, REPORTING_CONSUMER).await
}