Method GetPartitionOwner

pkg/consistent/consistent.go:377–384

GetPartitionOwner retrieves the owner of the specified partition in a thread-safe manner. It ensures that the access to shared resources is synchronized.

(partitionID int)

// GetPartitionOwner retrieves the owner of the specified partition in a thread-safe manner.
// It ensures that the access to shared resources is synchronized.
func (c *Consistent) GetPartitionOwner(partitionID int) Member {
	// Acquire a read lock to ensure thread-safe access to the partitions map.
	c.mu.RLock()
	defer c.mu.RUnlock()

	// Delegate the actual lookup to the non-thread-safe internal helper function.
	return c.getPartitionOwnerInternal(partitionID)
}

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