Search Options

Results per page
Sort
Preferred Languages
Advance

Results 41 - 50 of 80 for newobj (0.12 sec)

  1. pkg/controller/ttlafterfinished/ttlafterfinished_controller.go

    	jobInformer.Informer().AddEventHandler(cache.ResourceEventHandlerFuncs{
    		AddFunc: func(obj interface{}) {
    			tc.addJob(logger, obj)
    		},
    		UpdateFunc: func(oldObj, newObj interface{}) {
    			tc.updateJob(logger, oldObj, newObj)
    		},
    	})
    
    	tc.jLister = jobInformer.Lister()
    	tc.jListerSynced = jobInformer.Informer().HasSynced
    
    	tc.clock = clock.RealClock{}
    
    	return tc
    }
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue May 07 23:59:28 UTC 2024
    - 10.4K bytes
    - Viewed (0)
  2. pkg/controller/garbagecollector/graph_builder.go

    				gvk:       kind,
    			}
    			gb.graphChanges.Add(event)
    		},
    		UpdateFunc: func(oldObj, newObj interface{}) {
    			// TODO: check if there are differences in the ownerRefs,
    			// finalizers, and DeletionTimestamp; if not, ignore the update.
    			event := &event{
    				eventType: updateEvent,
    				obj:       newObj,
    				oldObj:    oldObj,
    				gvk:       kind,
    			}
    			gb.graphChanges.Add(event)
    		},
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat May 04 18:33:12 UTC 2024
    - 36.9K bytes
    - Viewed (0)
  3. pkg/controller/disruption/disruption.go

    	podInformer.Informer().AddEventHandler(cache.ResourceEventHandlerFuncs{
    		AddFunc: func(obj interface{}) {
    			dc.addPod(logger, obj)
    		},
    		UpdateFunc: func(oldObj, newObj interface{}) {
    			dc.updatePod(logger, oldObj, newObj)
    		},
    		DeleteFunc: func(obj interface{}) {
    			dc.deletePod(logger, obj)
    		},
    	})
    	dc.podLister = podInformer.Lister()
    	dc.podListerSynced = podInformer.Informer().HasSynced
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat May 04 18:33:12 UTC 2024
    - 36.1K bytes
    - Viewed (0)
  4. pkg/controller/replicaset/replica_set.go

    		),
    	}
    
    	rsInformer.Informer().AddEventHandler(cache.ResourceEventHandlerFuncs{
    		AddFunc: func(obj interface{}) {
    			rsc.addRS(logger, obj)
    		},
    		UpdateFunc: func(oldObj, newObj interface{}) {
    			rsc.updateRS(logger, oldObj, newObj)
    		},
    		DeleteFunc: func(obj interface{}) {
    			rsc.deleteRS(logger, obj)
    		},
    	})
    	rsInformer.Informer().AddIndexers(cache.Indexers{
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat May 04 18:33:12 UTC 2024
    - 33.2K bytes
    - Viewed (0)
  5. pkg/scheduler/framework/plugins/nodevolumelimits/csi.go

    	}
    }
    
    func (pl *CSILimits) isSchedulableAfterPodDeleted(logger klog.Logger, pod *v1.Pod, oldObj, newObj interface{}) (framework.QueueingHint, error) {
    	deletedPod, _, err := util.As[*v1.Pod](oldObj, newObj)
    	if err != nil {
    		return framework.Queue, fmt.Errorf("unexpected objects in isSchedulableAfterPodDeleted: %w", err)
    	}
    
    	if len(deletedPod.Spec.Volumes) == 0 {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue May 14 18:07:11 UTC 2024
    - 16.6K bytes
    - Viewed (0)
  6. src/go/parser/resolver.go

    	for _, ident := range idents {
    		if ident.Obj != nil {
    			panic(fmt.Sprintf("%v: identifier %s already declared or resolved", ident.Pos(), ident.Name))
    		}
    		obj := ast.NewObj(kind, ident.Name)
    		// remember the corresponding declaration for redeclaration
    		// errors and global variable resolution/typechecking phase
    		obj.Decl = decl
    		obj.Data = data
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Thu Nov 02 12:56:53 UTC 2023
    - 15.8K bytes
    - Viewed (0)
  7. pkg/controller/statefulset/stateful_set.go

    		// lookup the statefulset and enqueue
    		AddFunc: func(obj interface{}) {
    			ssc.addPod(logger, obj)
    		},
    		// lookup current and old statefulset if labels changed
    		UpdateFunc: func(oldObj, newObj interface{}) {
    			ssc.updatePod(logger, oldObj, newObj)
    		},
    		// lookup statefulset accounting for deletion tombstones
    		DeleteFunc: func(obj interface{}) {
    			ssc.deletePod(logger, obj)
    		},
    	})
    	ssc.podLister = podInformer.Lister()
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Jun 05 19:06:41 UTC 2024
    - 18.5K bytes
    - Viewed (0)
  8. pkg/scheduler/framework/types.go

    // - `oldObj` `newObj`: the object involved in that event.
    //   - For example, the given event is "Node deleted", the `oldObj` will be that deleted Node.
    //   - `oldObj` is nil if the event is add event.
    //   - `newObj` is nil if the event is delete event.
    type QueueingHintFn func(logger klog.Logger, pod *v1.Pod, oldObj, newObj interface{}) (QueueingHint, error)
    
    type QueueingHint int
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Jun 12 19:28:17 UTC 2024
    - 36.7K bytes
    - Viewed (0)
  9. pkg/controller/util/node/controller_utils.go

    		}
    	}
    }
    
    // CreateUpdateNodeHandler creates a node update handler. (Common to lifecycle and ipam)
    func CreateUpdateNodeHandler(f func(oldNode, newNode *v1.Node) error) func(oldObj, newObj interface{}) {
    	return func(origOldObj, origNewObj interface{}) {
    		node := origNewObj.(*v1.Node).DeepCopy()
    		prevNode := origOldObj.(*v1.Node).DeepCopy()
    
    		if err := f(prevNode, node); err != nil {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Jul 05 23:39:52 UTC 2023
    - 10.6K bytes
    - Viewed (0)
  10. staging/src/k8s.io/apiserver/pkg/authentication/request/headerrequest/requestheader_controller.go

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