Add Count field to specify minimum number of counts that need to be seen

fn.go

@@ -103,7 +103,7 @@ func (f *Function) RunFunction(_ context.Context, req *fnv1.RunFunctionRequest)
 	return rsp, nil
 }
 
-func match(in *v1alpha1.Input, e corev1.Event) bool {
+func match(in *v1alpha1.Input, e corev1.Event) bool { //nolint:gocyclo // This method is above our cyclomatic complexity level. Be wary of adding additional complexity.
 	ib, err := json.Marshal(in.InvolvedObject)
 	if err != nil {
 		return false
@@ -131,5 +131,9 @@ func match(in *v1alpha1.Input, e corev1.Event) bool {
 	if in.Type != "" && in.Type != e.Type {
 		return false
 	}
+
+	if in.Count != 0 && in.Count >= e.Count {
+		return false
+	}
 	return true
 }

fn_test.go

@@ -187,6 +187,58 @@ func TestMatch(t *testing.T) {
 				match: true,
 			},
 		},
+		"MatchCount": {
+			args: args{
+				in: &v1alpha1.Input{
+					Type: "Normal",
+					InvolvedObject: corev1.ObjectReference{
+						Kind:       "Pod",
+						Name:       "oom-killed",
+						APIVersion: "v1",
+					},
+					Count: 1,
+				},
+				e: corev1.Event{
+					Type: "Normal",
+					InvolvedObject: corev1.ObjectReference{
+						Kind:       "Pod",
+						Name:       "oom-killed",
+						Namespace:  "default",
+						APIVersion: "v1",
+					},
+					Count: 2,
+				},
+			},
+			want: want{
+				match: true,
+			},
+		},
+		"MatchNotEnoughEvents": {
+			args: args{
+				in: &v1alpha1.Input{
+					Type: "Normal",
+					InvolvedObject: corev1.ObjectReference{
+						Kind:       "Pod",
+						Name:       "oom-killed",
+						APIVersion: "v1",
+					},
+					Count: 3,
+				},
+				e: corev1.Event{
+					Type: "Normal",
+					InvolvedObject: corev1.ObjectReference{
+						Kind:       "Pod",
+						Name:       "oom-killed",
+						Namespace:  "default",
+						APIVersion: "v1",
+					},
+					Count: 1,
+				},
+			},
+			want: want{
+				match: false,
+			},
+		},
 	}
 
 	for name, tc := range cases {

input/v1alpha1/input.go

@@ -29,5 +29,10 @@ type Input struct {
 	// InvolvedObject specifies properties of the Object that can be used to
 	// filter incoming events.
 	// +optional
-	InvolvedObject corev1.ObjectReference `json:"involvedObject" protobuf:"bytes,2,opt,name=involvedObject"`
+	InvolvedObject corev1.ObjectReference `json:"involvedObject"`
+	// Count the minimal number of times the event has occurred.
+	// e.g. if Count: 1, then the event needs to have occurred more than 1
+	// time.
+	// +optional
+	Count int32 `json:"count"`
 }

package/input/filter.event.fn.upbound.io_inputs.yaml

@@ -28,6 +28,13 @@ spec:
               may reject unrecognized values.
               More info: https://git.k8s.io/community/contributors/devel/sig-architecture/api-conventions.md#resources
             type: string
+          count:
+            description: |-
+              Count the minimal number of times the event has occurred.
+              e.g. if Count: 1, then the event needs to have occurred more than 1
+              time.
+            format: int32
+            type: integer
           involvedObject:
             description: |-
               InvolvedObject specifies properties of the Object that can be used to