Struct DistributedExecutor 

pub struct DistributedExecutor {
    pub backends: Vec<ExecutionBackend>,
    pub load_balancer: LoadBalancer,
    pub fault_tolerance: FaultToleranceConfig,
    pub scheduler: ExecutionScheduler,
    pub resource_manager: ResourceManager,
}

A distributed quantum circuit execution engine

This manages execution of quantum circuits across multiple backends, handling load balancing, fault tolerance, and result aggregation.

Fields

backends: Vec<ExecutionBackend>

Available execution backends

load_balancer: LoadBalancer

Load balancing strategy

fault_tolerance: FaultToleranceConfig

Fault tolerance configuration

scheduler: ExecutionScheduler

Execution scheduling policy

resource_manager: ResourceManager

Resource management

Implementations

impl DistributedExecutor

pub fn new() -> Self

Create a new distributed executor

pub fn add_backend(&mut self, backend: ExecutionBackend) -> QuantRS2Result<()>

Add a backend to the distributed executor

pub fn submit_job<const N: usize>( &mut self, job: DistributedJob<N>, ) -> QuantRS2Result<String>

Submit a job for distributed execution

pub const fn get_job_status( &self, job_id: &str, ) -> QuantRS2Result<ExecutionStatus>

Get execution status for a job

pub const fn cancel_job(&mut self, job_id: &str) -> QuantRS2Result<()>

Cancel a job

pub fn get_results(&self, job_id: &str) -> QuantRS2Result<DistributedResult>

Get results for a completed job

pub fn get_health_status(&self) -> SystemHealthStatus

Get system health status

Trait Implementations

impl Debug for DistributedExecutor

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

Formats the value using the given formatter.

impl Default for DistributedExecutor

fn default() -> Self

Returns the “default value” for a type.