- Sort Score
- Result 10 results
- Languages All
Results 41 - 50 of 189 for newobj (0.13 sec)
-
staging/src/k8s.io/apimachinery/pkg/runtime/converter_test.go
return } newObj := reflect.New(reflect.TypeOf(item).Elem()).Interface() err = runtime.NewTestUnstructuredConverter(simpleEquality).FromUnstructured(newUnstr, newObj) if err != nil { t.Errorf("FromUnstructured failed: %v", err) return } if !reflect.DeepEqual(item, newObj) { t.Errorf("Object changed, diff: %v", cmp.Diff(item, newObj)) } }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jul 11 16:02:13 UTC 2023 - 22.9K bytes - Viewed (0) -
staging/src/k8s.io/apimachinery/pkg/util/managedfields/internal/managedfieldsupdater.go
fieldManager: fieldManager, } } // Update implements Manager. func (f *managedFieldsUpdater) Update(liveObj, newObj runtime.Object, managed Managed, manager string) (runtime.Object, Managed, error) { self := "current-operation" object, managed, err := f.fieldManager.Update(liveObj, newObj, managed, self) if err != nil { return object, managed, err }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Mar 08 21:44:00 UTC 2023 - 2.7K 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/apimachinery/pkg/util/managedfields/internal/versioncheck.go
} // Update implements Manager. func (f *versionCheckManager) Update(liveObj, newObj runtime.Object, managed Managed, manager string) (runtime.Object, Managed, error) { // Nothing to do for updates, this is checked in many other places. return f.fieldManager.Update(liveObj, newObj, managed, manager) } // Apply implements Manager.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue May 16 20:03:48 UTC 2023 - 1.8K 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/scheduler/eventhandlers_test.go
name string oldObj interface{} newObj interface{} }{ { name: "pod updated with the same UID", oldObj: withPodName(podWithPort("oldUID", nodeName, 80), "pod"), newObj: withPodName(podWithPort("oldUID", nodeName, 8080), "pod"), }, { name: "pod updated with different UIDs", oldObj: withPodName(podWithPort("oldUID", nodeName, 80), "pod"),
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jan 10 14:38:54 UTC 2024 - 21.5K bytes - Viewed (0) -
pkg/scheduler/framework/plugins/nodeaffinity/node_affinity_test.go
args *config.NodeAffinityArgs pod *v1.Pod oldObj, newObj interface{} expectedHint framework.QueueingHint expectedErr bool }{ "backoff-wrong-new-object": { args: &config.NodeAffinityArgs{}, pod: podWithNodeAffinity.Obj(), newObj: "not-a-node", expectedHint: framework.Queue, expectedErr: true, },
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Dec 18 12:00:10 UTC 2023 - 38.7K bytes - Viewed (0) -
pkg/kube/kclient/index.go
addObj(obj) idx.mu.Unlock() if delegate != nil { delegate.OnAdd(obj, initialList) } }, UpdateFunc: func(oldObj, newObj any) { idx.mu.Lock() deleteObj(oldObj) addObj(newObj) idx.mu.Unlock() if delegate != nil { delegate.OnUpdate(oldObj, newObj) } }, DeleteFunc: func(obj any) { idx.mu.Lock() deleteObj(obj) idx.mu.Unlock() if delegate != nil {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu May 04 03:49:30 UTC 2023 - 3.5K 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)