Add reason to input

fn.go

@@ -132,6 +132,10 @@ func match(in *v1alpha1.Input, e corev1.Event) bool { //nolint:gocyclo // This m
 		return false
 	}
 
+	if in.Reason != "" && in.Reason != e.Reason {
+		return false
+	}
+
 	if in.Count != 0 && in.Count >= e.Count {
 		return false
 	}

fn_test.go

@@ -36,6 +36,19 @@ func TestMatch(t *testing.T) {
 				match: true,
 			},
 		},
+		"MatchesReasonOnly": {
+			args: args{
+				in: &v1alpha1.Input{
+					Type: "BackOff",
+				},
+				e: corev1.Event{
+					Type: "BackOff",
+				},
+			},
+			want: want{
+				match: true,
+			},
+		},
 		"MatchesNameOnly": {
 			args: args{
 				in: &v1alpha1.Input{
@@ -115,6 +128,28 @@ func TestMatch(t *testing.T) {
 				match: false,
 			},
 		},
+		"DoesntMatchReason": {
+			args: args{
+				in: &v1alpha1.Input{
+					Reason: "BackOff",
+					InvolvedObject: corev1.ObjectReference{
+						Name:      "oom-killed",
+						Namespace: "default",
+					},
+				},
+				e: corev1.Event{
+					Type:   "Warning",
+					Reason: "FailedScheduling",
+					InvolvedObject: corev1.ObjectReference{
+						Name:      "oom-killed",
+						Namespace: "default",
+					},
+				},
+			},
+			want: want{
+				match: false,
+			},
+		},
 		"DoesntMatchKind": {
 			args: args{
 				in: &v1alpha1.Input{

input/v1alpha1/input.go

@@ -26,6 +26,9 @@ type Input struct {
 	// Type of this event (Normal, Warning).
 	// +optional
 	Type string `json:"type"`
+	// Reason correlated to the Event. e.g. BackOff.
+	// +optional
+	Reason string `json:"reason"`
 	// InvolvedObject specifies properties of the Object that can be used to
 	// filter incoming events.
 	// +optional

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

@@ -90,6 +90,9 @@ spec:
             type: string
           metadata:
             type: object
+          reason:
+            description: Reason correlated to the Event. e.g. BackOff.
+            type: string
           type:
             description: Type of this event (Normal, Warning).
             type: string