karmada-io
/
karmada
mirror of https://github.com/karmada-io/karmada.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Rename func to getClusterNameFromAnnotation to match with updated behavior 

Signed-off-by: yizhang-zen <yizhang@zendesk.com>
This commit is contained in:
yizhang-zen 2024-04-03 14:38:18 -07:00
parent b0da31afc1
commit 04395e3579
2 changed files with 6 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
pkg/controllers/status/work_status_controller.go
View File

@ -152,7 +152,7 @@ func (c *WorkStatusController) RunWorkQueue() {
// generateKey generates a key from obj, the key contains cluster, GVK, namespace and name.
func generateKey(obj interface{}) (util.QueueKey, error) {
resource := obj.(*unstructured.Unstructured)
cluster, err := getClusterNameFromLabel(resource)
cluster, err := getClusterNameFromAnnotation(resource)
if err != nil {
return nil, err
}
@ -164,8 +164,8 @@ func generateKey(obj interface{}) (util.QueueKey, error) {
return keys.FederatedKeyFunc(cluster, obj)
}
// getClusterNameFromLabel gets cluster name from ownerLabel, if label not exist, means resource is not created by karmada.
func getClusterNameFromLabel(resource *unstructured.Unstructured) (string, error) {
// getClusterNameFromAnnotation gets cluster name from ownerLabel, if label not exist, means resource is not created by karmada.
func getClusterNameFromAnnotation(resource *unstructured.Unstructured) (string, error) {
workNamespace, exist := resource.GetAnnotations()[workv1alpha2.WorkNamespaceAnnotation]
if !exist {
klog.V(4).Infof("Ignore resource(%s/%s/%s) which not managed by karmada", resource.GetKind(), resource.GetNamespace(), resource.GetName())

6
pkg/controllers/status/work_status_controller_test.go
View File

@ -382,7 +382,7 @@ func TestGenerateKey(t *testing.T) {
existErr: false,
},
{
name: "getClusterNameFromLabel failed",
name: "getClusterNameFromAnnotation failed",
obj: &unstructured.Unstructured{
Object: map[string]interface{}{
"apiVersion": "v1",
@ -437,7 +437,7 @@ func TestGenerateKey(t *testing.T) {
}
}
func TestGetClusterNameFromLabel(t *testing.T) {
func TestGetClusterNameFromAnnotation(t *testing.T) {
tests := []struct {
name string
resource *unstructured.Unstructured
@ -502,7 +502,7 @@ func TestGetClusterNameFromLabel(t *testing.T) {
for _, tt := range tests {
t.Run(tt.name, func(t *testing.T) {
actual, err := getClusterNameFromLabel(tt.resource)
actual, err := getClusterNameFromAnnotation(tt.resource)
assert.Equal(t, tt.expect, actual)
if tt.existErr {
assert.NotEmpty(t, err)