Struct LearningEventSubscriber 

pub struct LearningEventSubscriber { /* private fields */ }

LearningEvent を受信して LearningDaemon に Record を送信

LearningEventChannel から LearningEvent を受信し、 Record に変換してバッチで LearningDaemon に送信する。

対応 Event

• LearningEvent::StrategyAdvice → StrategyAdviceRecord
• LearningEvent::DependencyGraphInference → DependencyGraphRecord
• LearningEvent::LearnStatsSnapshot → LearnStatsRecord

使用例

use swarm_engine_core::events::LearningEventChannel;
use swarm_engine_core::learn::daemon::{LearningEventSubscriber, EventSubscriberConfig};

let channel = LearningEventChannel::global();
channel.enable();

let subscriber = LearningEventSubscriber::new(channel.subscribe(), record_tx);
tokio::spawn(subscriber.run());

Implementations

impl LearningEventSubscriber

pub fn new(rx: Receiver<LearningEvent>, record_tx: Sender<Vec<Record>>) -> Self

新しい LearningEventSubscriber を作成

pub fn with_config( rx: Receiver<LearningEvent>, record_tx: Sender<Vec<Record>>, config: EventSubscriberConfig, ) -> Self

設定を指定して LearningEventSubscriber を作成

pub async fn run(self)

受信ループを開始

LearningEvent を受信し、Record に変換してバッチ送信する。 チャンネルが閉じられるか、送信先が閉じられたら終了。