- Sort Score
- Result 10 results
- Languages All
Results 1 - 3 of 3 for AnnotateInitialEventsEndBookmark (0.43 sec)
-
staging/src/k8s.io/apiserver/pkg/storage/util.go
} return uint64(currentResourceVersion), nil } // AnnotateInitialEventsEndBookmark adds a special annotation to the given object // which indicates that the initial events have been sent. // // Note that this function assumes that the obj's annotation // field is a reference type (i.e. a map). func AnnotateInitialEventsEndBookmark(obj runtime.Object) error { objMeta, err := meta.Accessor(obj) if err != nil {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Apr 18 08:05:06 UTC 2024 - 4.6K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/storage/cacher/cache_watcher.go
if event.Type == watch.Bookmark { e := &watch.Event{Type: watch.Bookmark, Object: event.Object.DeepCopyObject()} if !c.wasBookmarkAfterRvSent() { if err := storage.AnnotateInitialEventsEndBookmark(e.Object); err != nil { utilruntime.HandleError(fmt.Errorf("error while accessing object's metadata gr: %v, identifier: %v, obj: %#v, err: %v", c.groupResource, c.identifier, e.Object, err)) return nil }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Aug 24 12:22:41 UTC 2023 - 18.7K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/storage/etcd3/watcher.go
klog.Errorf("failed to propagate object version: %v", err) return nil } if e.isInitialEventsEndBookmark { if err := storage.AnnotateInitialEventsEndBookmark(object); err != nil { wc.sendError(fmt.Errorf("error while accessing object's metadata gr: %v, type: %v, obj: %#v, err: %v", wc.watcher.groupResource, wc.watcher.objectType, object, err)) return nil }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Sep 25 10:26:38 UTC 2023 - 18.9K bytes - Viewed (0)