Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 2 of 2 for shouldListFromStorage (0.21 sec)

  1. staging/src/k8s.io/apiserver/pkg/util/flowcontrol/request/list_work_estimator.go

    		if listOptions.SendInitialEvents == nil || !*listOptions.SendInitialEvents {
    			return WorkEstimate{InitialSeats: e.config.MinimumSeats}
    		}
    	}
    
    	isListFromCache := requestInfo.Verb == "watch" || !shouldListFromStorage(query, &listOptions)
    
    	numStored, err := e.countGetterFn(key(requestInfo))
    	switch {
    	case err == ObjectCountStaleErr:
    		// object count going stale is indicative of degradation, so we should
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri May 10 11:56:42 UTC 2024
    - 7K bytes
    - Viewed (0)
  2. staging/src/k8s.io/apiserver/pkg/storage/cacher/cacher.go

    		objVal.Set(reflect.Zero(objVal.Type()))
    		if !opts.IgnoreNotFound {
    			return storage.NewKeyNotFoundError(key, int64(readResourceVersion))
    		}
    	}
    	return nil
    }
    
    // NOTICE: Keep in sync with shouldListFromStorage function in
    //
    //	staging/src/k8s.io/apiserver/pkg/util/flowcontrol/request/list_work_estimator.go
    func shouldDelegateList(opts storage.ListOptions) bool {
    	resourceVersion := opts.ResourceVersion
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Jun 12 10:12:02 UTC 2024
    - 51.8K bytes
    - Viewed (0)
Back to top