Skip to content

Commit 7de28f5

Browse files
committed
Revert BindingLabels & QueueLabels changes
There is already too much stuff happening in this PR. Thank you @benmoss for suggesting that we split it in #513 Signed-off-by: Gerhard Lazu <[email protected]>
1 parent ac8ce4b commit 7de28f5

File tree

2 files changed

+12
-8
lines changed

2 files changed

+12
-8
lines changed

pkg/reconciler/trigger/resources/binding.go

Lines changed: 5 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -25,6 +25,7 @@ import (
2525
"k8s.io/apimachinery/pkg/runtime"
2626
rabbitv1beta1 "knative.dev/eventing-rabbitmq/third_party/pkg/apis/rabbitmq.com/v1beta1"
2727

28+
"knative.dev/eventing/pkg/apis/eventing"
2829
eventingv1 "knative.dev/eventing/pkg/apis/eventing/v1"
2930
)
3031

@@ -86,14 +87,14 @@ func NewBinding(ctx context.Context, args *BindingArgs) (*rabbitv1beta1.Binding,
8687
// BindingLabels generates the labels present on the Queue linking the Broker / Trigger to the
8788
// Binding.
8889
func BindingLabels(b *eventingv1.Broker, t *eventingv1.Trigger) map[string]string {
89-
if t != nil {
90+
if t == nil {
9091
return map[string]string{
91-
"eventing.knative.dev/broker": b.Name,
92-
"eventing.knative.dev/trigger": t.Name,
92+
eventing.BrokerLabelKey: b.Name,
9393
}
9494
} else {
9595
return map[string]string{
96-
"eventing.knative.dev/broker": b.Name,
96+
eventing.BrokerLabelKey: b.Name,
97+
TriggerLabelKey: t.Name,
9798
}
9899
}
99100
}

pkg/reconciler/trigger/resources/queue.go

Lines changed: 7 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -24,9 +24,12 @@ import (
2424
"k8s.io/apimachinery/pkg/runtime"
2525
rabbitv1beta1 "knative.dev/eventing-rabbitmq/third_party/pkg/apis/rabbitmq.com/v1beta1"
2626

27+
"knative.dev/eventing/pkg/apis/eventing"
2728
eventingv1 "knative.dev/eventing/pkg/apis/eventing/v1"
2829
)
2930

31+
const TriggerLabelKey = "eventing.knative.dev/trigger"
32+
3033
type QueueArgs struct {
3134
Name string
3235
Namespace string
@@ -70,14 +73,14 @@ func NewQueue(ctx context.Context, args *QueueArgs) *rabbitv1beta1.Queue {
7073
// QueueLabels generates the labels present on the Queue linking the Broker / Trigger to the
7174
// Queue.
7275
func QueueLabels(b *eventingv1.Broker, t *eventingv1.Trigger) map[string]string {
73-
if t != nil {
76+
if t == nil {
7477
return map[string]string{
75-
"eventing.knative.dev/broker": b.Name,
76-
"eventing.knative.dev/trigger": t.Name,
78+
eventing.BrokerLabelKey: b.Name,
7779
}
7880
} else {
7981
return map[string]string{
80-
"eventing.knative.dev/broker": b.Name,
82+
eventing.BrokerLabelKey: b.Name,
83+
TriggerLabelKey: t.Name,
8184
}
8285
}
8386
}

0 commit comments

Comments
 (0)