Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 2 of 2 for RecordsWatchCacheCapacityChange (0.86 sec)

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