Skip to content

Commit 9279395

Browse files
authored
Merge pull request #167 from justinsb/label_selector_helper
Use labels helper to build label selector
2 parents 4860dbf + ba75639 commit 9279395

File tree

1 file changed

+4
-8
lines changed

1 file changed

+4
-8
lines changed

pkg/patterns/declarative/watch.go

Lines changed: 4 additions & 8 deletions
Original file line numberDiff line numberDiff line change
@@ -20,10 +20,9 @@ import (
2020
"context"
2121
"fmt"
2222
"sort"
23-
"strings"
2423

2524
metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
26-
"k8s.io/apimachinery/pkg/fields"
25+
"k8s.io/apimachinery/pkg/labels"
2726
"k8s.io/apimachinery/pkg/runtime/schema"
2827
"k8s.io/client-go/rest"
2928
"sigs.k8s.io/controller-runtime/pkg/controller"
@@ -74,12 +73,9 @@ type watchAll struct {
7473
func (w *watchAll) Notify(ctx context.Context, dest DeclarativeObject, objs *manifest.Objects) error {
7574
log := log.Log
7675

77-
labelSelector := strings.Builder{}
78-
for k, v := range w.labelMaker(ctx, dest) {
79-
if labelSelector.Len() != 0 {
80-
labelSelector.WriteRune(',')
81-
}
82-
fmt.Fprintf(&labelSelector, "%s=%s", k, fields.EscapeValue(v))
76+
labelSelector, err := labels.ValidatedSelectorFromSet(w.labelMaker(ctx, dest))
77+
if err != nil {
78+
return fmt.Errorf("failed to build label selector: %w", err)
8379
}
8480

8581
notify := metav1.ObjectMeta{Name: dest.GetName(), Namespace: dest.GetNamespace()}

0 commit comments

Comments
 (0)