Method LocateKey

pkg/consistent/consistent.go:402–408

LocateKey determines the owner of the partition corresponding to the given key. It calculates the partition ID for the key and retrieves the associated member in a thread-safe manner.

(key []byte)

// LocateKey determines the owner of the partition corresponding to the given key.
// It calculates the partition ID for the key and retrieves the associated member in a thread-safe manner.
func (c *Consistent) LocateKey(key []byte) Member {
	// Calculate the partition ID based on the hash of the key.
	partitionID := c.GetPartitionID(key)

	// Retrieve the owner of the partition using the thread-safe method.
	return c.GetPartitionOwner(partitionID)
}

// closestN retrieves the closest N members to the given partition ID in the consistent hash ring.
// It ensures thread-safe access and validates that the requested count of members can be satisfied.