Struct EnrichConfig 

pub struct EnrichConfig {
    pub connector: Template,
    pub method: HttpMethod,
    pub path: Option<Template>,
    pub merge_path: Template,
    pub timeout_ms: Template,
    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: Template

Named connector reference. A JSONLogic expression, as HttpCallConfig::connector; read it through Self::resolve_connector.

method: HttpMethod

HTTP method for the enrichment call

path: Option<Template>

Enrichment path, as a JSONLogic expression. Read it through Self::resolve_path.

Back-compat: path_logic is kept as an alias for the pre-3.9 spelling, as on HttpCallConfig::path.

merge_path: Template

Dot-path where enrichment data is merged into the message context, as a JSONLogic expression. Read it through Self::resolve_merge_path.

timeout_ms: Template

Request timeout in milliseconds (default: 30000). Read it through Self::resolve_timeout_ms.

on_error: EnrichErrorAction

What to do on enrichment failure

Implementations

impl EnrichConfig

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

Resolve the connector name for this message.

Errors

As resolve_opt_string.

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

Resolve the enrichment path. Ok(None) when no path is configured.

Errors

As HttpCallConfig::resolve_path.

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

Resolve the dot-path enrichment data is merged into.

Errors

As resolve_opt_string.

pub fn resolve_timeout_ms(&self, ctx: &TaskContext<'_>) -> Result<u64>

Resolve the request timeout in milliseconds.

Errors

As HttpCallConfig::resolve_timeout_ms.

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.