scottk/kubernetes
1
0
Fork 0
mirror of https://github.com/optim-enterprises-bv/kubernetes.git synced 2025-11-04 04:08:16 +00:00
Code Issues Packages Projects Releases Wiki Activity

Add error handling for Register() call

Browse Source 
Register() can return an error as [1], so this adds the error handling.

[1]: f772c9017c/pkg/scheduler/framework/v1alpha1/registry.go (L56)
This commit is contained in:
Kenichi Omichi
2019-12-30 23:35:26 +00:00
parent a1364be012
commit 43d9748d3a
1 changed files with 4 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

5
test/integration/scheduler/preemption_test.go
View File

@@ -125,9 +125,12 @@ func TestPreemption(t *testing.T) {
// Initialize scheduler with a filter plugin. // Initialize scheduler with a filter plugin.
var filter tokenFilter var filter tokenFilter
registry := make(framework.Registry) registry := make(framework.Registry)
registry.Register(filterPluginName, func(_ *runtime.Unknown, fh framework.FrameworkHandle) (framework.Plugin, error) { err := registry.Register(filterPluginName, func(_ *runtime.Unknown, fh framework.FrameworkHandle) (framework.Plugin, error) {
return &filter, nil return &filter, nil
}) })
if err != nil {
t.Fatalf("Error registering a filter: %v", err)
}
plugins := &schedulerconfig.Plugins{ plugins := &schedulerconfig.Plugins{
Filter: &schedulerconfig.PluginSet{ Filter: &schedulerconfig.PluginSet{
Enabled: []schedulerconfig.Plugin{ Enabled: []schedulerconfig.Plugin{