Search Options

Results per page
Sort
Preferred Languages
Advance

Results 41 - 50 of 189 for newobj (0.13 sec)

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. 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)
  6. staging/src/k8s.io/apiserver/pkg/util/peerproxy/peerproxy.go

    	h.storageversionInformer = svi.Informer()
    
    	svi.Informer().AddEventHandler(cache.ResourceEventHandlerFuncs{
    		AddFunc: func(obj interface{}) {
    			h.addSV(obj)
    		},
    		UpdateFunc: func(oldObj, newObj interface{}) {
    			h.updateSV(oldObj, newObj)
    		},
    		DeleteFunc: func(obj interface{}) {
    			h.deleteSV(obj)
    		}})
    	return h
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Jul 19 00:36:22 UTC 2023
    - 2K bytes
    - Viewed (0)
  7. 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)
  8. 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)
  9. 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)
  10. 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)
Back to top