- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 41 for newobj (0.36 sec)
-
staging/src/k8s.io/apimachinery/pkg/util/managedfields/internal/structuredmerge.go
} // Update implements Manager. func (f *structuredMergeManager) Update(liveObj, newObj runtime.Object, managed Managed, manager string) (runtime.Object, Managed, error) { newObjVersioned, err := f.toVersioned(newObj) if err != nil { return nil, nil, fmt.Errorf("failed to convert new object (%v) to proper version (%v): %v", objectGVKNN(newObj), f.groupVersion, err) } liveObjVersioned, err := f.toVersioned(liveObj) if err != nil {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Oct 30 22:55:50 UTC 2023 - 7.3K bytes - Viewed (0) -
pkg/controller/certificates/rootcacertpublisher/publisher.go
utilruntime.HandleError(err) return } if cm.Name != RootCACertConfigMapName { return } c.queue.Add(cm.Namespace) } func (c *Publisher) configMapUpdated(_, newObj interface{}) { cm, err := convertToCM(newObj) if err != nil { utilruntime.HandleError(err) return } if cm.Name != RootCACertConfigMapName { return } c.queue.Add(cm.Namespace) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 6.8K bytes - Viewed (0) -
pkg/controller/storageversionmigrator/resourceversion.go
} _, _ = svmInformer.Informer().AddEventHandler(cache.ResourceEventHandlerFuncs{ AddFunc: func(obj interface{}) { rvController.addSVM(logger, obj) }, UpdateFunc: func(oldObj, newObj interface{}) { rvController.updateSVM(logger, oldObj, newObj) }, }) return rvController } func (rv *ResourceVersionController) addSVM(logger klog.Logger, obj interface{}) { svm := obj.(*svmv1alpha1.StorageVersionMigration)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 8.5K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/util/peerproxy/peerproxy.go
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jul 19 00:36:22 UTC 2023 - 2K bytes - Viewed (0) -
pkg/controller/ttl/ttl_controller.go
} }() ttlc.enqueueNode(logger, node) } func (ttlc *Controller) updateNode(logger klog.Logger, _, newObj interface{}) { node, ok := newObj.(*v1.Node) if !ok { utilruntime.HandleError(fmt.Errorf("unexpected object type: %v", newObj)) return } // Processing all updates of nodes guarantees that we will update // the ttl annotation, when cluster size changes.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 8.5K bytes - Viewed (0) -
pkg/scheduler/util/utils.go
// object stored in it will be converted instead. func As[T any](oldObj, newobj interface{}) (T, T, error) { var oldTyped T var newTyped T var ok bool if newobj != nil { newTyped, ok = newobj.(T) if !ok { return oldTyped, newTyped, fmt.Errorf("expected %T, but got %T", newTyped, newobj) } } if oldObj != nil {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Sep 21 01:40:44 UTC 2023 - 6.2K bytes - Viewed (0) -
pkg/controller/storageversionmigrator/storageversionmigrator.go
} _, _ = svmInformer.Informer().AddEventHandler(cache.ResourceEventHandlerFuncs{ AddFunc: func(obj interface{}) { svmController.addSVM(logger, obj) }, UpdateFunc: func(oldObj, newObj interface{}) { svmController.updateSVM(logger, oldObj, newObj) }, }) return svmController } func (svmc *SVMController) Name() string { return svmc.controllerName }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 9.5K bytes - Viewed (0) -
pkg/scheduler/framework/plugins/tainttoleration/taint_toleration.go
// pod schedulable. func (pl *TaintToleration) isSchedulableAfterNodeChange(logger klog.Logger, pod *v1.Pod, oldObj, newObj interface{}) (framework.QueueingHint, error) { originalNode, modifiedNode, err := util.As[*v1.Node](oldObj, newObj) if err != nil { return framework.Queue, err } wasUntolerated := true if originalNode != nil {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jun 12 13:26:09 UTC 2024 - 9.2K bytes - Viewed (0) -
pkg/scheduler/framework/plugins/schedulinggates/scheduling_gates.go
enableSchedulingQueueHint: fts.EnableSchedulingQueueHint, }, nil } func (pl *SchedulingGates) isSchedulableAfterPodChange(logger klog.Logger, pod *v1.Pod, oldObj, newObj interface{}) (framework.QueueingHint, error) { _, modifiedPod, err := util.As[*v1.Pod](oldObj, newObj) if err != nil { return framework.Queue, err } if modifiedPod.UID != pod.UID {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jun 12 13:26:09 UTC 2024 - 3.2K bytes - Viewed (0) -
pkg/scheduler/framework/plugins/nodeunschedulable/node_unschedulable.go
// pod schedulable. func (pl *NodeUnschedulable) isSchedulableAfterNodeChange(logger klog.Logger, pod *v1.Pod, oldObj, newObj interface{}) (framework.QueueingHint, error) { _, modifiedNode, err := util.As[*v1.Node](oldObj, newObj) if err != nil { return framework.Queue, err } if !modifiedNode.Spec.Unschedulable {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat Dec 16 12:50:11 UTC 2023 - 3.9K bytes - Viewed (0)