Search Options

Results per page
Sort
Preferred Languages
Advance

Results 11 - 20 of 131 for UpdateFunc (0.79 sec)

  1. pkg/registry/apps/daemonset/storage/storage_test.go

    	test.TestUpdate(
    		// valid
    		newValidDaemonSet(),
    		// updateFunc
    		func(obj runtime.Object) runtime.Object {
    			object := obj.(*apps.DaemonSet)
    			object.Spec.Template.Spec.NodeSelector = map[string]string{"c": "d"}
    			object.Spec.Template.Spec.DNSPolicy = api.DNSDefault
    			return object
    		},
    		// invalid updateFunc
    		func(obj runtime.Object) runtime.Object {
    			object := obj.(*apps.DaemonSet)
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Aug 12 20:55:35 UTC 2019
    - 5.3K bytes
    - Viewed (0)
  2. pkg/registry/admissionregistration/validatingadmissionpolicy/storage/storage_test.go

    	test.TestUpdate(
    		// valid
    		validValidatingAdmissionPolicy(),
    		// updateFunc
    		func(obj runtime.Object) runtime.Object {
    			object := obj.(*admissionregistration.ValidatingAdmissionPolicy)
    			object.Labels = map[string]string{"c": "d"}
    			return object
    		},
    		// invalid updateFunc
    		func(obj runtime.Object) runtime.Object {
    			object := obj.(*admissionregistration.ValidatingAdmissionPolicy)
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Mar 07 23:43:34 UTC 2023
    - 6.9K bytes
    - Viewed (0)
  3. pkg/registry/core/configmap/storage/storage_test.go

    	test := genericregistrytest.New(t, storage.Store)
    	test.TestUpdate(
    		// valid
    		validNewConfigMap(),
    		// updateFunc
    		func(obj runtime.Object) runtime.Object {
    			cfg := obj.(*api.ConfigMap)
    			cfg.Data["update-test"] = "value"
    			return cfg
    		},
    		// invalid updateFunc
    		func(obj runtime.Object) runtime.Object {
    			cfg := obj.(*api.ConfigMap)
    			cfg.Data["bad*Key"] = "value"
    			return cfg
    		},
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Aug 12 20:55:35 UTC 2019
    - 4.3K bytes
    - Viewed (0)
  4. pkg/registry/admissionregistration/validatingwebhookconfiguration/storage/storage_test.go

    	test.TestUpdate(
    		// valid
    		validValidatingWebhookConfiguration(),
    		// updateFunc
    		func(obj runtime.Object) runtime.Object {
    			object := obj.(*admissionregistration.ValidatingWebhookConfiguration)
    			object.Labels = map[string]string{"c": "d"}
    			return object
    		},
    		// invalid updateFunc
    		func(obj runtime.Object) runtime.Object {
    			object := obj.(*admissionregistration.ValidatingWebhookConfiguration)
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat May 13 15:10:55 UTC 2023
    - 6K bytes
    - Viewed (0)
  5. 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)
  6. pkg/controller/certificates/rootcacertpublisher/publisher.go

    	cmInformer.Informer().AddEventHandler(cache.ResourceEventHandlerFuncs{
    		DeleteFunc: e.configMapDeleted,
    		UpdateFunc: e.configMapUpdated,
    	})
    	e.cmLister = cmInformer.Lister()
    	e.cmListerSynced = cmInformer.Informer().HasSynced
    
    	nsInformer.Informer().AddEventHandler(cache.ResourceEventHandlerFuncs{
    		AddFunc:    e.namespaceAdded,
    		UpdateFunc: e.namespaceUpdated,
    	})
    	e.nsListerSynced = nsInformer.Informer().HasSynced
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat May 04 18:33:12 UTC 2024
    - 6.8K bytes
    - Viewed (0)
  7. pkg/scheduler/eventhandlers.go

    					utilruntime.HandleError(fmt.Errorf("unable to handle object in %T: %T", sched, obj))
    					return false
    				}
    			},
    			Handler: cache.ResourceEventHandlerFuncs{
    				AddFunc:    sched.addPodToCache,
    				UpdateFunc: sched.updatePodInCache,
    				DeleteFunc: sched.deletePodFromCache,
    			},
    		},
    	); err != nil {
    		return err
    	}
    	handlers = append(handlers, handlerRegistration)
    
    	// unscheduled pod queue
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Mar 07 21:21:04 UTC 2024
    - 24K bytes
    - Viewed (0)
  8. pkg/test/framework/components/echo/kube/pod_controller.go

    	_, informer := cache.NewInformer(podListWatch, &corev1.Pod{}, 0, controllers.EventHandler[*corev1.Pod]{
    		AddFunc: func(pod *corev1.Pod) {
    			q.Push(func() error {
    				return handlers.added(pod)
    			})
    		},
    		UpdateFunc: func(old, cur *corev1.Pod) {
    			q.Push(func() error {
    				if old.GetResourceVersion() != cur.GetResourceVersion() {
    					return handlers.updated(cur)
    				}
    				return nil
    			})
    		},
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Tue May 09 02:22:47 UTC 2023
    - 2.6K bytes
    - Viewed (0)
  9. pkg/registry/admissionregistration/validatingadmissionpolicybinding/storage/storage_test.go

    			test.TestUpdate(
    				// valid
    				b,
    				// updateFunc
    				func(obj runtime.Object) runtime.Object {
    					object := obj.(*admissionregistration.ValidatingAdmissionPolicyBinding)
    					object.Labels = map[string]string{"c": "d"}
    					return object
    				},
    				// invalid updateFunc
    				func(obj runtime.Object) runtime.Object {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Jul 20 16:30:09 UTC 2023
    - 7.7K bytes
    - Viewed (0)
  10. pkg/proxy/config/config.go

    		logger:       klog.FromContext(ctx),
    	}
    
    	_, _ = endpointSliceInformer.Informer().AddEventHandlerWithResyncPeriod(
    		cache.ResourceEventHandlerFuncs{
    			AddFunc:    result.handleAddEndpointSlice,
    			UpdateFunc: result.handleUpdateEndpointSlice,
    			DeleteFunc: result.handleDeleteEndpointSlice,
    		},
    		resyncPeriod,
    	)
    
    	return result
    }
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Apr 22 05:08:41 UTC 2024
    - 15.1K bytes
    - Viewed (0)
Back to top