Struct MapConfig 

pub struct MapConfig {
    pub mappings: Vec<MapMapping>,
}

Configuration for the map function containing a list of mappings.

Each mapping specifies a target path and a JSONLogic expression to evaluate. Mappings are processed sequentially, allowing later mappings to use results from earlier ones.

Fields

mappings: Vec<MapMapping>

List of mappings to execute in order.

Implementations

impl MapConfig

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

Parses a MapConfig from a JSON value.

Arguments

• input - JSON object containing a “mappings” array

Errors

Returns DataflowError::Validation if:

• The “mappings” field is missing
• The “mappings” field is not an array
• Any mapping is missing “path” or “logic” fields

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

Executes all map transformations using pre-compiled logic.

Processes each mapping sequentially, evaluating the JSONLogic expression and assigning the result to the target path. Changes are tracked for audit trail purposes.

Arguments

• message - The message to transform (modified in place)
• datalogic - DataLogic instance for evaluation
• logic_cache - Pre-compiled logic expressions

Returns

• Ok((status, changes)) - Status code (200 success, 500 if errors) and list of changes
• Err - If a critical error occurs during execution

Behavior

• Null evaluation results are skipped (no assignment made)
• Root field assignments (data, metadata, temp_data) merge objects instead of replacing
• Each successful assignment invalidates the context cache for subsequent mappings

Trait Implementations

impl Clone for MapConfig

fn clone(&self) -> MapConfig

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for MapConfig

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

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for MapConfig

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

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.