Method Remove

pkg/consistent/consistent.go:313–347

Remove deletes a member from the consistent hash circle and redistributes partitions. If the member does not exist, the method exits early.

(memberName string)

// Remove deletes a member from the consistent hash circle and redistributes partitions.
// If the member does not exist, the method exits early.
func (c *Consistent) Remove(memberName string) {
	// Acquire a write lock to ensure thread-safe access.
	c.mu.Lock()
	defer c.mu.Unlock()

	// Check if the member exists in the hash ring. If not, exit early.
	if _, exists := c.members[memberName]; !exists {
		return
	}

	// Remove all replicas of the member from the hash ring and sorted set.
	for replicaIndex := 0; replicaIndex < c.config.ReplicationFactor; replicaIndex++ {
		// Generate the unique key for each replica of the member.
		replicaKey := []byte(fmt.Sprintf("%s%d", memberName, replicaIndex))
		hashValue := c.hasher(replicaKey)

		// Remove the hash value from the hash ring.
		delete(c.ring, hashValue)

		// Remove the hash value from the sorted set.
		c.removeFromSortedSet(hashValue)
	}

	// Remove the member from the members map.
	delete(c.members, memberName)

	// If no members remain, reset the partition table and exit.
	if len(c.members) == 0 {
		c.partitions = make(map[int]*Member)
		return
	}

	// Redistribute partitions among the remaining members.
	c.distributePartitions()
}

// 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.