Search Options

Results per page
Sort
Preferred Languages
Advance

Results 11 - 20 of 41 for newobj (0.36 sec)

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. 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)
  6. 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)
  7. 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)
  8. 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)
  9. 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)
  10. 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)
Back to top