Struct LearningSink 

pub struct LearningSink { /* private fields */ }

Learning sink - triggers offline learning when events arrive.

Uses spawn_blocking internally to run synchronous LearningStore::run_offline_learning without blocking the async runtime.

Trigger Integration

By default, learning runs on every event (AlwaysTrigger). Use with_trigger() to customize when learning runs:

let sink = LearningSink::new(path, 20)
    .with_trigger(TriggerBuilder::every_n_episodes(10));

Implementations

impl LearningSink

pub fn new(learning_path: PathBuf, max_sessions: usize) -> Self

Create a new learning sink.

By default, runs learning on every event (AlwaysTrigger).

Arguments

• learning_path - Path to learning data directory
• max_sessions - Maximum sessions to analyze

pub fn with_trigger(self, trigger: Arc<dyn TrainTrigger>) -> Self

Set a custom trigger for controlling when learning runs.

Example

use swarm_engine_core::learn::TriggerBuilder;

// Run learning every 10 events
let sink = LearningSink::new(path, 20)
    .with_trigger(TriggerBuilder::every_n_episodes(10));

// Run learning every 5 minutes OR when 50 events accumulated
let sink = LearningSink::new(path, 20)
    .with_trigger(Arc::new(OrTrigger::new(vec![
        TriggerBuilder::every_minutes(5),
        TriggerBuilder::every_n_episodes(50),
    ])));

pub fn learning_path(&self) -> &PathBuf

Get the learning path.

pub fn event_count(&self) -> usize

Get the current event count.

Trait Implementations

impl EventSink for LearningSink

type Event = WatchEvent

Event type consumed by this sink.

async fn process(&mut self, event: Self::Event) -> Result<(), SwarmError>

Process an event.