Struct DistributedQuantumOrchestrator 

pub struct DistributedQuantumOrchestrator { /* private fields */ }

Implementations

impl DistributedQuantumOrchestrator

pub fn new(config: DistributedOrchestratorConfig) -> Self

Create a new orchestrator with an empty node/workflow registry.

pub fn execute_distributed( &self, circuit: &str, ) -> Result<DistributedExecutionResult, String>

Attempt to execute a circuit on the distributed system.

This performs real local bookkeeping (execution-id allocation, node selection based on the actual registry and node capacity limits) but cannot dispatch work to a remote node because no network transport is implemented in this build. Rather than fabricate a successful result, it reports the specific reason execution could not proceed.

pub fn add_node(&mut self, node_info: NodeInfo) -> Result<(), String>

Register (or update) a node in the orchestrator’s registry.

pub fn remove_node(&mut self, node_id: &str) -> Result<(), String>

Remove a previously registered node from the registry.

pub fn get_node_status(&self, node_id: &str) -> Result<NodeStatus, String>

Look up the real, currently-recorded status of a registered node.

pub fn schedule_workflow( &self, workflow: DistributedWorkflow, ) -> Result<String, String>

Validate and register a workflow for scheduling, returning a real generated workflow id. The workflow’s step dependency graph is checked for cycles using a real topological sort (petgraph); a workflow whose dependencies form a cycle is rejected rather than silently accepted.

pub fn node_count(&self) -> usize

Number of nodes currently registered (used by callers/tests to observe real registry state).

pub fn workflow_count(&self) -> usize

Number of workflows currently scheduled.

Trait Implementations

impl Debug for DistributedQuantumOrchestrator

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.