github/kubernetes
1
0
Fork 0
mirror of https://github.com/k3s-io/kubernetes.git synced 2025-08-17 23:57:49 +00:00
Code Issues Projects Releases Wiki Activity

apiserver/storage: use metav1.InitialEventsAnnotationKey const

Browse Source
This commit is contained in:
Lukasz Szaszkiewicz 2024-03-11 11:40:21 +01:00
parent b3926d137c
commit ed2b92c3df
5 changed files with 8 additions and 14 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
staging/src/k8s.io/apiserver/pkg/storage/cacher/cache_watcher_test.go
View File

@ -579,7 +579,7 @@ func TestCacheWatcherDrainingNoBookmarkAfterResourceVersionSent(t *testing.T) {
{Type: watch.Bookmark, Object: &v1.Pod{ {Type: watch.Bookmark, Object: &v1.Pod{
ObjectMeta: metav1.ObjectMeta{ ObjectMeta: metav1.ObjectMeta{
ResourceVersion: "10", ResourceVersion: "10",
Annotations: map[string]string{"k8s.io/initial-events-end": "true"}, Annotations: map[string]string{metav1.InitialEventsAnnotationKey: "true"},
}, },
}}, }},
{Type: watch.Added, Object: makePod(15)}, {Type: watch.Added, Object: makePod(15)},

2
staging/src/k8s.io/apiserver/pkg/storage/cacher/cacher_whitebox_test.go
View File

@ -1926,7 +1926,7 @@ func TestDoNotPopExpiredWatchersWhenNoEventsSeen(t *testing.T) {
{Type: watch.Bookmark, Object: &example.Pod{ {Type: watch.Bookmark, Object: &example.Pod{
ObjectMeta: metav1.ObjectMeta{ ObjectMeta: metav1.ObjectMeta{
ResourceVersion: "102", ResourceVersion: "102",
Annotations: map[string]string{"k8s.io/initial-events-end": "true"}, Annotations: map[string]string{metav1.InitialEventsAnnotationKey: "true"},
}, },
}}, }},
}, true) }, true)

4
staging/src/k8s.io/apiserver/pkg/storage/testing/watcher_tests.go
View File

@ -1250,7 +1250,7 @@ func RunWatchSemantics(ctx context.Context, t *testing.T, store storage.Interfac
Object: &example.Pod{ Object: &example.Pod{
ObjectMeta: metav1.ObjectMeta{ ObjectMeta: metav1.ObjectMeta{
ResourceVersion: createdInitialPods[len(createdInitialPods)-1].ResourceVersion, ResourceVersion: createdInitialPods[len(createdInitialPods)-1].ResourceVersion,
Annotations: map[string]string{"k8s.io/initial-events-end": "true"}, Annotations: map[string]string{metav1.InitialEventsAnnotationKey: "true"},
}, },
}, },
}} }}
@ -1513,7 +1513,7 @@ func RunWatchSemanticInitialEventsExtended(ctx context.Context, t *testing.T, st
watchEvents = append(watchEvents, watch.Event{Type: watch.Bookmark, Object: &example.Pod{ watchEvents = append(watchEvents, watch.Event{Type: watch.Bookmark, Object: &example.Pod{
ObjectMeta: metav1.ObjectMeta{ ObjectMeta: metav1.ObjectMeta{
ResourceVersion: globalResourceVersion, ResourceVersion: globalResourceVersion,
Annotations: map[string]string{"k8s.io/initial-events-end": "true"}, Annotations: map[string]string{metav1.InitialEventsAnnotationKey: "true"},
}, },
}}) }})
return watchEvents return watchEvents

12
staging/src/k8s.io/apiserver/pkg/storage/util.go
View File

@ -24,18 +24,12 @@ import (
"k8s.io/apimachinery/pkg/api/meta" "k8s.io/apimachinery/pkg/api/meta"
"k8s.io/apimachinery/pkg/api/validation/path" "k8s.io/apimachinery/pkg/api/validation/path"
metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
"k8s.io/apimachinery/pkg/fields" "k8s.io/apimachinery/pkg/fields"
"k8s.io/apimachinery/pkg/labels" "k8s.io/apimachinery/pkg/labels"
"k8s.io/apimachinery/pkg/runtime" "k8s.io/apimachinery/pkg/runtime"
) )
const (
// initialEventsAnnotationKey the name of the key
// under which an annotation marking the end of list stream
// is kept.
initialEventsAnnotationKey = "k8s.io/initial-events-end"
)
type SimpleUpdateFunc func(runtime.Object) (runtime.Object, error) type SimpleUpdateFunc func(runtime.Object) (runtime.Object, error)
// SimpleUpdateFunc converts SimpleUpdateFunc into UpdateFunc // SimpleUpdateFunc converts SimpleUpdateFunc into UpdateFunc
@ -144,7 +138,7 @@ func AnnotateInitialEventsEndBookmark(obj runtime.Object) error {
if objAnnotations == nil { if objAnnotations == nil {
objAnnotations = map[string]string{} objAnnotations = map[string]string{}
} }
objAnnotations[initialEventsAnnotationKey] = "true" objAnnotations[metav1.InitialEventsAnnotationKey] = "true"
objMeta.SetAnnotations(objAnnotations) objMeta.SetAnnotations(objAnnotations)
return nil return nil
} }
@ -157,5 +151,5 @@ func HasInitialEventsEndBookmarkAnnotation(obj runtime.Object) (bool, error) {
return false, err return false, err
} }
objAnnotations := objMeta.GetAnnotations() objAnnotations := objMeta.GetAnnotations()
return objAnnotations[initialEventsAnnotationKey] == "true", nil return objAnnotations[metav1.InitialEventsAnnotationKey] == "true", nil
} }

2
staging/src/k8s.io/apiserver/pkg/storage/util_test.go
View File

@ -154,7 +154,7 @@ func TestHasInitialEventsEndBookmarkAnnotation(t *testing.T) {
createAnnotatedPod := func(name, value string) *example.Pod { createAnnotatedPod := func(name, value string) *example.Pod {
p := createPod(name) p := createPod(name)
p.Annotations = map[string]string{} p.Annotations = map[string]string{}
p.Annotations["k8s.io/initial-events-end"] = value p.Annotations[metav1.InitialEventsAnnotationKey] = value
return p return p
} }
scenarios := []struct { scenarios := []struct {