- Sort Score
- Result 10 results
- Languages All
Results 1 - 5 of 5 for UpdateFunc (0.15 sec)
-
staging/src/k8s.io/apiserver/pkg/storage/testing/store_tests.go
t.Errorf("Unexpected error: %v", err) } updateFunc := func(input runtime.Object, res storage.ResponseMeta) (runtime.Object, *uint64, error) { return input, nil, nil } // GuaranteedUpdate without suggestion should return an error if err := store.GuaranteedUpdate(ctx, preset[1].key, &example.Pod{}, false, nil, updateFunc, nil); !storage.IsInternalError(err) { t.Errorf("Unexpected error: %v", err) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 11 12:45:33 UTC 2024 - 91.4K bytes - Viewed (0) -
pkg/controller/job/job_controller.go
podBackoffStore: newBackoffStore(), } if _, err := jobInformer.Informer().AddEventHandler(cache.ResourceEventHandlerFuncs{ AddFunc: func(obj interface{}) { jm.addJob(logger, obj) }, UpdateFunc: func(oldObj, newObj interface{}) { jm.updateJob(logger, oldObj, newObj) }, DeleteFunc: func(obj interface{}) { jm.deleteJob(logger, obj) }, }); err != nil {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Jun 10 23:56:37 UTC 2024 - 77.6K bytes - Viewed (0) -
src/cmd/link/internal/ld/lib.go
} } ctxt.Logf("%s", out) } // Helper for updating a Macho binary in some way (shared between // dwarf combining and UUID update). updateMachoOutFile := func(op string, updateFunc machoUpdateFunc) { // For os.Rename to work reliably, must be in same directory as outfile. rewrittenOutput := *flagOutfile + "~" exef, err := os.Open(*flagOutfile) if err != nil {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue May 21 18:45:27 UTC 2024 - 88.6K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/storage/cacher/cacher.go
// GuaranteedUpdate implements storage.Interface. func (c *Cacher) GuaranteedUpdate( ctx context.Context, key string, destination runtime.Object, ignoreNotFound bool, preconditions *storage.Preconditions, tryUpdate storage.UpdateFunc, _ runtime.Object) error { // Ignore the suggestion and try to pass down the current version of the object // read from cache. if elem, exists, err := c.watchCache.GetByKey(key); err != nil {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jun 12 10:12:02 UTC 2024 - 51.8K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/storage/cacher/cacher_whitebox_test.go
podList.ListMeta = metav1.ListMeta{ResourceVersion: "100"} return d.err } func (d *dummyStorage) GuaranteedUpdate(_ context.Context, _ string, _ runtime.Object, _ bool, _ *storage.Preconditions, _ storage.UpdateFunc, _ runtime.Object) error { return fmt.Errorf("unimplemented") } func (d *dummyStorage) Count(_ string) (int64, error) { return 0, fmt.Errorf("unimplemented") } func (d *dummyStorage) injectError(err error) {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jun 12 10:12:02 UTC 2024 - 82.9K bytes - Viewed (0)