pipe-audit-core 0.1.8

Universal data validation and compliance audit engine
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34

// src/validators/file/row_count.rs
use crate::validators::{FileValidator, ValidationReport, ValidationResult};
use polars::prelude::*;

pub struct RowCountValidator {
    pub min: usize,
    pub max: Option<usize>,
}

impl FileValidator for RowCountValidator {
    fn name(&self) -> &'static str {
        "RowCount"
    }

    fn validate(&self, df: &DataFrame) -> ValidationResult<ValidationReport> {
        let rows = df.height();
        let max_check = self.max.map(|m| rows > m).unwrap_or(false);

        if rows < self.min || max_check {
            Ok(ValidationReport {
                status: "fail",
                details: Some(format!(
                    "rows={}, min={}, max={:?}",
                    rows, self.min, self.max
                )),
            })
        } else {
            Ok(ValidationReport {
                status: "pass",
                details: None,
            })
        }
    }
}