Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 5 of 5 for UpdateFunc (0.15 sec)

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. 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)
Back to top