Struct Orchestrator 

pub struct Orchestrator { /* private fields */ }

Orchestrator - メインループ管理

Implementations

impl Orchestrator

pub fn validate(&self) -> Result<(), SwarmError>

Orchestrator の設定を検証

run_task() を呼ぶ前にこのメソッドで設定を検証できます。 run_task() 内でも同様のチェックが行われますが、事前に検証したい場合に使用します。

Errors

• SwarmError::NoWorkers: Worker が設定されていない
• SwarmError::MissingDependencyGraph: DependencyGraph のソースが設定されていない

Example

let orchestrator = OrchestratorBuilder::new()
    .add_worker(worker)
    .batch_invoker(invoker)
    .build(runtime);

// 事前検証
orchestrator.validate()?;

// タスク実行
let result = orchestrator.run_task(task)?;

impl Orchestrator

pub fn new( workers: Vec<Box<dyn WorkerAgent>>, config: SwarmConfig, runtime: Handle, ) -> Self

新規作成

pub fn with_analyzer(self, analyzer: Box<dyn Analyzer>) -> Self

Analyzer を設定

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

Manager を追加

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

BatchInvoker を設定

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

DependencyGraphProvider を設定

run_task() 時に ExplorationSpace がない場合、 このプロバイダーを使って DependencyGraph を自動生成する。

pub fn enable_partitioning(&mut self)

Worker パーティショニングを有効化

各 Manager に Worker を均等に割り当てる。 Manager ごとに担当 Worker のみの TaskContext を渡すため、 大規模システムでのスケーラビリティが向上する。

呼び出しタイミング

全ての Manager を追加した後に呼び出すこと。

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

DependencyGraph への参照を取得

ExplorationSpaceV2 に設定されている DependencyGraph を返す。 学習データ保存時に action_order を抽出するために使用。

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

タスクを設定してメインループを実行

SwarmTask を Extensions に登録してから run() を実行する。 Manager は state.shared.extensions.get::<SwarmTask>() でタスクを読み取れる。

Errors

• SwarmError::MissingDependencyGraph: DependencyGraph を生成できなかった

Example

let task = SwarmTask::new("Find the auth handler")
    .with_target_path("/path/to/repo");

let result = orchestrator.run_task(task)?;

pub fn run(&mut self) -> SwarmResult

メインループを実行

pub fn request_terminate(&mut self)

外部から終了を要求

pub fn termination_judge(&self) -> &TerminationJudge

TerminationJudge への参照を取得

pub fn termination_judge_mut(&mut self) -> &mut TerminationJudge

TerminationJudge への可変参照を取得

pub fn state(&self) -> &SwarmState

State への参照を取得

pub fn async_system(&self) -> &AsyncTaskSystem

AsyncTaskSystem への参照を取得

pub fn learned_provider(&self) -> Option<&SharedLearnedProvider>

LearnedProvider への参照を取得