- Sort Score
- Result 10 results
- Languages All
Results 1 - 3 of 3 for listResourceVersion (0.18 sec)
-
pkg/controller/storageversionmigrator/storageversionmigrator.go
if err != nil { return err } listResourceVersion, err := convertResourceVersionToInt(toBeProcessedSVM.Status.ResourceVersion) if err != nil { return err } if gcListResourceVersion < listResourceVersion { return fmt.Errorf("GC cache is not up to date, requeuing to attempt again. gcListResourceVersion: %d, listResourceVersion: %d", gcListResourceVersion, listResourceVersion) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 9.5K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/storage/cacher/watch_cache.go
} size := w.endIndex - w.startIndex var oldest uint64 switch { case w.listResourceVersion > 0 && !w.removedEventSinceRelist: // If no event was removed from the buffer since last relist, the oldest watch // event we can deliver is one greater than the resource version of the list. oldest = w.listResourceVersion + 1 case size > 0: // If the previous condition is not satisfied: either some event was already
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 11 10:20:57 UTC 2024 - 26.2K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/storage/cacher/cacher_testing_utils_test.go
index := c.watchCache.startIndex % c.watchCache.capacity if c.watchCache.cache[index].ResourceVersion > rv { break } c.watchCache.startIndex++ } c.watchCache.listResourceVersion = rv if _, err = client.KV.Put(ctx, "compact_rev_key", resourceVersion); err != nil { t.Fatalf("Could not update compact_rev_key: %v", err) } if _, err = client.Compact(ctx, int64(rv)); err != nil {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Oct 20 20:43:52 UTC 2023 - 3.8K bytes - Viewed (0)