Struct EnrichConfig 

pub struct EnrichConfig {
    pub connector: String,
    pub method: HttpMethod,
    pub path: Option<String>,
    pub path_logic: Option<Template>,
    pub merge_path: String,
    pub timeout_ms: u64,
    pub on_error: EnrichErrorAction,
}

Configuration for the enrich integration function.

Enrichment calls an external service and merges the response into the message context.

Unknown keys are rejected, as for HttpCallConfig. Note that the destination field here is merge_path and takes no alias — only HttpCallConfig::response_path accepts output.

Fields

connector: String

Named connector reference

method: HttpMethod

HTTP method for the enrichment call

path: Option<String>

Static path

path_logic: Option<Template>

JSONLogic expression to compute path dynamically. Compiled once at engine construction; read it through EnrichConfig::resolve_path.

merge_path: String

Dot-path where enrichment data is merged into the message context

timeout_ms: u64

Request timeout in milliseconds (default: 30000)

on_error: EnrichErrorAction

What to do on enrichment failure

Implementations

impl EnrichConfig

pub fn resolve_path(&self, ctx: &TaskContext<'_>) -> Result<Option<String>>

Resolve the enrichment path: path_logic when compiled, otherwise the static path. Ok(None) when neither is set.

Errors

As HttpCallConfig::resolve_path.

Trait Implementations

impl Clone for EnrichConfig

fn clone(&self) -> EnrichConfig

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for EnrichConfig

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

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for EnrichConfig

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

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.