- Sort Score
- Result 10 results
- Languages All
Results 41 - 50 of 80 for newobj (0.12 sec)
-
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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) -
staging/src/k8s.io/apiserver/pkg/authentication/request/headerrequest/requestheader_controller.go
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 10.9K bytes - Viewed (0)