rskit-dataset 0.2.0-alpha.2

Dataset collection framework: source, transform, target, collector
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15

//! Pluggable per-item validation seam for the collection engine.
//!
//! The engine treats validation as an injected policy: a [`Validator`] inspects each item after its
//! transforms and rejects it with a typed error. The engine ships no built-in validator — callers
//! opt in (for example a schema-backed validator for tabular records).

use rskit_errors::AppResult;

use crate::DatasetItem;

/// Rejects invalid items before they are materialized by a sink.
pub trait Validator<T: DatasetItem>: Send + Sync {
    /// Return an error when `item` fails validation; `Ok(())` accepts it.
    fn validate(&self, item: &T) -> AppResult<()>;
}