feat: add alibabacloud mns as eventsource

Signed-off-by: shuangkun <[email protected]>
argoproj · Jan 10, 2024 · bf99dcf · bf99dcf
1 parent 4939a3c
commit bf99dcf
Show file tree

Hide file tree

Showing 17 changed files with 1,813 additions and 507 deletions.
diff --git a/api/event-source.html b/api/event-source.html
diff --git a/api/event-source.md b/api/event-source.md
diff --git a/api/jsonschema/schema.json b/api/jsonschema/schema.json
@@ -1551,6 +1551,13 @@
           "description": "Minio event sources",
           "type": "object"
         },
+        "mns": {
+          "additionalProperties": {
+            "$ref": "#/definitions/io.argoproj.eventsource.v1alpha1.MNSEventSource"
+          },
+          "description": "MNS event sources",
+          "type": "object"
+        },
         "mqtt": {
           "additionalProperties": {
             "$ref": "#/definitions/io.argoproj.eventsource.v1alpha1.MQTTEventSource"
@@ -2171,6 +2178,38 @@
       ],
       "type": "object"
     },
+    "io.argoproj.eventsource.v1alpha1.MNSEventSource": {
+      "description": "MNSEventSource refers to event-source for AlibabaCloud MNS related events",
+      "properties": {
+        "accessKey": {
+          "$ref": "#/definitions/io.k8s.api.core.v1.SecretKeySelector",
+          "description": "AccessKey refers K8s secret containing AlibabaCloud access key"
+        },
+        "endpoint": {
+          "description": "Endpoint configures connection to a specific AlibabaCloud MNS endpoint",
+          "type": "string"
+        },
+        "filter": {
+          "$ref": "#/definitions/io.argoproj.eventsource.v1alpha1.EventSourceFilter",
+          "description": "Filter"
+        },
+        "jsonBody": {
+          "type": "boolean"
+        },
+        "queue": {
+          "description": "Queue is AlibabaCloud MNS queue to listen to for messages",
+          "type": "string"
+        },
+        "secretKey": {
+          "$ref": "#/definitions/io.k8s.api.core.v1.SecretKeySelector",
+          "description": "SecretKey refers K8s secret containing AlibabaCloud secret key"
+        }
+      },
+      "required": [
+        "queue"
+      ],
+      "type": "object"
+    },
     "io.argoproj.eventsource.v1alpha1.MQTTEventSource": {
       "description": "MQTTEventSource refers to event-source for MQTT related events",
       "properties": {