Support any K8s spec as trigger source (#259)

* feature(): adding support backoff feature

* feature(): update backoff policy feature and add example

* feature(): adding support to directly specify any K8s resource spec as trigger source

Makefile

@@ -283,10 +283,6 @@ coverage:
 clean:
 	-rm -rf ${CURRENT_DIR}/dist
 
-.PHONY: protogen
-protogen:
-	./hack/generate-proto.sh
-
 .PHONY: clientgen
 clientgen:
 	./hack/update-codegen.sh
@@ -296,7 +292,7 @@ openapi-gen:
 	./hack/update-openapigen.sh
 
 .PHONY: codegen
-codegen: clientgen openapigen protogen
+codegen: clientgen openapigen
 
 .PHONY: e2e
 e2e:

controllers/common/informer_test.go

@@ -37,7 +37,7 @@ func getInformerFactory(clientset kubernetes.Interface, queue workqueue.RateLimi
 		OwnerGroupVersionKind: schema.GroupVersionKind{Version: "v1", Kind: "Pod"},
 		OwnerInformer:         ownerInformer,
 		SharedInformerFactory: informerFactory,
-		Queue:                 queue,
+		Queue: queue,
 	}
 }
 

controllers/gateway/controller.go

@@ -194,7 +194,7 @@ func (c *GatewayController) Run(ctx context.Context, gwThreads, eventThreads int
 		OwnerGroupVersionKind: v1alpha1.SchemaGroupVersionKind,
 		OwnerInformer:         c.informer,
 		SharedInformerFactory: informers.NewFilteredSharedInformerFactory(c.kubeClientset, gatewayResourceResyncPeriod, c.Config.Namespace, listOptionsFunc),
-		Queue:                 c.queue,
+		Queue: c.queue,
 	}
 
 	c.podInformer = factory.NewPodInformer()

controllers/sensor/controller.go

@@ -195,7 +195,7 @@ func (c *SensorController) Run(ctx context.Context, ssThreads, eventThreads int)
 		OwnerGroupVersionKind: v1alpha1.SchemaGroupVersionKind,
 		OwnerInformer:         c.informer,
 		SharedInformerFactory: informers.NewFilteredSharedInformerFactory(c.kubeClientset, sensorResourceResyncPeriod, c.Config.Namespace, listOptionsFunc),
-		Queue:                 c.queue,
+		Queue: c.queue,
 	}
 
 	c.podInformer = factory.NewPodInformer()

examples/sensors/trigger-resource.yaml

@@ -0,0 +1,54 @@
+apiVersion: argoproj.io/v1alpha1
+kind: Sensor
+metadata:
+  name: trigger-resource-sensor
+  labels:
+    sensors.argoproj.io/sensor-controller-instanceid: argo-events
+spec:
+  template:
+    spec:
+      containers:
+        - name: "sensor"
+          image: "argoproj/sensor"
+          imagePullPolicy: Always
+      serviceAccountName: argo-events-sa
+  dependencies:
+    - name: "webhook-gateway-http:foo"
+  eventProtocol:
+    type: "HTTP"
+    http:
+      port: "9300"
+  triggers:
+    - template:
+        name: trigger1
+        group: argoproj.io
+        version: v1alpha1
+        kind: Workflow
+        source:
+          # resource is generic template for K8s resource
+          # This is similar to `inline` trigger but useful if you are using kustomize and want to parameterize the trigger
+          resource:
+              apiVersion: argoproj.io/v1alpha1
+              kind: Workflow
+              metadata:
+                generateName: webhook-
+              spec:
+                entrypoint: whalesay
+                arguments:
+                  parameters:
+                    - name: message
+                      # this is the value that should be overridden
+                      value: hello world
+                templates:
+                  - name: whalesay
+                    inputs:
+                      parameters:
+                        - name: message
+                    container:
+                      image: docker/whalesay:latest
+                      command: [cowsay]
+                      args: ["{{inputs.parameters.message}}"]
+      resourceParameters:
+        - src:
+            event: "webhook-gateway-http:foo"
+          dest: spec.arguments.parameters.0.value

gateways/community/gitlab/start.go

@@ -66,8 +66,8 @@ func (rc *RouteConfig) PostStart() error {
 	formattedUrl := gwcommon.GenerateFormattedURL(rc.ges.Hook)
 
 	opt := &gitlab.AddProjectHookOptions{
-		URL:                   &formattedUrl,
-		Token:                 &c.token,
+		URL:   &formattedUrl,
+		Token: &c.token,
 		EnableSSLVerification: &rc.ges.EnableSSLVerification,
 	}
 

gateways/core/resource/start_test.go

@@ -93,7 +93,7 @@ func TestFilter(t *testing.T) {
 				Namespace: "fake",
 				Labels: map[string]string{
 					"workflows.argoproj.io/phase": "Succeeded",
-					"name":                        "my-workflow",
+					"name": "my-workflow",
 				},
 			},
 		}