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 schema_logsource(&self, schema: &str) -> Option<&LogSource>

The logsource a recognized schema implies, if any (built-in default or binding override). Used by the router to fill gaps in an event’s logsource before conflict-based pruning.

pub fn schemas_with_logsource(&self) -> Vec<String>

The recognized schema names that carry an implied logsource (built-in defaults plus binding overrides), sorted for deterministic output.

pub fn set_product_partition(&self) -> Vec<Option<HashSet<String>>>

For each pipeline-set index, the set of lowercased products whose rules are safe to keep when partitioning per-schema engines, or None to keep the full ruleset.

A set is partitionable only when every schema that can route to it (direct bindings plus aliases) implies a product; if any routing schema is product-less (cross-platform), the set keeps all rules. The default set (index 0) is never partitioned, because unbound and unknown events route there and could be any product. Callers still apply their own pipeline-safety check (a product-setting change_logsource disables partitioning for that set).

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.