Struct LearningLifecycleHook 

pub struct LearningLifecycleHook { /* private fields */ }

Learning を自動実行する LifecycleHook

Swarm 終了時に TrainTrigger をチェックし、条件を満たせば Learn を実行。

Eval カウント

内部で Eval 実行回数をカウントし、CountTrigger と連携。 例: 10 回の Eval 後に Learn を実行。

非同期 Sink との違い

項目	LearningLifecycleHook	LearningSink (pipeline)
呼び出し	Orchestrator 終了時	ファイル監視イベント時
実行モデル	同期 callback	async trait
用途	Eval 終了後の即時学習	Daemon モードでの継続学習

将来拡張

• IPC/WebSocket で外部 Learner プロセスと通信
• DPO 学習の自動実行

Implementations

impl LearningLifecycleHook

pub fn new(learning_path: impl Into<PathBuf>) -> Self

新しい LearningLifecycleHook を作成

デフォルトは AlwaysTrigger（毎回 Learn 実行）。

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

TrainTrigger を設定

Example

use swarm_engine_core::learn::TriggerBuilder;

// 10 回の Eval 後に Learn 実行
let hook = LearningLifecycleHook::new(path)
    .with_trigger(TriggerBuilder::every_n_episodes(10));

pub fn with_scenario(self, scenario: impl Into<String>) -> Self

シナリオ名を設定

pub fn with_learn_callback<F>(self, callback: F) -> Self

where F: Fn(&str, &SwarmState) + Send + Sync + 'static,

Learn 実行コールバックを設定

デフォルトの Learn 実行ロジックをオーバーライド。 DPO 学習など、カスタムの学習処理を実行できる。

pub fn eval_count_handle(&self) -> Arc<AtomicUsize>

外部から eval_count を共有するための Arc を取得

複数の Orchestrator 間で Eval カウントを共有する場合に使用。

pub fn with_shared_eval_count(self, count: Arc<AtomicUsize>) -> Self

共有された eval_count を設定

pub fn current_eval_count(&self) -> usize

現在の Eval カウントを取得

pub fn learning_path(&self) -> &PathBuf

Learning パスを取得

Trait Implementations

impl LifecycleHook for LearningLifecycleHook

fn on_start(&mut self, worker_count: usize)

Swarm 開始時に呼ばれる

fn on_terminate(&mut self, state: &SwarmState, result: &SwarmResult)

Swarm 終了時に呼ばれる

fn name(&self) -> &str

Hook の名前（デバッグ用）