Struct CapabilityBasedQuantumBalancer 

pub struct CapabilityBasedQuantumBalancer {
    pub quantum_capability_weights: HashMap<String, f64>,
    pub quantum_performance_history: Arc<RwLock<HashMap<NodeId, QuantumPerformanceHistory>>>,
}

Capability-based quantum load balancer (base implementation)

Fields

quantum_capability_weights: HashMap<String, f64>

quantum_performance_history: Arc<RwLock<HashMap<NodeId, QuantumPerformanceHistory>>>

Implementations

impl CapabilityBasedQuantumBalancer

pub fn new() -> Self

Trait Implementations

impl Debug for CapabilityBasedQuantumBalancer

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

Formats the value using the given formatter.

impl Default for CapabilityBasedQuantumBalancer

fn default() -> Self

Returns the “default value” for a type.

impl LoadBalancer for CapabilityBasedQuantumBalancer

fn select_node<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, available_nodes: &'life1 [NodeInfo], requirements: &'life2 ResourceRequirements, ) -> Pin<Box<dyn Future<Output = Result<NodeId, DistributedComputationError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait,

fn update_node_metrics<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, node_id: &'life1 NodeId, metrics: &'life2 PerformanceMetrics, ) -> Pin<Box<dyn Future<Output = Result<(), DistributedComputationError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait,

fn get_balancer_metrics(&self) -> LoadBalancerMetrics

fn select_nodes( &self, partitions: &[CircuitPartition], available_nodes: &HashMap<NodeId, NodeInfo>, requirements: &ExecutionRequirements, ) -> Result<HashMap<Uuid, NodeId>, DistributedComputationError>

fn rebalance_load( &self, current_allocation: &HashMap<Uuid, NodeId>, nodes: &HashMap<NodeId, NodeInfo>, ) -> Option<HashMap<Uuid, NodeId>>

fn predict_execution_time( &self, partition: &CircuitPartition, node: &NodeInfo, ) -> Duration