Struct DistributedCoordinator 

pub struct DistributedCoordinator { /* private fields */ }

分散コーディネーター

Implementations

impl DistributedCoordinator

pub fn new(load_balancer: Arc<dyn LoadBalancer>) -> Self

pub async fn register_node(&self, node: NodeInfo)

ノードを登録

pub async fn unregister_node(&self, node_id: &str)

ノードを削除

pub async fn update_heartbeat(&self, node_id: &str)

ノードのハートビートを更新

pub async fn submit_workflow( &self, execution_id: WorkflowExecutionId, ) -> Result<String, WorkflowError>

ワークフロー実行を分散実行キューに追加

pub async fn assign_task( &self, task_id: &str, ) -> Result<Option<String>, WorkflowError>

利用可能なノードにタスクを割り当て

pub async fn complete_task( &self, task_id: &str, success: bool, ) -> Result<(), WorkflowError>

タスク完了を報告

pub async fn get_running_tasks(&self) -> Vec<DistributedTask>

実行中のタスクを取得

pub async fn get_node_load(&self, node_id: &str) -> Option<f64>

ノードの負荷情報を取得

pub async fn get_cluster_load(&self) -> f64

クラスター全体の負荷を取得

pub async fn cleanup_dead_nodes(&self, timeout: Duration)

デッドノードの検出とクリーンアップ

pub async fn failover_task( &self, _task_id: &str, ) -> Result<Option<String>, WorkflowError>

フェイルオーバー: 失敗したタスクを別のノードに再割り当て