Struct ConsistentHashAssigner 

pub struct ConsistentHashAssigner {
    pub vnodes_per_core: u32,
    pub seed: u64,
}

Consistent-hash based partition assigner.

Uses virtual nodes proportional to each node’s core count for weighted distribution. The hash ring is deterministic given the same set of nodes (fixed seed).

Fields

vnodes_per_core: u32

Number of virtual nodes per core.

seed: u64

Fixed seed for deterministic hashing.

Implementations

impl ConsistentHashAssigner

pub fn new() -> Self

Create a new assigner with default settings.

pub fn with_config(vnodes_per_core: u32, seed: u64) -> Self

Create a new assigner with custom virtual node count and seed.

Trait Implementations

impl Debug for ConsistentHashAssigner

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

Formats the value using the given formatter.

impl Default for ConsistentHashAssigner

fn default() -> Self

Returns the “default value” for a type.

impl PartitionAssigner for ConsistentHashAssigner

fn initial_assignment( &self, num_partitions: u32, nodes: &[NodeInfo], constraints: &AssignmentConstraints, ) -> AssignmentPlan

Generate an initial assignment for the given number of partitions.

fn rebalance( &self, current: &HashMap<u32, NodeId>, nodes: &[NodeInfo], constraints: &AssignmentConstraints, ) -> AssignmentPlan

Generate a rebalance plan given the current assignments and new node set.

fn validate_plan( &self, plan: &AssignmentPlan, nodes: &[NodeInfo], constraints: &AssignmentConstraints, ) -> Vec<String>

Validate that an assignment plan satisfies the given constraints.