Search Options

Results per page
Sort
Preferred Languages
Advance

Results 41 - 50 of 176 for newobj (0.2 sec)

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. 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)
  6. 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)
  7. 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)
  8. 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)
  9. pkg/scheduler/framework/plugins/noderesources/fit_test.go

    			if tc.expectedErr {
    				require.Error(t, err)
    				return
    			}
    			require.NoError(t, err)
    			require.Equal(t, tc.expectedHint, actualHint)
    		})
    	}
    }
    
    func Test_isSchedulableAfterNodeChange(t *testing.T) {
    	testcases := map[string]struct {
    		pod            *v1.Pod
    		oldObj, newObj interface{}
    		expectedHint   framework.QueueingHint
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Jun 12 13:26:09 UTC 2024
    - 57.4K bytes
    - Viewed (0)
  10. 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)
Back to top