Struct LearnableSwarmBuilder 

pub struct LearnableSwarmBuilder { /* private fields */ }

学習機能付き Swarm のビルダー

Orchestrator + LearningDaemon + Subscriber を統合構築する。

Implementations

impl LearnableSwarmBuilder

pub fn new(runtime: Handle) -> Self

新しいビルダーを作成

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

シナリオ名を設定

pub fn with_learning(self, enabled: bool) -> Self

学習機能を有効化

Note: LearningEventChannel の有効化は build() 時に行われる。

pub fn data_dir(self, path: impl Into<PathBuf>) -> Self

データディレクトリを設定

pub fn swarm_config(self, config: SwarmConfig) -> Self

Swarm 設定を追加

pub fn add_worker(self, worker: Box<dyn WorkerAgent>) -> Self

Worker を追加

pub fn workers(self, workers: Vec<Box<dyn WorkerAgent>>) -> Self

複数の Workers を追加

pub fn add_manager(self, manager: Box<dyn ManagerAgent>) -> Self

Manager を追加

pub fn managers(self, managers: Vec<Box<dyn ManagerAgent>>) -> Self

複数の Managers を追加

pub fn batch_invoker(self, invoker: Box<dyn BatchInvoker>) -> Self

BatchInvoker を設定

pub fn dependency_provider( self, provider: Box<dyn DependencyGraphProvider>, ) -> Self

DependencyGraphProvider を設定

pub fn operator_provider( self, provider: Box<dyn OperatorProvider<NodeRules>>, ) -> Self

OperatorProvider を設定

pub fn extensions(self, extensions: Extensions) -> Self

Extensions を設定

pub fn dependency_graph(self, graph: DependencyGraph) -> Self

DependencyGraph を設定

pub fn offline_model(self, model: OfflineModel) -> Self

Offline model を設定

pub fn with_scenario_profile(self, profile: &ScenarioProfile) -> Self

ScenarioProfile から OfflineModel を生成して設定

ScenarioProfile の各コンポーネント（LearnedExploration, LearnedStrategy, LearnedDepGraph） を OfflineModel に変換し、Orchestrator に適用する。

Example

use swarm_engine_core::learn::{LearnableSwarmBuilder, ScenarioProfile};

let profile = load_profile("troubleshooting")?;
let swarm = LearnableSwarmBuilder::new(runtime.handle().clone())
    .with_scenario_profile(&profile)
    .build()?;

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

Offline model への参照を取得（build 前に参照する場合）

pub fn prior_snapshot(self, snapshot: LearningSnapshot) -> Self

Prior snapshot を設定

pub fn learning_store(self, store: LearningStore) -> Self

LearningStore を設定（ロードなし、store のみ設定）

pub fn with_learning_store(self, store: LearningStore) -> Self

既存の LearningStore からシナリオデータを自動ロード

prior_snapshot, offline_model, data_dir を自動設定し、learning を有効化する。 EvalRunner など、store を保持し続ける必要がある場合に使用。

Note

ロード時のクリティカルエラー（permission denied 等）は build() 時に返される。 NotFound（初回実行）は正常として扱われる。

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

Train trigger を設定

pub fn lifecycle_hook(self, hook: Box<dyn LifecycleHook>) -> Self

LifecycleHook を設定

pub fn enable_exploration(self, enabled: bool) -> Self

Exploration を有効化

pub fn with_trace_subscriber(self, subscriber: Arc<dyn TraceSubscriber>) -> Self

TraceSubscriber を設定（ActionEvent のトレース出力）

Example

use swarm_engine_core::events::{InMemoryTraceSubscriber, JsonlTraceSubscriber};

// InMemory: 最後にまとめて出力
let trace = Arc::new(InMemoryTraceSubscriber::new());
builder.with_trace_subscriber(trace.clone());

// Jsonl: リアルタイム出力
let trace = Arc::new(JsonlTraceSubscriber::new("trace.jsonl")?);
builder.with_trace_subscriber(trace);

pub fn with_learning_store_path(self, path: impl AsRef<Path>) -> Self

LearningStore からシナリオデータを自動ロード（パス指定）

prior_snapshot と offline_model を自動設定する。

Note

Store 作成失敗やロード時のクリティカルエラーは build() 時に返される。

pub fn build(self) -> Result<LearnableSwarm, SwarmError>

LearnableSwarm を構築