- Sort Score
- Result 10 results
- Languages All
Results 1 - 3 of 3 for CreateDeleteNodeHandler (0.29 sec)
-
pkg/controller/util/node/controller_utils.go
if err := f(prevNode, node); err != nil { utilruntime.HandleError(fmt.Errorf("Error while processing Node Add/Delete: %v", err)) } } } // CreateDeleteNodeHandler creates a delete node handler. (Common to lifecycle and ipam) func CreateDeleteNodeHandler(logger klog.Logger, f func(node *v1.Node) error) func(obj interface{}) { return func(originalObj interface{}) { originalNode, isNode := originalObj.(*v1.Node)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jul 05 23:39:52 UTC 2023 - 10.6K bytes - Viewed (0) -
pkg/controller/tainteviction/taint_eviction.go
return nil }), UpdateFunc: controllerutil.CreateUpdateNodeHandler(func(oldNode, newNode *v1.Node) error { tm.NodeUpdated(oldNode, newNode) return nil }), DeleteFunc: controllerutil.CreateDeleteNodeHandler(logger, func(node *v1.Node) error { tm.NodeUpdated(node, nil) return nil }), }) if err != nil { return nil, fmt.Errorf("unable to add node event handler: %w", err) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 19.9K bytes - Viewed (0) -
pkg/controller/nodelifecycle/node_lifecycle_controller.go
return nil }), UpdateFunc: controllerutil.CreateUpdateNodeHandler(func(_, newNode *v1.Node) error { nc.nodeUpdateQueue.Add(newNode.Name) return nil }), DeleteFunc: controllerutil.CreateDeleteNodeHandler(logger, func(node *v1.Node) error { nc.nodesToRetry.Delete(node.Name) return nil }), }) nc.leaseLister = leaseInformer.Lister() nc.leaseInformerSynced = leaseInformer.Informer().HasSynced
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 51.6K bytes - Viewed (0)