Search Options

Results per page
Sort
Preferred Languages
Advance

Results 21 - 30 of 41 for newobj (0.12 sec)

  1. pkg/kube/kclient/clienttest/test_helpers.go

    	return controllers.EventHandler[controllers.Object]{
    		AddFunc: func(obj controllers.Object) {
    			tracker.Record("add/" + obj.GetName())
    		},
    		UpdateFunc: func(oldObj, newObj controllers.Object) {
    			tracker.Record("update/" + newObj.GetName())
    		},
    		DeleteFunc: func(obj controllers.Object) {
    			tracker.Record("delete/" + obj.GetName())
    		},
    	}
    }
    
    func Names[T controllers.Object](list []T) sets.String {
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Fri Feb 23 19:18:21 UTC 2024
    - 3.9K bytes
    - Viewed (0)
  2. src/go/ast/scope.go

    	Data any    // object-specific data; or nil
    	Type any    // placeholder for type information; may be nil
    }
    
    // NewObj creates a new object of a given kind and name.
    func NewObj(kind ObjKind, name string) *Object {
    	return &Object{Kind: kind, Name: name}
    }
    
    // Pos computes the source position of the declaration of an object name.
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Thu Mar 28 21:32:41 UTC 2024
    - 4.6K bytes
    - Viewed (0)
  3. pkg/controller/validatingadmissionpolicystatus/controller.go

    	}
    	reg, err := policyInformer.Informer().AddEventHandler(cache.ResourceEventHandlerFuncs{
    		AddFunc: func(obj interface{}) {
    			c.enqueuePolicy(obj)
    		},
    		UpdateFunc: func(oldObj, newObj interface{}) {
    			c.enqueuePolicy(newObj)
    		},
    	})
    	if err != nil {
    		return nil, err
    	}
    	c.policySynced = reg.HasSynced
    	return c, nil
    }
    
    func (c *Controller) enqueuePolicy(policy any) {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat May 04 18:33:12 UTC 2024
    - 5.3K bytes
    - Viewed (0)
  4. pkg/kube/krt/informer.go

    		AddExtendedFunc: func(obj I, initialSync bool) {
    			handler(Event[I]{
    				New:   &obj,
    				Event: controllers.EventAdd,
    			}, initialSync)
    		},
    		UpdateFunc: func(oldObj, newObj I) {
    			handler(Event[I]{
    				Old:   &oldObj,
    				New:   &newObj,
    				Event: controllers.EventUpdate,
    			}, false)
    		},
    		DeleteFunc: func(obj I) {
    			handler(Event[I]{
    				Old:   &obj,
    				Event: controllers.EventDelete,
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Mon Jun 10 11:01:46 UTC 2024
    - 6.1K bytes
    - Viewed (0)
  5. pkg/controller/serviceaccount/serviceaccounts_controller.go

    }
    
    // namespaceUpdated reacts to a Namespace update (or re-list) by creating a default ServiceAccount in the namespace if needed
    func (c *ServiceAccountsController) namespaceUpdated(oldObj interface{}, newObj interface{}) {
    	newNamespace := newObj.(*v1.Namespace)
    	c.queue.Add(newNamespace.Name)
    }
    
    func (c *ServiceAccountsController) runWorker(ctx context.Context) {
    	for c.processNextWorkItem(ctx) {
    	}
    }
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat May 04 18:33:12 UTC 2024
    - 7.5K bytes
    - Viewed (0)
  6. staging/src/k8s.io/apiextensions-apiserver/pkg/controller/openapiv3/controller.go

    	klog.V(4).Infof("Adding customresourcedefinition %s", castObj.Name)
    	c.enqueue(castObj)
    }
    
    func (c *Controller) updateCustomResourceDefinition(oldObj, newObj interface{}) {
    	castNewObj := newObj.(*apiextensionsv1.CustomResourceDefinition)
    	klog.V(4).Infof("Updating customresourcedefinition %s", castNewObj.Name)
    	c.enqueue(castNewObj)
    }
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat May 04 18:33:12 UTC 2024
    - 7.9K bytes
    - Viewed (0)
  7. pkg/controller/namespace/namespace_controller.go

    		cache.ResourceEventHandlerFuncs{
    			AddFunc: func(obj interface{}) {
    				namespace := obj.(*v1.Namespace)
    				namespaceController.enqueueNamespace(namespace)
    			},
    			UpdateFunc: func(oldObj, newObj interface{}) {
    				namespace := newObj.(*v1.Namespace)
    				namespaceController.enqueueNamespace(namespace)
    			},
    		},
    		resyncPeriod,
    	)
    	namespaceController.lister = namespaceInformer.Lister()
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat May 04 18:33:12 UTC 2024
    - 7.6K bytes
    - Viewed (0)
  8. pkg/controlplane/controller/crdregistration/crdregistration_controller.go

    			c.enqueueCRD(cast)
    		},
    		UpdateFunc: func(oldObj, newObj interface{}) {
    			// Enqueue both old and new object to make sure we remove and add appropriate API services.
    			// The working queue will resolve any duplicates and only changes will stay in the queue.
    			c.enqueueCRD(oldObj.(*apiextensionsv1.CustomResourceDefinition))
    			c.enqueueCRD(newObj.(*apiextensionsv1.CustomResourceDefinition))
    		},
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat May 04 18:33:12 UTC 2024
    - 8.3K bytes
    - Viewed (0)
  9. staging/src/k8s.io/apiextensions-apiserver/pkg/controller/openapi/controller.go

    	klog.V(4).Infof("Adding customresourcedefinition %s", castObj.Name)
    	c.enqueue(castObj)
    }
    
    func (c *Controller) updateCustomResourceDefinition(oldObj, newObj interface{}) {
    	castNewObj := newObj.(*apiextensionsv1.CustomResourceDefinition)
    	klog.V(4).Infof("Updating customresourcedefinition %s", castNewObj.Name)
    	c.enqueue(castNewObj)
    }
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat May 04 18:33:12 UTC 2024
    - 9.6K bytes
    - Viewed (0)
  10. pkg/controlplane/controller/legacytokentracking/controller.go

    		creationRatelimiter: limiter,
    		clock:               cl,
    	}
    
    	informer.AddEventHandler(cache.ResourceEventHandlerFuncs{
    		AddFunc: func(obj interface{}) {
    			c.enqueue()
    		},
    		UpdateFunc: func(oldObj, newObj interface{}) {
    			c.enqueue()
    		},
    		DeleteFunc: func(obj interface{}) {
    			c.enqueue()
    		},
    	})
    
    	return c
    }
    
    func (c *Controller) enqueue() {
    	c.queue.Add(queueKey)
    }
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat May 04 18:33:12 UTC 2024
    - 6K bytes
    - Viewed (0)
Back to top