filter resource-scoped pingsources (yeah still there)

knative · Jul 15, 2020 · f08ba82 · f08ba82
1 parent 8520ec9
commit f08ba82
Showing 1 changed file with 6 additions and 0 deletions.
diff --git a/pkg/adapter/mtping/config.go b/pkg/adapter/mtping/config.go
@@ -19,6 +19,7 @@ package mtping
 import (
 	corev1 "k8s.io/api/core/v1"
 
+	"knative.dev/eventing/pkg/apis/eventing"
 	"knative.dev/eventing/pkg/apis/sources/v1alpha2"
 )
 
@@ -50,6 +51,11 @@ type PingConfigs map[string]PingConfig
 // Project creates a PingConfig for the given source
 func Project(i interface{}) interface{} {
 	obj := i.(*v1alpha2.PingSource)
+
+	if scope, ok := obj.Annotations[eventing.ScopeAnnotationKey]; ok && scope != eventing.ScopeCluster {
+		return nil
+	}
+
 	cfg := &PingConfig{
 		ObjectReference: corev1.ObjectReference{
 			Name:      obj.Name,