Struct RoutingPlan 

pub struct RoutingPlan { /* private fields */ }

A resolved routing plan: the deduplicated pipeline-sets to build one engine each, plus the schema-to-set mapping and the unknown-handling policy.

Pure data: it decides which pipeline-set an event routes to, leaving the engine construction and dispatch to the caller. The default set (index 0) is always present, so there is always a fallback target.

Implementations

impl RoutingPlan

pub fn from_config(config: &RoutingConfig) -> Self

Build a plan from a routing config, deduplicating identical pipeline-sets so the caller compiles each distinct set once.

pub fn pipeline_sets(&self) -> &[Vec<String>]

The deduplicated pipeline-sets, in index order (set 0 is the default). The caller builds one engine per entry.

pub fn on_unknown(&self) -> OnUnknown

The configured unknown-handling policy.

pub fn decide(&self, schema: Option<&str>) -> RouteDecision

Decide how to route an event given its classified schema (or None when nothing matched).

Trait Implementations

impl Clone for RoutingPlan

fn clone(&self) -> RoutingPlan

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for RoutingPlan

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

Formats the value using the given formatter.