Skip to content

K
k3s
Commit aadd5ac8 authored by Kubernetes Submit Queue's avatar Kubernetes Submit Queue Committed by GitHub
Browse files
Options

Merge pull request #34618 from mwielgus/more-dep-tests

Automatic merge from submit-queue Add non default replica preferences test to federation depoyment tests cc: @quinton-hole
parents 44337ba8 493481ef
Hide whitespace changes
Inline Side-by-side
Showing with 12 additions and 0 deletions
federation/pkg/federation-controller/deployment/deploymentcontroller_test.go
View file @ aadd5ac8
...@@ -147,6 +147,18 @@ func TestDeploymentController(t *testing.T) { ...@@ -147,6 +147,18 @@ func TestDeploymentController(t *testing.T) {
clusterWatch.Add(cluster2) clusterWatch.Add(cluster2)
assert.NoError(t, CheckObjectFromChan(cluster1UpdateChan, checkDeployment(dep1, *dep1.Spec.Replicas/2))) assert.NoError(t, CheckObjectFromChan(cluster1UpdateChan, checkDeployment(dep1, *dep1.Spec.Replicas/2)))
assert.NoError(t, CheckObjectFromChan(cluster2CreateChan, checkDeployment(dep1, *dep1.Spec.Replicas/2))) assert.NoError(t, CheckObjectFromChan(cluster2CreateChan, checkDeployment(dep1, *dep1.Spec.Replicas/2)))
// Add new deployment with non-default replica placement preferences.
dep2 := newDeploymentWithReplicas("deployment2", 9)
dep2.Annotations = make(map[string]string)
dep2.Annotations[FedDeploymentPreferencesAnnotation] = `{"rebalance": true,
"clusters": {
"cluster1": {"weight": 2},
"cluster2": {"weight": 1}
}}`
deploymentsWatch.Add(dep2)
assert.NoError(t, CheckObjectFromChan(cluster1CreateChan, checkDeployment(dep2, 6)))
assert.NoError(t, CheckObjectFromChan(cluster2CreateChan, checkDeployment(dep2, 3)))
} }
func GetDeploymentFromChan(c chan runtime.Object) *extensionsv1.Deployment { func GetDeploymentFromChan(c chan runtime.Object) *extensionsv1.Deployment {
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment