Search Options

Results per page
Sort
Preferred Languages
Advance

Results 31 - 38 of 38 for oldObj (0.88 sec)

  1. pkg/registry/core/service/storage/storage.go

    			txn.Commit()
    		} else {
    			txn.Revert()
    		}
    	}
    
    	return finish, nil
    }
    
    func (r *REST) beginUpdate(ctx context.Context, obj, oldObj runtime.Object, options *metav1.UpdateOptions) (genericregistry.FinishFunc, error) {
    	newSvc := obj.(*api.Service)
    	oldSvc := oldObj.(*api.Service)
    
    	// Make sure the existing object has all fields we expect to be defaulted.
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Apr 11 13:09:33 UTC 2024
    - 22.3K bytes
    - Viewed (0)
  2. pkg/scheduler/util/assumecache/assume_cache.go

    	} else {
    		c.logger.V(10).Info("Adding object to assume cache", "description", c.description, "cacheKey", name, "assumeCache", obj)
    	}
    }
    
    func (c *AssumeCache) update(oldObj interface{}, newObj interface{}) {
    	c.add(newObj)
    }
    
    func (c *AssumeCache) delete(obj interface{}) {
    	if obj == nil {
    		return
    	}
    
    	name, err := cache.DeletionHandlingMetaNamespaceKeyFunc(obj)
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Apr 25 09:46:58 UTC 2024
    - 10.6K bytes
    - Viewed (0)
  3. pkg/controller/cronjob/cronjob_controllerv2.go

    	})
    
    	cronJobsInformer.Informer().AddEventHandler(cache.ResourceEventHandlerFuncs{
    		AddFunc: func(obj interface{}) {
    			jm.enqueueController(obj)
    		},
    		UpdateFunc: func(oldObj, newObj interface{}) {
    			jm.updateCronJob(logger, oldObj, newObj)
    		},
    		DeleteFunc: func(obj interface{}) {
    			jm.enqueueController(obj)
    		},
    	})
    
    	metrics.Register()
    
    	return jm, nil
    }
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu May 09 03:34:25 UTC 2024
    - 29.2K bytes
    - Viewed (0)
  4. pkg/controlplane/controller/clusterauthenticationtrust/cluster_authentication_trust_controller.go

    			// so we don't have to be choosy about our key.
    			AddFunc: func(obj interface{}) {
    				c.queue.Add(keyFn())
    			},
    			UpdateFunc: func(oldObj, newObj interface{}) {
    				c.queue.Add(keyFn())
    			},
    			DeleteFunc: func(obj interface{}) {
    				c.queue.Add(keyFn())
    			},
    		},
    	})
    
    	return c
    }
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat May 04 18:33:12 UTC 2024
    - 18.2K bytes
    - Viewed (0)
  5. pkg/controller/servicecidrs/servicecidrs_controller.go

    	if !ok {
    		return
    	}
    	c.queue.Add(cidr.Name)
    	for _, key := range c.overlappingServiceCIDRs(cidr) {
    		c.queue.Add(key)
    	}
    }
    
    func (c *Controller) updateServiceCIDR(oldObj, obj interface{}) {
    	key, err := cache.MetaNamespaceKeyFunc(obj)
    	if err == nil {
    		c.queue.Add(key)
    	}
    }
    
    // deleteServiceCIDR
    func (c *Controller) deleteServiceCIDR(obj interface{}) {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat May 04 18:33:12 UTC 2024
    - 18K bytes
    - Viewed (0)
  6. src/runtime/map_faststr.go

    	if c := h.oldbuckets; c != nil {
    		if !h.sameSizeGrow() {
    			// There used to be half as many buckets; mask down one more power of two.
    			m >>= 1
    		}
    		oldb := (*bmap)(add(c, (hash&m)*uintptr(t.BucketSize)))
    		if !evacuated(oldb) {
    			b = oldb
    		}
    	}
    	top := tophash(hash)
    	for ; b != nil; b = b.overflow(t) {
    		for i, kptr := uintptr(0), b.keys(); i < abi.MapBucketCount; i, kptr = i+1, add(kptr, 2*goarch.PtrSize) {
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Thu May 23 01:17:26 UTC 2024
    - 15.3K bytes
    - Viewed (0)
  7. src/runtime/map_fast64.go

    		if c := h.oldbuckets; c != nil {
    			if !h.sameSizeGrow() {
    				// There used to be half as many buckets; mask down one more power of two.
    				m >>= 1
    			}
    			oldb := (*bmap)(add(c, (hash&m)*uintptr(t.BucketSize)))
    			if !evacuated(oldb) {
    				b = oldb
    			}
    		}
    	}
    	for ; b != nil; b = b.overflow(t) {
    		for i, k := uintptr(0), b.keys(); i < abi.MapBucketCount; i, k = i+1, add(k, 8) {
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Thu May 23 01:17:26 UTC 2024
    - 14.1K bytes
    - Viewed (0)
  8. src/runtime/map_fast32.go

    		if c := h.oldbuckets; c != nil {
    			if !h.sameSizeGrow() {
    				// There used to be half as many buckets; mask down one more power of two.
    				m >>= 1
    			}
    			oldb := (*bmap)(add(c, (hash&m)*uintptr(t.BucketSize)))
    			if !evacuated(oldb) {
    				b = oldb
    			}
    		}
    	}
    	for ; b != nil; b = b.overflow(t) {
    		for i, k := uintptr(0), b.keys(); i < abi.MapBucketCount; i, k = i+1, add(k, 4) {
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Thu May 23 01:17:26 UTC 2024
    - 13.9K bytes
    - Viewed (0)
Back to top