kubernetes/staging/src/k8s.io/apiserver/pkg/util/flowcontrol/watch_tracker.go

var readOnlyVerbs …

type watchIdentifier …

type ForgetWatchFunc …

type WatchTracker …

type builtinIndexes …

func getBuiltinIndexes() builtinIndexes { … }

type watchTracker …

func NewWatchTracker() WatchTracker { … }

const unsetValue …

func getIndexValue(r *http.Request, field string) string { … }

type indexValue …

// RegisterWatch implements WatchTracker interface.
func (w *watchTracker) RegisterWatch(r *http.Request) ForgetWatchFunc { … }

func (w *watchTracker) updateIndexLocked(identifier *watchIdentifier, index *indexValue, incr int) { … }

func (w *watchTracker) forgetWatch(identifier *watchIdentifier, index *indexValue) ForgetWatchFunc { … }

// GetInterestedWatchCount implements WatchTracker interface.
//
// TODO(wojtek-t): As of now, requestInfo for object creation (POST) doesn't
// contain the Name field set. Figure out if we can somehow get it for the
// more accurate cost estimation.
//
// TODO(wojtek-t): Figure out how to approach DELETECOLLECTION calls.
func (w *watchTracker) GetInterestedWatchCount(requestInfo *request.RequestInfo) int { … }