Struct RequestLogRepository 

pub struct RequestLogRepository {
    pub base: BaseRepository<RequestLog>,
}

请求日志Repository

Fields

base: BaseRepository<RequestLog>

Implementations

impl RequestLogRepository

pub fn new(query_executor: Box<dyn QueryExecutor>) -> Self

pub async fn find_by_deployment_id( &self, deployment_id: Uuid, start_time: DateTime<Utc>, end_time: DateTime<Utc>, context: &QueryContext, ) -> DatabaseResult<Vec<RequestLog>>

根据部署ID获取日志

pub async fn find_errors( &self, start_time: DateTime<Utc>, end_time: DateTime<Utc>, context: &QueryContext, ) -> DatabaseResult<Vec<RequestLog>>

获取错误日志

Examples found in repository

examples/burncloud_usage.rs (line 217)

async fn advanced_query_examples(db: &BurnCloudDatabase) -> Result<(), Box<dyn std::error::Error>> {
    let context = QueryContext::default();

    // 时间范围查询
    let start_time = chrono::Utc::now() - chrono::Duration::hours(24);
    let end_time = chrono::Utc::now();

    // 获取过去24小时的系统指标
    let recent_metrics = db.system_metrics.find_by_time_range(start_time, end_time, &context).await?;
    println!("📊 过去24小时系统指标: {} 条记录", recent_metrics.len());

    // 获取特定部署的性能指标
    if let Some(deployment) = db.deployments.get_running_deployments(&context).await?.first() {
        let deployment_metrics = db.model_metrics
            .find_by_deployment_id(deployment.id, start_time, end_time, &context)
            .await?;
        println!("📈 部署 {} 的性能指标: {} 条记录", deployment.name, deployment_metrics.len());

        // 获取该部署的错误日志
        let error_logs = db.request_logs.find_errors(start_time, end_time, &context).await?;
        println!("❌ 过去24小时错误日志: {} 条记录", error_logs.len());
    }

    Ok(())
}