Struct DistributedExecutor 

pub struct DistributedExecutor { /* private fields */ }

Distributed executor for multi-node graph execution

Implementations

impl DistributedExecutor

pub fn new() -> Self

Create a new distributed executor

pub fn with_timeout(self, timeout_ms: u64) -> Self

Set communication timeout

pub fn partition_graph( &mut self, graph: &ComputationGraph, worker_ids: &[String], ) -> Result<(), GraphError>

Partition a graph across multiple workers Uses a simple round-robin strategy for now

pub fn get_partition(&self, worker_id: &str) -> Option<&GraphPartition>

Get partition for a specific worker

pub fn get_partitions(&self) -> &HashMap<String, GraphPartition>

Get all partitions

pub fn get_assignment(&self, node_id: &str) -> Option<&NodeAssignment>

Get node assignment

pub fn execute_distributed( &self, _graph: &ComputationGraph, ) -> Result<HashMap<String, Vec<f32>>, GraphError>

Execute a distributed graph NOTE: This is a stub that will be integrated with ipfrs-network

pub fn estimate_communication_cost(&self, worker_id: &str) -> usize

Estimate communication cost for a partition

pub fn worker_count(&self) -> usize

Get total number of workers

pub fn timeout(&self) -> u64

Get timeout in milliseconds

Trait Implementations

impl Default for DistributedExecutor

fn default() -> Self

Returns the “default value” for a type.