Struct CapabilityBasedBalancer 

pub struct CapabilityBasedBalancer { /* private fields */ }

Capability-based load balancer

Implementations

impl CapabilityBasedBalancer

pub fn new() -> Self

Trait Implementations

impl Debug for CapabilityBasedBalancer

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

Formats the value using the given formatter.

impl Default for CapabilityBasedBalancer

fn default() -> Self

Returns the “default value” for a type.

impl LoadBalancer for CapabilityBasedBalancer

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

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

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

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

fn get_balancer_metrics(&self) -> LoadBalancerMetrics