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

const pruneInterval …

const staleTolerationThreshold …

var ObjectCountNotFoundErr …

var ObjectCountStaleErr …

type StorageObjectCountTracker …

// NewStorageObjectCountTracker returns an instance of
// StorageObjectCountTracker interface that can be used to
// keep track of the total number of objects for each resource.
func NewStorageObjectCountTracker() StorageObjectCountTracker { … }

type timestampedCount …

type objectCountTracker …

func (t *objectCountTracker) Set(groupResource string, count int64) { … }

func (t *objectCountTracker) Get(groupResource string) (int64, error) { … }

// RunUntil runs all the necessary maintenance.
func (t *objectCountTracker) RunUntil(stopCh <-chan struct{ … }

func (t *objectCountTracker) prune(threshold time.Duration) error { … }