Use broker injection label key from trigger types (#917)

- do not hard code as there is a change coming it in eventing v0.16 release
This commit is contained in:
Navid Shaikh 2020-07-07 16:44:44 +05:30 committed by GitHub
parent 4b62f2008b
commit 4ee2dc4fd3
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 7 additions and 4 deletions

View File

@ -19,14 +19,16 @@ import (
"time"
"k8s.io/apimachinery/pkg/util/wait"
"knative.dev/eventing/pkg/apis/eventing/v1beta1"
)
// LabelNamespaceForDefaultBroker adds label 'knative-eventing-injection=enabled' to the configured namespace
func LabelNamespaceForDefaultBroker(r *KnRunResultCollector) error {
_, err := Kubectl{}.Run("label", "namespace", r.KnTest().Kn().Namespace(), "knative-eventing-injection=enabled")
cmd := []string{"label", "namespace", r.KnTest().Kn().Namespace(), v1beta1.InjectionAnnotation + "=enabled"}
_, err := Kubectl{}.Run(cmd...)
if err != nil {
r.T().Fatalf("Error executing 'kubectl label namespace %s knative-eventing-injection=enabled'. Error: %s", r.KnTest().Kn().Namespace(), err.Error())
r.T().Fatalf("error executing '%s': %s", strings.Join(cmd, " "), err.Error())
}
return wait.PollImmediate(10*time.Second, 5*time.Minute, func() (bool, error) {
@ -41,8 +43,9 @@ func LabelNamespaceForDefaultBroker(r *KnRunResultCollector) error {
// UnlabelNamespaceForDefaultBroker removes label 'knative-eventing-injection=enabled' from the configured namespace
func UnlabelNamespaceForDefaultBroker(r *KnRunResultCollector) {
_, err := Kubectl{}.Run("label", "namespace", r.KnTest().Kn().Namespace(), "knative-eventing-injection-")
cmd := []string{"label", "namespace", r.KnTest().Kn().Namespace(), v1beta1.InjectionAnnotation + "-"}
_, err := Kubectl{}.Run(cmd...)
if err != nil {
r.T().Fatalf("Error executing 'kubectl label namespace %s knative-eventing-injection-'. Error: %s", r.KnTest().Kn().Namespace(), err.Error())
r.T().Fatalf("error executing '%s': %s", strings.Join(cmd, " "), err.Error())
}
}