github/kubernetes
1
0
Fork 0
mirror of https://github.com/k3s-io/kubernetes.git synced 2025-08-04 18:00:08 +00:00
Code Issues Projects Releases Wiki Activity

schduler: fix validation test

Browse Source 
Signed-off-by: sakeven <jc5930@sina.cn>
This commit is contained in:
sakeven 2017-06-30 19:19:21 +08:00
parent 0641386318
commit 86c453a192
1 changed files with 48 additions and 58 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

106
plugin/pkg/scheduler/api/validation/validation_test.go
View File

@ -17,70 +17,60 @@ limitations under the License.
package validation package validation
import ( import (
"errors"
"fmt"
"testing" "testing"
"k8s.io/kubernetes/plugin/pkg/scheduler/api" "k8s.io/kubernetes/plugin/pkg/scheduler/api"
) )
func TestValidatePriorityWithNoWeight(t *testing.T) { func TestValidatePolicy(t *testing.T) {
policy := api.Policy{Priorities: []api.PriorityPolicy{{Name: "NoWeightPriority"}}} tests := []struct {
if ValidatePolicy(policy) == nil { policy api.Policy
t.Errorf("Expected error about priority weight not being positive") expected error
} }{
} {
policy: api.Policy{Priorities: []api.PriorityPolicy{{Name: "NoWeightPriority"}}},
func TestValidatePriorityWithZeroWeight(t *testing.T) { expected: errors.New("Priority NoWeightPriority should have a positive weight applied to it or it has overflown"),
policy := api.Policy{Priorities: []api.PriorityPolicy{{Name: "NoWeightPriority", Weight: 0}}} },
if ValidatePolicy(policy) == nil { {
t.Errorf("Expected error about priority weight not being positive") policy: api.Policy{Priorities: []api.PriorityPolicy{{Name: "NoWeightPriority", Weight: 0}}},
} expected: errors.New("Priority NoWeightPriority should have a positive weight applied to it or it has overflown"),
} },
{
func TestValidatePriorityWithNonZeroWeight(t *testing.T) { policy: api.Policy{Priorities: []api.PriorityPolicy{{Name: "WeightPriority", Weight: 2}}},
policy := api.Policy{Priorities: []api.PriorityPolicy{{Name: "WeightPriority", Weight: 2}}} expected: nil,
errs := ValidatePolicy(policy) },
if errs != nil { {
t.Errorf("Unexpected errors %v", errs) policy: api.Policy{Priorities: []api.PriorityPolicy{{Name: "WeightPriority", Weight: -2}}},
} expected: errors.New("Priority WeightPriority should have a positive weight applied to it or it has overflown"),
} },
{
func TestValidatePriorityWithNegativeWeight(t *testing.T) { policy: api.Policy{Priorities: []api.PriorityPolicy{{Name: "WeightPriority", Weight: api.MaxWeight}}},
policy := api.Policy{Priorities: []api.PriorityPolicy{{Name: "WeightPriority", Weight: -2}}} expected: errors.New("Priority WeightPriority should have a positive weight applied to it or it has overflown"),
if ValidatePolicy(policy) == nil { },
t.Errorf("Expected error about priority weight not being positive") {
} policy: api.Policy{ExtenderConfigs: []api.ExtenderConfig{{URLPrefix: "http://127.0.0.1:8081/extender", FilterVerb: "filter", Weight: 2}}},
} expected: nil,
},
func TestValidatePriorityWithOverFlowWeight(t *testing.T) { {
policy := api.Policy{Priorities: []api.PriorityPolicy{{Name: "WeightPriority", Weight: api.MaxWeight}}} policy: api.Policy{ExtenderConfigs: []api.ExtenderConfig{{URLPrefix: "http://127.0.0.1:8081/extender", FilterVerb: "filter", Weight: -2}}},
if ValidatePolicy(policy) == nil { expected: errors.New("Priority for extender http://127.0.0.1:8081/extender should have a positive weight applied to it"),
t.Errorf("Expected error about priority weight not being overflown.") },
} {
} policy: api.Policy{
ExtenderConfigs: []api.ExtenderConfig{
func TestValidateExtenderWithNonNegativeWeight(t *testing.T) { {URLPrefix: "http://127.0.0.1:8081/extender", BindVerb: "bind", Weight: 2},
extenderPolicy := api.Policy{ExtenderConfigs: []api.ExtenderConfig{{URLPrefix: "http://127.0.0.1:8081/extender", FilterVerb: "filter", Weight: 2}}} {URLPrefix: "http://127.0.0.1:8082/extender", BindVerb: "bind", Weight: 2},
errs := ValidatePolicy(extenderPolicy) }},
if errs != nil { expected: errors.New("Only one extender can implement bind, found 2"),
t.Errorf("Unexpected errors %v", errs)
}
}
func TestValidateExtenderWithNegativeWeight(t *testing.T) {
extenderPolicy := api.Policy{ExtenderConfigs: []api.ExtenderConfig{{URLPrefix: "http://127.0.0.1:8081/extender", FilterVerb: "filter", Weight: -2}}}
if ValidatePolicy(extenderPolicy) == nil {
t.Errorf("Expected error about priority weight for extender not being positive")
}
}
func TestValidateMultipleExtendersWithBind(t *testing.T) {
extenderPolicy := api.Policy{
ExtenderConfigs: []api.ExtenderConfig{
{URLPrefix: "http://127.0.0.1:8081/extender", BindVerb: "bind"},
{URLPrefix: "http://127.0.0.1:8082/extender", BindVerb: "bind"},
}, },
} }
if ValidatePolicy(extenderPolicy) == nil {
t.Errorf("Expected failure when multiple extenders with bind") for _, test := range tests {
actual := ValidatePolicy(test.policy)
if fmt.Sprint(test.expected) != fmt.Sprint(actual) {
t.Errorf("expected: %s, actual: %s", test.expected, actual)
}
} }
} }