Search Options

Results per page
Sort
Preferred Languages
Advance

Results 31 - 40 of 131 for UpdateFunc (0.25 sec)

  1. pkg/registry/storage/storageclass/storage/storage_test.go

    	defer server.Terminate(t)
    	defer storage.Store.DestroyFunc()
    	test := genericregistrytest.New(t, storage.Store).ClusterScope()
    	test.TestUpdate(
    		// valid
    		validNewStorageClass("foo"),
    		// updateFunc
    		func(obj runtime.Object) runtime.Object {
    			object := obj.(*storageapi.StorageClass)
    			object.Parameters = map[string]string{"foo": "bar"}
    			return object
    		},
    		//invalid update
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Aug 12 20:55:35 UTC 2019
    - 4.6K bytes
    - Viewed (0)
  2. pkg/controller/endpointslice/endpointslice_controller.go

    		AddFunc: c.onServiceUpdate,
    		UpdateFunc: func(old, cur interface{}) {
    			c.onServiceUpdate(cur)
    		},
    		DeleteFunc: c.onServiceDelete,
    	})
    	c.serviceLister = serviceInformer.Lister()
    	c.servicesSynced = serviceInformer.Informer().HasSynced
    
    	podInformer.Informer().AddEventHandler(cache.ResourceEventHandlerFuncs{
    		AddFunc:    c.addPod,
    		UpdateFunc: c.updatePod,
    		DeleteFunc: c.deletePod,
    	})
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Jun 04 08:33:32 UTC 2024
    - 23.6K bytes
    - Viewed (0)
  3. pkg/registry/resource/resourceclaimparameters/storage/storage_test.go

    	defer server.Terminate(t)
    	defer storage.Store.DestroyFunc()
    	test := genericregistrytest.New(t, storage.Store)
    	test.TestUpdate(
    		// valid
    		validNewResourceClaimParameters("foo"),
    		// updateFunc
    		func(obj runtime.Object) runtime.Object {
    			object := obj.(*resource.ResourceClaimParameters)
    			object.Labels = map[string]string{"foo": "bar"}
    			return object
    		},
    		// invalid update
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Mar 07 15:15:31 UTC 2024
    - 4K bytes
    - Viewed (0)
  4. pkg/registry/resource/resourceslice/storage/storage_test.go

    	defer server.Terminate(t)
    	defer storage.Store.DestroyFunc()
    	test := genericregistrytest.New(t, storage.Store).ClusterScope()
    	test.TestUpdate(
    		// valid
    		validNewResourceSlice("foo"),
    		// updateFunc
    		func(obj runtime.Object) runtime.Object {
    			object := obj.(*resource.ResourceSlice)
    			object.Labels = map[string]string{"foo": "bar"}
    			return object
    		},
    		// invalid update
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Mar 14 17:07:36 UTC 2024
    - 4.1K bytes
    - Viewed (0)
  5. 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())
    		},
    	}
    }
    
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Fri Feb 23 19:18:21 UTC 2024
    - 3.9K bytes
    - Viewed (0)
  6. pkg/registry/resource/podschedulingcontext/storage/storage_test.go

    	defer server.Terminate(t)
    	defer storage.Store.DestroyFunc()
    	test := genericregistrytest.New(t, storage.Store)
    	test.TestUpdate(
    		// valid
    		validNewPodSchedulingContexts("foo", metav1.NamespaceDefault),
    		// updateFunc
    		func(obj runtime.Object) runtime.Object {
    			object := obj.(*resource.PodSchedulingContext)
    			if object.Labels == nil {
    				object.Labels = map[string]string{}
    			}
    			object.Labels["foo"] = "bar"
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Apr 12 15:46:12 UTC 2023
    - 5.7K bytes
    - Viewed (0)
  7. pkg/registry/storage/csidriver/storage/storage_test.go

    	defer storage.Store.DestroyFunc()
    	test := genericregistrytest.New(t, storage.Store).ClusterScope()
    	notPodInfoOnMount := false
    
    	test.TestUpdate(
    		// valid
    		validNewCSIDriver("foo"),
    		// updateFunc
    		func(obj runtime.Object) runtime.Object {
    			object := obj.(*storageapi.CSIDriver)
    			object.Labels = map[string]string{"a": "b"}
    			return object
    		},
    		//invalid update
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Mar 14 15:49:55 UTC 2023
    - 4.7K bytes
    - Viewed (0)
  8. staging/src/k8s.io/apiserver/pkg/registry/generic/registry/dryrun.go

    }
    
    func (s *DryRunnableStorage) GuaranteedUpdate(
    	ctx context.Context, key string, destination runtime.Object, ignoreNotFound bool,
    	preconditions *storage.Preconditions, tryUpdate storage.UpdateFunc, dryRun bool, cachedExistingObject runtime.Object) error {
    	if dryRun {
    		var current runtime.Object
    		v, err := conversion.EnforcePtr(destination)
    		if err != nil {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Jun 02 20:40:48 UTC 2023
    - 3.8K bytes
    - Viewed (0)
  9. pkg/kube/kclient/index.go

    		AddFunc: func(obj any, initialList bool) {
    			idx.mu.Lock()
    			addObj(obj)
    			idx.mu.Unlock()
    			if delegate != nil {
    				delegate.OnAdd(obj, initialList)
    			}
    		},
    		UpdateFunc: func(oldObj, newObj any) {
    			idx.mu.Lock()
    			deleteObj(oldObj)
    			addObj(newObj)
    			idx.mu.Unlock()
    			if delegate != nil {
    				delegate.OnUpdate(oldObj, newObj)
    			}
    		},
    		DeleteFunc: func(obj any) {
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu May 04 03:49:30 UTC 2023
    - 3.5K bytes
    - Viewed (0)
  10. pkg/registry/core/podtemplate/storage/storage_test.go

    	storage, server := newStorage(t)
    	defer server.Terminate(t)
    	defer storage.Store.DestroyFunc()
    	test := genericregistrytest.New(t, storage.Store)
    	test.TestUpdate(
    		//valid
    		validNewPodTemplate("foo"),
    		// updateFunc
    		func(obj runtime.Object) runtime.Object {
    			object := obj.(*api.PodTemplate)
    			object.Template.Spec.NodeSelector = map[string]string{"a": "b"}
    			return object
    		},
    	)
    }
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Aug 12 20:55:35 UTC 2019
    - 4.1K bytes
    - Viewed (0)
Back to top