Struct WeightedPlacementPlanner 

pub struct WeightedPlacementPlanner { /* private fields */ }

The weighted-placement, multi-signal rebalancer planner.

Holds only the PlacementPolicy; all live state is read through PlacementSignals at plan time, so one planner instance serves the whole cluster lifetime.

Implementations

impl WeightedPlacementPlanner

pub fn new(policy: PlacementPolicy) -> WeightedPlacementPlanner

A planner with the given policy.

pub fn policy(&self) -> &PlacementPolicy

pub fn plan_rebalance( &self, membership: &MembershipCatalog, ownership: &ShardOwnershipCatalog, signals: &impl PlacementSignals, ) -> RebalancePlan

Plan a rebalance across the whole ownership catalog without mutating it. Runs the primary capacity-balance pass, then the secondary hotspot-relief pass on top, and returns the combined RebalancePlan. Ranges owned by members that are not placement-eligible (draining members, witnesses) are left to the drain flow and never moved here.

pub fn plan_rebalance_scoped( &self, membership: &MembershipCatalog, ownership: &ShardOwnershipCatalog, signals: &impl PlacementSignals, authorities: &PlacementAuthorityCatalog, ) -> Result<AuthorityScopedRebalancePlan, PlacementAuthorityError>

Trait Implementations

impl Clone for WeightedPlacementPlanner

fn clone(&self) -> WeightedPlacementPlanner

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for WeightedPlacementPlanner

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

Formats the value using the given formatter.

impl Default for WeightedPlacementPlanner

fn default() -> WeightedPlacementPlanner

Returns the “default value” for a type.