Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 2 of 2 for RecordResourceVersion (0.14 sec)

  1. staging/src/k8s.io/apiserver/pkg/storage/cacher/metrics/metrics.go

    	listCacheNumReturned.WithLabelValues(resourcePrefix).Add(float64(numReturned))
    }
    
    // RecordResourceVersion sets the current resource version for a given resource type.
    func RecordResourceVersion(resourcePrefix string, resourceVersion uint64) {
    	watchCacheResourceVersion.WithLabelValues(resourcePrefix).Set(float64(resourceVersion))
    }
    
    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

    	// UpdateResourceVersion in flight at any point in time, which is true now,
    	// because reflector calls them synchronously from its main thread.
    	if w.eventHandler != nil {
    		w.eventHandler(wcEvent)
    	}
    	metrics.RecordResourceVersion(w.groupResource.String(), resourceVersion)
    	return nil
    }
    
    // Assumes that lock is already held for write.
    func (w *watchCache) updateCache(event *watchCacheEvent) {
    	w.resizeCacheLocked(event.RecordTime)
    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