Method addMemberToRing

pkg/consistent/consistent.go:260–281

addMemberToRing adds a member to the consistent hash ring and updates the sorted set of hashes.

(member Member)

// addMemberToRing adds a member to the consistent hash ring and updates the sorted set of hashes.
func (c *Consistent) addMemberToRing(member Member) {
	// Add replication factor entries for the member in the hash ring.
	for replicaIndex := 0; replicaIndex < c.config.ReplicationFactor; replicaIndex++ {
		// Generate a unique key for each replica of the member.
		replicaKey := []byte(fmt.Sprintf("%s%d", member.String(), replicaIndex))
		hashValue := c.hasher(replicaKey)

		// Add the hash value to the ring and associate it with the member.
		c.ring[hashValue] = &member

		// Append the hash value to the sorted set of hashes.
		c.sortedSet = append(c.sortedSet, hashValue)
	}

	// Sort the hash values to maintain the ring's order.
	sort.Slice(c.sortedSet, func(i, j int) bool {
		return c.sortedSet[i] < c.sortedSet[j]
	})

	// Add the member to the members map.
	c.members[member.String()] = &member
}

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