Struct EnsembleNode 

pub struct EnsembleNode { /* private fields */ }

Ensemble node for multi-model fusion.

This node runs multiple behaviors/models in parallel and combines their results using a configurable strategy. This is useful for:

• Combining multiple AI models for robust predictions
• Redundancy and fault tolerance
• Multi-modal sensor fusion

Strategies

• WeightedVote: Models vote with weights, success if total > threshold
• Conservative: All models must succeed (high precision, low recall)
• Optimistic: Any model can succeed (high recall, low precision)
• Majority: More than half must succeed (balanced)

Example

use mecha10_behavior_patterns::prelude::*;


let ensemble = EnsembleNode::new(EnsembleStrategy::WeightedVote)
    .add_model(Box::new(YoloV8), 0.4)
    .add_model(Box::new(YoloV10), 0.3)
    .add_model(Box::new(CustomDetector), 0.3);

Implementations

impl EnsembleNode

pub fn new(strategy: EnsembleStrategy) -> Self

Create a new ensemble node with the given strategy.

pub fn add_model(self, behavior: BoxedBehavior, weight: f32) -> Self

Add a model with a weight.

pub fn add_named_model( self, name: impl Into<String>, behavior: BoxedBehavior, weight: f32, ) -> Self

Add a named model.

pub fn with_threshold(self, threshold: f32) -> Self

Set the threshold for weighted voting (default 0.5).

pub fn model_count(&self) -> usize

Get the number of models in the ensemble.

Trait Implementations

impl BehaviorNode for EnsembleNode

fn tick<'life0, 'life1, 'async_trait>( &'life0 mut self, ctx: &'life1 Context, ) -> Pin<Box<dyn Future<Output = Result<NodeStatus>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Execute one tick of the behavior.

fn reset<'life0, 'async_trait>( &'life0 mut self, ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Reset the behavior to its initial state.

fn on_init<'life0, 'life1, 'async_trait>( &'life0 mut self, ctx: &'life1 Context, ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Called when the behavior is first initialized.

fn on_terminate<'life0, 'life1, 'async_trait>( &'life0 mut self, ctx: &'life1 Context, ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Called when the behavior is being terminated.

fn name(&self) -> &str

Get the name of this behavior node.

impl Debug for EnsembleNode

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

Formats the value using the given formatter.