- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 100 for UpdateFunc (0.18 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) -
pilot/pkg/status/manager.go
return &IstioGenerationProvider{result} } result := &Controller{ fn: wrapper, workers: m.workers, } return result } type UpdateFunc func(status any, context any) GenerationProvider type Controller struct { fn UpdateFunc workers WorkerQueue } // EnqueueStatusUpdateResource informs the manager that this controller would like to
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Jul 24 04:04:42 UTC 2023 - 4.2K bytes - Viewed (0) -
pkg/kube/controllers/common.go
} else if e.AddFunc != nil { e.AddFunc(Extract[T](obj)) } } func (e EventHandler[T]) OnUpdate(oldObj, newObj interface{}) { if e.UpdateFunc != nil { e.UpdateFunc(Extract[T](oldObj), Extract[T](newObj)) } } func (e EventHandler[T]) OnDelete(obj interface{}) { if e.DeleteFunc != nil { e.DeleteFunc(Extract[T](obj)) } } var _ cache.ResourceEventHandler = EventHandler[Object]{}
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Apr 11 08:27:29 UTC 2024 - 8.9K bytes - Viewed (0) -
plugin/pkg/auth/authorizer/node/graph_populator.go
graph: graph, } podHandler, _ := pods.Informer().AddEventHandler(cache.ResourceEventHandlerFuncs{ AddFunc: g.addPod, UpdateFunc: g.updatePod, DeleteFunc: g.deletePod, }) pvsHandler, _ := pvs.Informer().AddEventHandler(cache.ResourceEventHandlerFuncs{ AddFunc: g.addPV, UpdateFunc: g.updatePV, DeleteFunc: g.deletePV, })
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Mar 07 21:22:55 UTC 2024 - 6.5K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/storage/util.go
"k8s.io/apimachinery/pkg/labels" "k8s.io/apimachinery/pkg/runtime" ) type SimpleUpdateFunc func(runtime.Object) (runtime.Object, error) // SimpleUpdateFunc converts SimpleUpdateFunc into UpdateFunc func SimpleUpdate(fn SimpleUpdateFunc) UpdateFunc { return func(input runtime.Object, _ ResponseMeta) (runtime.Object, *uint64, error) { out, err := fn(input) return out, nil, err } }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Apr 18 08:05:06 UTC 2024 - 4.6K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/util/peerproxy/peerproxy.go
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jul 19 00:36:22 UTC 2023 - 2K bytes - Viewed (0) -
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) -
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/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) -
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)