Struct LearnableSwarm 

pub struct LearnableSwarm { /* private fields */ }

学習機能付き Swarm

Orchestrator + LearningDaemon + Subscriber を統合管理する。

Implementations

impl LearnableSwarm

pub fn run_task(&mut self, task: SwarmTask) -> Result<SwarmResult, SwarmError>

タスクを実行

pub fn run(&mut self) -> SwarmResult

メインループを実行（タスクなし）

pub fn orchestrator(&self) -> &Orchestrator

Orchestrator への参照を取得

pub fn orchestrator_mut(&mut self) -> &mut Orchestrator

Orchestrator への可変参照を取得

pub fn dependency_graph(&self) -> Option<&DependencyGraph>

DependencyGraph への参照を取得

pub fn config(&self) -> &LearnableSwarmConfig

設定を取得

pub fn learning_store(&self) -> Option<&LearningStore>

LearningStore を取得

pub fn offline_model(&self) -> Option<&OfflineModel>

Offline model を取得

pub fn is_learning_enabled(&self) -> bool

学習機能が有効かどうか

pub fn take_shutdown_tx(&mut self) -> Option<Sender<()>>

Shutdown 送信チャンネルを取得（所有権を移動）

非同期 shutdown が不可能な環境（tokio runtime 内での block_on）で使用。 取得後、try_send(()) でシャットダウン信号を送信し、Drop で cleanup。

pub async fn shutdown(self)

Graceful shutdown

LearningDaemon と Subscriber を停止し、完了を待つ。 学習が有効な場合、shutdown 前に LearnStatsSnapshot Event を発行する。

pub fn shutdown_blocking(self)

同期的な shutdown（blocking）