Method GetLoadDistribution

pkg/consistent/consistent.go:351–363

GetLoadDistribution provides a thread-safe snapshot of the current load distribution across members. It returns a map where the keys are member identifiers and the values are their respective loads.

()

// GetLoadDistribution provides a thread-safe snapshot of the current load distribution across members.
// It returns a map where the keys are member identifiers and the values are their respective loads.
func (c *Consistent) GetLoadDistribution() map[string]float64 {
	// Acquire a read lock to ensure thread-safe access to the loads map.
	c.mu.RLock()
	defer c.mu.RUnlock()

	// Create a copy of the loads map to avoid exposing internal state.
	loadDistribution := make(map[string]float64)
	for memberName, memberLoad := range c.loads {
		loadDistribution[memberName] = memberLoad
	}

	return loadDistribution
}

// GetPartitionID calculates and returns the partition ID for a given key.
// The partition ID is determined by hashing the key and applying modulo operation with the partition count.