Struct DistributedExecutor 

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

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 fn get_job_status(&self, job_id: &str) -> QuantRS2Result<ExecutionStatus>

Get the current execution status for a previously submitted job.

Returns QuantRS2Error::InvalidInput if no job with the given ID exists.

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

Cancel a queued or running job.

If the job is already completed, failed, or cancelled the call succeeds but the status is not changed. Returns QuantRS2Error::InvalidInput if no job with the given ID exists.

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

Retrieve the result record for a job.

Returns QuantRS2Error::InvalidInput if no job with the given ID exists. For jobs that are still queued or running the returned status field will reflect that; callers should check the status before consuming the result fields.

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.