Struct ValidationRule 

pub struct ValidationRule {
    pub name: String,
    pub rule_type: ValidationRuleType,
    pub config: String,
    pub level: ValidationLevel,
    pub description: Option<String>,
    pub active: bool,
    pub applies_to: Vec<SchemaType>,
    pub subject_patterns: Vec<String>,
}

Content validation rule for custom schema validation

Validation rules extend beyond compatibility checking to enforce organizational policies and data quality requirements.

Examples

use rivven_schema::types::{ValidationRule, ValidationRuleType, ValidationLevel};

// Require a "doc" field in all Avro schemas
let doc_required = ValidationRule::new(
    "doc-required",
    ValidationRuleType::FieldRequired,
    r#"{"field": "doc"}"#,
).with_level(ValidationLevel::Error);

// Enforce naming convention
let naming_rule = ValidationRule::new(
    "pascal-case",
    ValidationRuleType::NamingConvention,
    r#"{"pattern": "^[A-Z][a-zA-Z0-9]*$"}"#,
);

Fields

name: String

Unique rule name

rule_type: ValidationRuleType

Rule type

config: String

Rule configuration (JSON)

level: ValidationLevel

Validation level

description: Option<String>

Description of what the rule checks

active: bool

Whether the rule is active

applies_to: Vec<SchemaType>

Schema types this rule applies to (empty = all)

subject_patterns: Vec<String>

Subjects this rule applies to (regex patterns, empty = all)

Implementations

impl ValidationRule

pub fn new( name: impl Into<String>, rule_type: ValidationRuleType, config: impl Into<String>, ) -> Self

Create a new validation rule

pub fn with_level(self, level: ValidationLevel) -> Self

Set the validation level

pub fn with_description(self, description: impl Into<String>) -> Self

Set the description

pub fn with_active(self, active: bool) -> Self

Set the active state

pub fn with_schema_types(self, types: Vec<SchemaType>) -> Self

Add schema types this rule applies to

pub fn with_subject_patterns(self, patterns: Vec<String>) -> Self

Add subject patterns this rule applies to

pub fn for_subjects(self, patterns: Vec<String>) -> Self

Alias for with_subject_patterns for convenience

pub fn for_schema_types(self, types: Vec<SchemaType>) -> Self

Alias for with_schema_types for convenience

pub fn applies(&self, schema_type: SchemaType, subject: &str) -> bool

Check if this rule applies to the given schema type and subject

pub fn name(&self) -> &str

Get the rule name

pub fn rule_type(&self) -> ValidationRuleType

Get the rule type

pub fn config(&self) -> &str

Get the rule config

pub fn level(&self) -> ValidationLevel

Get the validation level

pub fn description(&self) -> Option<&str>

Get the description

pub fn is_active(&self) -> bool

Check if the rule is active

Trait Implementations

impl Clone for ValidationRule

fn clone(&self) -> ValidationRule

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for ValidationRule

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for ValidationRule

fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Serialize for ValidationRule

fn serialize<__S>(&self, __serializer: __S) -> Result<__S::Ok, __S::Error>

where __S: Serializer,

Serialize this value into the given Serde serializer.