github/kubernetes
1
0
Fork 0
mirror of https://github.com/k3s-io/kubernetes.git synced 2025-09-12 20:57:20 +00:00
Code Issues Projects Releases Wiki Activity

Add a least-requested priority function

Browse Source
This commit is contained in:
Brendan Burns
2014-10-06 15:58:18 -07:00
parent 467a7a2cc1
commit 4230a8ca61
10 changed files with 218 additions and 25 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
plugin/pkg/scheduler/factory/factory.go
View File

@@ -202,9 +202,9 @@ type storeToMinionLister struct {
cache.Store
}
func (s *storeToMinionLister) List() (machines []string, err error) {
func (s *storeToMinionLister) List() (machines api.MinionList, err error) {
for _, m := range s.Store.List() {
machines = append(machines, m.(*api.Minion).ID)
machines.Items = append(machines.Items, *(m.(*api.Minion)))
}
return machines, nil
}

6
plugin/pkg/scheduler/factory/factory_test.go
View File

@@ -223,10 +223,14 @@ func TestStoreToMinionLister(t *testing.T) {
}
sml := storeToMinionLister{store}
got, err := sml.List()
gotNodes, err := sml.List()
if err != nil {
t.Fatalf("Unexpected error: %v", err)
}
got := make([]string, len(gotNodes.Items))
for ix := range gotNodes.Items {
got[ix] = gotNodes.Items[ix].ID
}
if !ids.HasAll(got...) || len(got) != len(ids) {
t.Errorf("Expected %v, got %v", ids, got)
}

6
plugin/pkg/scheduler/scheduler_test.go
View File

@@ -81,8 +81,10 @@ func TestScheduler(t *testing.T) {
var gotPod *api.Pod
var gotBinding *api.Binding
c := &Config{
MinionLister: scheduler.FakeMinionLister{"machine1"},
Algorithm: item.algo,
MinionLister: scheduler.FakeMinionLister(
api.MinionList{Items: []api.Minion{{TypeMeta: api.TypeMeta{ID: "machine1"}}}},
),
Algorithm: item.algo,
Binder: fakeBinder{func(b *api.Binding) error {
gotBinding = b
return item.injectBindError