Method Add

pkg/consistent/consistent.go:285–298

Add safely adds a new member to the consistent hash circle. It ensures thread safety and redistributes partitions after adding the member.

(member Member)

// Add safely adds a new member to the consistent hash circle.
// It ensures thread safety and redistributes partitions after adding the member.
func (c *Consistent) Add(member Member) {
	// Acquire a write lock to ensure thread safety.
	c.mu.Lock()
	defer c.mu.Unlock()

	// Check if the member already exists in the ring. If it does, exit early.
	if _, exists := c.members[member.String()]; exists {
		return
	}

	// Add the member to the ring and redistribute partitions.
	c.addMemberToRing(member)
	c.distributePartitions()
}

// removeFromSortedSet removes a hash value from the sorted set of hashes.
func (c *Consistent) removeFromSortedSet(hashValue uint64) {