- Sort Score
- Result 10 results
- Languages All
Results 1 - 2 of 2 for RecordsWatchCacheCapacityChange (0.86 sec)
-
staging/src/k8s.io/apiserver/pkg/storage/cacher/metrics/metrics.go
watchCacheResourceVersion.WithLabelValues(resourcePrefix).Set(float64(resourceVersion)) } // RecordsWatchCacheCapacityChange record watchCache capacity resize(increase or decrease) operations. func RecordsWatchCacheCapacityChange(objType string, old, new int) { WatchCacheCapacity.WithLabelValues(objType).Set(float64(new)) if old < new {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Jun 07 07:39:23 UTC 2024 - 7.5K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/storage/cacher/watch_cache.go
w.startIndex = w.endIndex - capacity } for i := w.startIndex; i < w.endIndex; i++ { newCache[i%capacity] = w.cache[i%w.capacity] } w.cache = newCache metrics.RecordsWatchCacheCapacityChange(w.groupResource.String(), w.capacity, capacity) w.capacity = capacity } func (w *watchCache) UpdateResourceVersion(resourceVersion string) { rv, err := w.versioner.ParseResourceVersion(resourceVersion)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 11 10:20:57 UTC 2024 - 26.2K bytes - Viewed (0)