Method calculateAverageLoad

pkg/consistent/consistent.go:161–173

calculateAverageLoad is a private helper method that performs the actual calculation of the average load across all members. It is not thread-safe and should be called only from within methods that already manage locking.

()

// of the average load across all members. It is not thread-safe and should be called
// only from within methods that already manage locking.
func (c *Consistent) calculateAverageLoad() float64 {
	// If there are no members, return an average load of 0 to prevent division by zero.
	if len(c.members) == 0 {
		return 0
	}

	// Calculate the average load by dividing the total partition count by the number of members
	// and multiplying by the configured load factor.
	avgLoad := float64(c.partitionCount/uint64(len(c.members))) * c.config.Load

	// Use math.Ceil to round up the average load to the nearest whole number.
	return math.Ceil(avgLoad)
}

// assignPartitionWithLoad distributes a partition to a member based on the load factor.
// It ensures that no member exceeds the calculated average load while distributing partitions.