mirrors/node-feature-discovery
1
0
Fork 0
mirror of https://github.com/kubernetes-sigs/node-feature-discovery.git synced 2024-12-14 11:57:51 +00:00
Code Activity

nfd-master: add error checking for CRD controller creation

Browse source
This commit is contained in:
Markus Lehtonen 2022-12-14 00:27:27 +02:00
parent 6975680195
commit 079655b42c
2 changed files with 10 additions and 5 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

10
pkg/nfd-master/nfd-api-controller.go
View file

@ -37,7 +37,7 @@ type nfdController struct {
stopChan chan struct{}
}
func newNfdController(config *restclient.Config) *nfdController {
func newNfdController(config *restclient.Config) (*nfdController, error) {
c := &nfdController{
stopChan: make(chan struct{}, 1),
}
@ -46,7 +46,7 @@ func newNfdController(config *restclient.Config) *nfdController {
informerFactory := nfdinformers.NewSharedInformerFactory(nfdClient, 5*time.Minute)
ruleInformer := informerFactory.Nfd().V1alpha1().NodeFeatureRules()
_, _ = ruleInformer.Informer().AddEventHandler(cache.ResourceEventHandlerFuncs{
if _, err := ruleInformer.Informer().AddEventHandler(cache.ResourceEventHandlerFuncs{
AddFunc: func(object interface{}) {
key, _ := cache.MetaNamespaceKeyFunc(object)
klog.V(2).Infof("NodeFeatureRule %v added", key)
@ -59,14 +59,16 @@ func newNfdController(config *restclient.Config) *nfdController {
key, _ := cache.MetaNamespaceKeyFunc(object)
klog.V(2).Infof("NodeFeatureRule %v deleted", key)
},
})
}); err != nil {
return nil, err
}
informerFactory.Start(c.stopChan)
utilruntime.Must(nfdv1alpha1.AddToScheme(nfdscheme.Scheme))
c.ruleLister = ruleInformer.Lister()
return c
return c, nil
}
func (c *nfdController) stop() {

5
pkg/nfd-master/nfd-master.go
View file

@ -155,7 +155,10 @@ func (m *nfdMaster) Run() error {
return err
}
klog.Info("starting nfd api controller")
m.nfdController = newNfdController(kubeconfig)
m.nfdController, err = newNfdController(kubeconfig)
if err != nil {
return fmt.Errorf("failed to initialize CRD controller: %w", err)
}
}
if !m.args.NoPublish {