Struct ValidationConfig 

pub struct ValidationConfig {
    pub rules: Vec<ValidationRule>,
}

Configuration for the validation function containing a list of rules.

Each rule specifies a JSONLogic condition that must evaluate to true for the validation to pass. If a rule evaluates to anything other than true, its error message is added to the message’s error list.

Fields

rules: Vec<ValidationRule>

List of validation rules to evaluate.

Implementations

impl ValidationConfig

pub fn from_json(input: &Value) -> Result<Self>

Parses a ValidationConfig from a JSON value.

Arguments

• input - JSON object containing a “rules” array

Errors

Returns DataflowError::Validation if:

• The “rules” field is missing
• The “rules” field is not an array
• Any rule is missing the “logic” field

pub fn execute( &self, message: &mut Message, datalogic: &Arc<DataLogic>, logic_cache: &[Arc<CompiledLogic>], ) -> Result<(usize, Vec<Change>)>

Executes all validation rules using pre-compiled logic.

Evaluates each rule sequentially against the message context. This is a read-only operation that does not modify message data.

Arguments

• message - The message to validate (errors are added to its error list)
• datalogic - DataLogic instance for evaluation
• logic_cache - Pre-compiled logic expressions

Returns

• Ok((200, [])) - All rules passed, no changes made
• Ok((400, [])) - One or more rules failed, errors added to message

Error Types

Validation errors are recorded with the following codes:

• VALIDATION_ERROR - Rule evaluated to non-true value
• EVALUATION_ERROR - Rule evaluation failed with an error
• COMPILATION_ERROR - Logic was not properly compiled

Trait Implementations

impl Clone for ValidationConfig

fn clone(&self) -> ValidationConfig

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for ValidationConfig

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

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for ValidationConfig

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

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.