Skip to content

Commit 472116d

Browse files
committed
fixup! proper label selectors
Signed-off-by: Bryce Palmer <[email protected]>
1 parent aaa1191 commit 472116d

File tree

1 file changed

+12
-1
lines changed

1 file changed

+12
-1
lines changed

pkg/monitortests/kubeapiserver/kasloganalyzer/monitortest.go

Lines changed: 12 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -7,6 +7,7 @@ import (
77
"time"
88

99
"k8s.io/apimachinery/pkg/labels"
10+
"k8s.io/apimachinery/pkg/selection"
1011
"k8s.io/client-go/informers"
1112
coreinformers "k8s.io/client-go/informers/core/v1"
1213
"k8s.io/client-go/kubernetes"
@@ -40,10 +41,20 @@ func (w *kasLogAnalyzer) PrepareCollection(ctx context.Context, adminRESTConfig
4041
kubeInformers := informers.NewSharedInformerFactory(kubeClient, 0)
4142
namespaceScopedCoreInformers := coreinformers.New(kubeInformers, "openshift-kube-apiserver", nil)
4243

44+
okasAppLabel, err := labels.NewRequirement("app", selection.Equals, []string{"openshift-kube-apiserver"})
45+
if err != nil {
46+
return err
47+
}
48+
49+
okasApiServerLabel, err := labels.NewRequirement("apiserver", selection.Equals, []string{"true"})
50+
if err != nil {
51+
return err
52+
}
53+
4354
ctx, w.stopCollection = context.WithCancel(ctx)
4455
podStreamer := podaccess.NewPodsStreamer(
4556
kubeClient,
46-
labels.NewSelector(),
57+
labels.NewSelector().Add(*okasAppLabel, *okasApiServerLabel),
4758
"openshift-kube-apiserver",
4859
"kube-apiserver",
4960
w.evaluator,

0 commit comments

Comments
 (0)