- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 50 for UpdateFunc (0.37 sec)
-
staging/src/k8s.io/apiserver/pkg/registry/generic/registry/dryrun_test.go
defer destroy() obj := UnstructuredOrDie(`{"kind": "Pod"}`) updateFunc := func(input runtime.Object, res storage.ResponseMeta) (output runtime.Object, ttl *uint64, err error) { return input, nil, errors.New("UpdateFunction shouldn't be called") } err := s.GuaranteedUpdate(context.Background(), "key", obj, false, nil, updateFunc, true, nil)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Aug 24 09:23:05 UTC 2023 - 9.9K bytes - Viewed (0) -
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) -
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) -
pkg/registry/batch/job/storage/storage_test.go
test := genericregistrytest.New(t, storage.Job.Store) two := int32(2) test.TestUpdate( // valid validNewJob(), // updateFunc func(obj runtime.Object) runtime.Object { object := obj.(*batch.Job) object.Spec.Parallelism = &two return object }, // invalid updateFunc func(obj runtime.Object) runtime.Object { object := obj.(*batch.Job) object.Spec.Selector = &metav1.LabelSelector{}
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Apr 15 14:34:53 UTC 2024 - 11.2K bytes - Viewed (0) -
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) -
staging/src/k8s.io/apiserver/pkg/storage/interfaces.go
type MatchValue struct { IndexName string Value string } // Pass an UpdateFunc to Interface.GuaranteedUpdate to make an update // that is guaranteed to succeed. // See the comment for GuaranteedUpdate for more details. type UpdateFunc func(input runtime.Object, res ResponseMeta) (output runtime.Object, ttl *uint64, err error)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Apr 29 07:53:48 UTC 2024 - 14.8K bytes - Viewed (0) -
pkg/controller/endpointslicemirroring/endpointslicemirroring_controller.go
), workerLoopPeriod: time.Second, } endpointsInformer.Informer().AddEventHandler(cache.ResourceEventHandlerFuncs{ AddFunc: func(obj interface{}) { c.onEndpointsAdd(logger, obj) }, UpdateFunc: func(oldObj, newObj interface{}) { c.onEndpointsUpdate(logger, oldObj, newObj) }, DeleteFunc: func(obj interface{}) { c.onEndpointsDelete(logger, obj) }, })
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon May 06 23:18:31 UTC 2024 - 20.1K bytes - Viewed (0) -
pkg/registry/core/replicationcontroller/storage/storage_test.go
test.TestUpdate( // valid validNewController(), // valid updateFunc func(obj runtime.Object) runtime.Object { object := obj.(*api.ReplicationController) object.Spec.Replicas = object.Spec.Replicas + 1 return object }, // invalid updateFunc func(obj runtime.Object) runtime.Object { object := obj.(*api.ReplicationController) object.Name = ""
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Apr 16 06:57:01 UTC 2024 - 16.9K bytes - Viewed (0) -
pkg/controller/volume/pvcprotection/pvc_protection_controller.go
e.pvcListerSynced = pvcInformer.Informer().HasSynced pvcInformer.Informer().AddEventHandler(cache.ResourceEventHandlerFuncs{ AddFunc: func(obj interface{}) { e.pvcAddedUpdated(logger, obj) }, UpdateFunc: func(old, new interface{}) { e.pvcAddedUpdated(logger, new) }, }) e.podLister = podInformer.Lister() e.podListerSynced = podInformer.Informer().HasSynced e.podIndexer = podInformer.Informer().GetIndexer()
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 14K bytes - Viewed (0) -
pkg/registry/apps/replicaset/storage/storage_test.go
test.TestUpdate( // valid validNewReplicaSet(), // valid updateFunc func(obj runtime.Object) runtime.Object { object := obj.(*apps.ReplicaSet) object.Spec.Replicas = object.Spec.Replicas + 1 return object }, // invalid updateFunc func(obj runtime.Object) runtime.Object { object := obj.(*apps.ReplicaSet) object.Name = "" return object
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Apr 12 15:46:12 UTC 2023 - 17.7K bytes - Viewed (0)