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

add scale down test for even distribution of replicas 

Signed-off-by: chaosi-zju <chaosi@zju.edu.cn>
This commit is contained in:
chaosi-zju 2023-12-14 16:27:25 +08:00
parent 57f13ced50
commit 265560be92
1 changed files with 73 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

76
pkg/scheduler/core/generic_scheduler_test.go
View File

@ -155,9 +155,9 @@ func Test_EvenDistributionOfReplicas(t *testing.T) {
}, },
// Test Case No.3 of even distribution of replicas // Test Case No.3 of even distribution of replicas
// 1. create deployment (replicas=7), weight=2:1:1:1 // 1. create deployment (replicas=7), weight=2:1:1:1
// 2. check three member cluster replicas, can be 3:2:1:1、3:1:2:1、3:1:1:2 // 2. check four member cluster replicas, can be 3:2:1:1、3:1:2:1、3:1:1:2
// 3. update replicas from 7 to 8 // 3. update replicas from 7 to 8
// 4. check three member cluster replicas, the added replica should lie in first cluster, i.e: // 4. check four member cluster replicas, the added replica should lie in first cluster, i.e:
// * 3:2:1:1 --> 4:2:1:1 // * 3:2:1:1 --> 4:2:1:1
// * 3:1:2:1 --> 4:1:2:1 // * 3:1:2:1 --> 4:1:2:1
// * 3:1:1:2 --> 4:1:1:2 // * 3:1:1:2 --> 4:1:1:2
@ -223,6 +223,76 @@ func Test_EvenDistributionOfReplicas(t *testing.T) {
}, },
wantErr: false, wantErr: false,
}, },
// Test Case No.4 of even distribution of replicas
// 1. create deployment (replicas=9), weight=2:1:1:1
// 2. check four member cluster replicas, can be 4:2:2:1、4:1:2:2、4:2:1:2
// 3. update replicas from 9 to 8
// 4. check four member cluster replicas, the reduced replica should be scaled down from cluster with 2 replicas previously, i.e:
// * 4:2:2:1 --> 4:2:1:1 or 4:1:2:1
// * 4:1:2:2 --> 4:1:1:2 or 4:1:2:1
// * 4:2:1:2 --> 4:1:1:2 or 4:2:1:1
{
name: "replica 9, static weighted 2:1:1:1, change replicas from 9 to 8, before change",
clusters: []*clusterv1alpha1.Cluster{
helper.NewCluster(ClusterMember1),
helper.NewCluster(ClusterMember2),
helper.NewCluster(ClusterMember3),
helper.NewCluster(ClusterMember4),
},
object: workv1alpha2.ResourceBindingSpec{
Replicas: 9,
},
placement: &policyv1alpha1.Placement{
ReplicaScheduling: &policyv1alpha1.ReplicaSchedulingStrategy{
ReplicaSchedulingType: policyv1alpha1.ReplicaSchedulingTypeDivided,
ReplicaDivisionPreference: policyv1alpha1.ReplicaDivisionPreferenceWeighted,
WeightPreference: &policyv1alpha1.ClusterPreferences{
StaticWeightList: []policyv1alpha1.StaticClusterWeight{
{TargetCluster: policyv1alpha1.ClusterAffinity{ClusterNames: []string{ClusterMember1}}, Weight: 2},
{TargetCluster: policyv1alpha1.ClusterAffinity{ClusterNames: []string{ClusterMember2}}, Weight: 1},
{TargetCluster: policyv1alpha1.ClusterAffinity{ClusterNames: []string{ClusterMember3}}, Weight: 1},
{TargetCluster: policyv1alpha1.ClusterAffinity{ClusterNames: []string{ClusterMember4}}, Weight: 1},
},
},
},
},
previousResultToNewResult: map[string][]string{
"": {"4:2:2:1", "4:1:2:2", "4:2:1:2"},
},
wantErr: false,
},
{
name: "replica 9, static weighted 2:1:1:1, change replicas from 9 to 8, after change",
clusters: []*clusterv1alpha1.Cluster{
helper.NewCluster(ClusterMember1),
helper.NewCluster(ClusterMember2),
helper.NewCluster(ClusterMember3),
helper.NewCluster(ClusterMember4),
},
object: workv1alpha2.ResourceBindingSpec{
Replicas: 8,
},
placement: &policyv1alpha1.Placement{
ReplicaScheduling: &policyv1alpha1.ReplicaSchedulingStrategy{
ReplicaSchedulingType: policyv1alpha1.ReplicaSchedulingTypeDivided,
ReplicaDivisionPreference: policyv1alpha1.ReplicaDivisionPreferenceWeighted,
WeightPreference: &policyv1alpha1.ClusterPreferences{
StaticWeightList: []policyv1alpha1.StaticClusterWeight{
{TargetCluster: policyv1alpha1.ClusterAffinity{ClusterNames: []string{ClusterMember1}}, Weight: 2},
{TargetCluster: policyv1alpha1.ClusterAffinity{ClusterNames: []string{ClusterMember2}}, Weight: 1},
{TargetCluster: policyv1alpha1.ClusterAffinity{ClusterNames: []string{ClusterMember3}}, Weight: 1},
{TargetCluster: policyv1alpha1.ClusterAffinity{ClusterNames: []string{ClusterMember4}}, Weight: 1},
},
},
},
},
previousResultToNewResult: map[string][]string{
"4:2:2:1": {"4:2:1:1", "4:1:2:1"},
"4:1:2:2": {"4:1:1:2", "4:1:2:1"},
"4:2:1:2": {"4:1:1:2", "4:2:1:1"},
},
wantErr: false,
},
} }
for _, tt := range tests { for _, tt := range tests {
t.Run(tt.name, func(t *testing.T) { t.Run(tt.name, func(t *testing.T) {
@ -242,7 +312,7 @@ func Test_EvenDistributionOfReplicas(t *testing.T) {
return return
} }
// 3. check if previous schedule result valid // 3. check if schedule result got match to expected
gotResult := targetClusterToString(got) gotResult := targetClusterToString(got)
for _, expectResult := range expect { for _, expectResult := range expect {
if gotResult == expectResult { if gotResult == expectResult {