Method getPartitionOwnerInternal

pkg/consistent/consistent.go:388–398

getPartitionOwnerInternal retrieves the owner of the specified partition without thread safety. This function assumes that synchronization has been handled by the caller.

(partitionID int)

// getPartitionOwnerInternal retrieves the owner of the specified partition without thread safety.
// This function assumes that synchronization has been handled by the caller.
func (c *Consistent) getPartitionOwnerInternal(partitionID int) Member {
	// Lookup the member associated with the given partition ID.
	member, exists := c.partitions[partitionID]
	if !exists {
		// If the partition ID does not exist, return a nil Member.
		return nil
	}

	// Return a copy of the member to ensure thread safety.
	return *member
}

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