-
Notifications
You must be signed in to change notification settings - Fork 879
Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
Added tests for scheduler/framework/plugins
Signed-off-by: Anuj Agrawal <[email protected]> Added tests for scheduler/framework/plugins Signed-off-by: Anuj Agrawal <[email protected]>
- Loading branch information
1 parent
6b18b6e
commit e818659
Showing
6 changed files
with
818 additions
and
0 deletions.
There are no files selected for viewing
147 changes: 147 additions & 0 deletions
147
pkg/scheduler/framework/plugins/apienablement/api_enablement_test.go
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
Original file line number | Diff line number | Diff line change |
---|---|---|
@@ -0,0 +1,147 @@ | ||
/* | ||
Copyright 2024 The Karmada Authors. | ||
Licensed under the Apache License, Version 2.0 (the "License"); | ||
you may not use this file except in compliance with the License. | ||
You may obtain a copy of the License at | ||
http://www.apache.org/licenses/LICENSE-2.0 | ||
Unless required by applicable law or agreed to in writing, software | ||
distributed under the License is distributed on an "AS IS" BASIS, | ||
WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. | ||
See the License for the specific language governing permissions and | ||
limitations under the License. | ||
*/ | ||
|
||
package apienablement | ||
|
||
import ( | ||
"context" | ||
"testing" | ||
|
||
"github.com/stretchr/testify/assert" | ||
metav1 "k8s.io/apimachinery/pkg/apis/meta/v1" | ||
|
||
clusterv1alpha1 "github.com/karmada-io/karmada/pkg/apis/cluster/v1alpha1" | ||
workv1alpha2 "github.com/karmada-io/karmada/pkg/apis/work/v1alpha2" | ||
"github.com/karmada-io/karmada/pkg/scheduler/framework" | ||
) | ||
|
||
func TestAPIEnablement_Filter(t *testing.T) { | ||
tests := []struct { | ||
name string | ||
bindingSpec *workv1alpha2.ResourceBindingSpec | ||
cluster *clusterv1alpha1.Cluster | ||
expectedCode framework.Code | ||
expectError bool | ||
}{ | ||
{ | ||
name: "API is enabled in cluster", | ||
bindingSpec: &workv1alpha2.ResourceBindingSpec{ | ||
Resource: workv1alpha2.ObjectReference{ | ||
APIVersion: "apps/v1", | ||
Kind: "Deployment", | ||
}, | ||
}, | ||
cluster: &clusterv1alpha1.Cluster{ | ||
ObjectMeta: metav1.ObjectMeta{ | ||
Name: "cluster1", | ||
}, | ||
Status: clusterv1alpha1.ClusterStatus{ | ||
APIEnablements: []clusterv1alpha1.APIEnablement{ | ||
{ | ||
GroupVersion: "apps/v1", | ||
Resources: []clusterv1alpha1.APIResource{ | ||
{ | ||
Kind: "Deployment", | ||
}, | ||
}, | ||
}, | ||
}, | ||
}, | ||
}, | ||
expectedCode: framework.Success, | ||
expectError: false, | ||
}, | ||
{ | ||
name: "API is not enabled in cluster", | ||
bindingSpec: &workv1alpha2.ResourceBindingSpec{ | ||
Resource: workv1alpha2.ObjectReference{ | ||
APIVersion: "custom.io/v1", | ||
Kind: "CustomResource", | ||
}, | ||
}, | ||
cluster: &clusterv1alpha1.Cluster{ | ||
ObjectMeta: metav1.ObjectMeta{ | ||
Name: "cluster1", | ||
}, | ||
Status: clusterv1alpha1.ClusterStatus{ | ||
APIEnablements: []clusterv1alpha1.APIEnablement{ | ||
{ | ||
GroupVersion: "apps/v1", | ||
Resources: []clusterv1alpha1.APIResource{ | ||
{ | ||
Kind: "Deployment", | ||
}, | ||
}, | ||
}, | ||
}, | ||
}, | ||
}, | ||
expectedCode: framework.Unschedulable, | ||
expectError: true, | ||
}, | ||
{ | ||
name: "cluster in target list with incomplete API enablements", | ||
bindingSpec: &workv1alpha2.ResourceBindingSpec{ | ||
Resource: workv1alpha2.ObjectReference{ | ||
APIVersion: "custom.io/v1", | ||
Kind: "CustomResource", | ||
}, | ||
Clusters: []workv1alpha2.TargetCluster{ | ||
{ | ||
Name: "cluster1", | ||
}, | ||
}, | ||
}, | ||
cluster: &clusterv1alpha1.Cluster{ | ||
ObjectMeta: metav1.ObjectMeta{ | ||
Name: "cluster1", | ||
}, | ||
Status: clusterv1alpha1.ClusterStatus{ | ||
Conditions: []metav1.Condition{ | ||
{ | ||
Type: clusterv1alpha1.ClusterConditionCompleteAPIEnablements, | ||
Status: metav1.ConditionFalse, | ||
}, | ||
}, | ||
}, | ||
}, | ||
expectedCode: framework.Success, | ||
expectError: false, | ||
}, | ||
} | ||
|
||
p := &APIEnablement{} | ||
for _, tt := range tests { | ||
t.Run(tt.name, func(t *testing.T) { | ||
result := p.Filter(context.Background(), tt.bindingSpec, nil, tt.cluster) | ||
assert.Equal(t, tt.expectedCode, result.Code()) | ||
assert.Equal(t, tt.expectError, result.AsError() != nil) | ||
}) | ||
} | ||
} | ||
|
||
func TestNew(t *testing.T) { | ||
plugin, err := New() | ||
assert.NoError(t, err) | ||
assert.NotNil(t, plugin) | ||
_, ok := plugin.(*APIEnablement) | ||
assert.True(t, ok) | ||
} | ||
|
||
func TestAPIEnablement_Name(t *testing.T) { | ||
p := &APIEnablement{} | ||
assert.Equal(t, Name, p.Name()) | ||
} |
160 changes: 160 additions & 0 deletions
160
pkg/scheduler/framework/plugins/clusteraffinity/cluster_affinity_test.go
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
Original file line number | Diff line number | Diff line change |
---|---|---|
@@ -0,0 +1,160 @@ | ||
/* | ||
Copyright 2024 The Karmada Authors. | ||
Licensed under the Apache License, Version 2.0 (the "License"); | ||
you may not use this file except in compliance with the License. | ||
You may obtain a copy of the License at | ||
http://www.apache.org/licenses/LICENSE-2.0 | ||
Unless required by applicable law or agreed to in writing, software | ||
distributed under the License is distributed on an "AS IS" BASIS, | ||
WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. | ||
See the License for the specific language governing permissions and | ||
limitations under the License. | ||
*/ | ||
|
||
package clusteraffinity | ||
|
||
import ( | ||
"context" | ||
"testing" | ||
|
||
"github.com/stretchr/testify/assert" | ||
metav1 "k8s.io/apimachinery/pkg/apis/meta/v1" | ||
|
||
clusterv1alpha1 "github.com/karmada-io/karmada/pkg/apis/cluster/v1alpha1" | ||
policyv1alpha1 "github.com/karmada-io/karmada/pkg/apis/policy/v1alpha1" | ||
workv1alpha2 "github.com/karmada-io/karmada/pkg/apis/work/v1alpha2" | ||
"github.com/karmada-io/karmada/pkg/scheduler/framework" | ||
) | ||
|
||
func TestClusterAffinity_Filter(t *testing.T) { | ||
tests := []struct { | ||
name string | ||
bindingSpec *workv1alpha2.ResourceBindingSpec | ||
bindingStatus *workv1alpha2.ResourceBindingStatus | ||
cluster *clusterv1alpha1.Cluster | ||
expectedCode framework.Code | ||
expectError bool | ||
}{ | ||
{ | ||
name: "matching affinity", | ||
bindingSpec: &workv1alpha2.ResourceBindingSpec{ | ||
Placement: &policyv1alpha1.Placement{ | ||
ClusterAffinity: &policyv1alpha1.ClusterAffinity{ | ||
ClusterNames: []string{"cluster1"}, | ||
}, | ||
}, | ||
}, | ||
cluster: &clusterv1alpha1.Cluster{ | ||
ObjectMeta: metav1.ObjectMeta{ | ||
Name: "cluster1", | ||
}, | ||
}, | ||
expectedCode: framework.Success, | ||
expectError: false, | ||
}, | ||
{ | ||
name: "non-matching affinity", | ||
bindingSpec: &workv1alpha2.ResourceBindingSpec{ | ||
Placement: &policyv1alpha1.Placement{ | ||
ClusterAffinity: &policyv1alpha1.ClusterAffinity{ | ||
ClusterNames: []string{"cluster2"}, | ||
}, | ||
}, | ||
}, | ||
cluster: &clusterv1alpha1.Cluster{ | ||
ObjectMeta: metav1.ObjectMeta{ | ||
Name: "cluster1", | ||
}, | ||
}, | ||
expectedCode: framework.Unschedulable, | ||
expectError: true, | ||
}, | ||
{ | ||
name: "matching affinity from ClusterAffinities", | ||
bindingSpec: &workv1alpha2.ResourceBindingSpec{ | ||
Placement: &policyv1alpha1.Placement{ | ||
ClusterAffinities: []policyv1alpha1.ClusterAffinityTerm{ | ||
{ | ||
AffinityName: "affinity1", | ||
ClusterAffinity: policyv1alpha1.ClusterAffinity{ | ||
ClusterNames: []string{"cluster1"}, | ||
}, | ||
}, | ||
}, | ||
}, | ||
}, | ||
bindingStatus: &workv1alpha2.ResourceBindingStatus{ | ||
SchedulerObservedAffinityName: "affinity1", | ||
}, | ||
cluster: &clusterv1alpha1.Cluster{ | ||
ObjectMeta: metav1.ObjectMeta{ | ||
Name: "cluster1", | ||
}, | ||
}, | ||
expectedCode: framework.Success, | ||
expectError: false, | ||
}, | ||
{ | ||
name: "no affinity specified", | ||
bindingSpec: &workv1alpha2.ResourceBindingSpec{ | ||
Placement: &policyv1alpha1.Placement{}, | ||
}, | ||
cluster: &clusterv1alpha1.Cluster{ | ||
ObjectMeta: metav1.ObjectMeta{ | ||
Name: "cluster1", | ||
}, | ||
}, | ||
expectedCode: framework.Success, | ||
expectError: false, | ||
}, | ||
} | ||
|
||
p := &ClusterAffinity{} | ||
|
||
for _, tt := range tests { | ||
t.Run(tt.name, func(t *testing.T) { | ||
result := p.Filter(context.Background(), tt.bindingSpec, tt.bindingStatus, tt.cluster) | ||
assert.Equal(t, tt.expectedCode, result.Code()) | ||
assert.Equal(t, tt.expectError, result.AsError() != nil) | ||
}) | ||
} | ||
} | ||
|
||
func TestClusterAffinity_Score(t *testing.T) { | ||
p := &ClusterAffinity{} | ||
spec := &workv1alpha2.ResourceBindingSpec{} | ||
cluster := &clusterv1alpha1.Cluster{} | ||
|
||
score, result := p.Score(context.Background(), spec, cluster) | ||
|
||
assert.Equal(t, framework.MinClusterScore, score) | ||
assert.Equal(t, framework.Success, result.Code()) | ||
} | ||
|
||
func TestClusterAffinity_ScoreExtensions(t *testing.T) { | ||
p := &ClusterAffinity{} | ||
assert.Equal(t, p, p.ScoreExtensions()) | ||
} | ||
|
||
func TestClusterAffinity_NormalizeScore(t *testing.T) { | ||
p := &ClusterAffinity{} | ||
result := p.NormalizeScore(context.Background(), nil) | ||
assert.Equal(t, framework.Success, result.Code()) | ||
} | ||
|
||
func TestNew(t *testing.T) { | ||
plugin, err := New() | ||
|
||
assert.NoError(t, err) | ||
assert.NotNil(t, plugin) | ||
_, ok := plugin.(*ClusterAffinity) | ||
assert.True(t, ok) | ||
} | ||
|
||
func TestClusterAffinity_Name(t *testing.T) { | ||
p := &ClusterAffinity{} | ||
assert.Equal(t, Name, p.Name()) | ||
} |
Oops, something went wrong.