Change event names

keventmesh · Oct 5, 2023 · 7e5c4f9 · 7e5c4f9
1 parent f31e0d2
commit 7e5c4f9
Show file tree

Hide file tree

Showing 10 changed files with 14 additions and 14 deletions.
diff --git a/infra/openshift-manifests/analytics-service/feedbacks-trigger.yaml b/infra/openshift-manifests/analytics-service/feedbacks-trigger.yaml
@@ -7,7 +7,7 @@ spec:
   broker: analytics-broker
   filter:
     attributes:
-      type: com.knative.dev.feedback.event
+      type: eventmesh.ai-demo.feedback
   subscriber:
     ref:
       apiVersion: serving.knative.dev/v1

diff --git a/infra/openshift-manifests/analytics-service/predictions-trigger.yaml b/infra/openshift-manifests/analytics-service/predictions-trigger.yaml
@@ -7,7 +7,7 @@ spec:
   broker: predictions-broker
   filter:
     attributes:
-      type: com.knative.dev.prediction.event
+      type: eventmesh.ai-demo.prediction
   subscriber:
     ref:
       apiVersion: serving.knative.dev/v1

diff --git a/infra/openshift-manifests/prediction-service/trigger.yaml b/infra/openshift-manifests/prediction-service/trigger.yaml
@@ -7,7 +7,7 @@ spec:
   broker: predictions-broker
   filter:
     attributes:
-      type: com.knative.dev.minio.event
+      type: eventmesh.ai-demo.storage
   subscriber:
     ref:
       apiVersion: serving.knative.dev/v1

diff --git a/infra/openshift-manifests/reply-service/trigger.yaml b/infra/openshift-manifests/reply-service/trigger.yaml
@@ -7,7 +7,7 @@ spec:
   broker: predictions-broker
   filter:
     attributes:
-      type: com.knative.dev.prediction.event
+      type: eventmesh.ai-demo.prediction
   subscriber:
     ref:
       apiVersion: v1
@@ -23,7 +23,7 @@ spec:
   broker: predictions-broker
   filter:
     attributes:
-      type: com.knative.dev.prediction.event
+      type: eventmesh.ai-demo.prediction
   subscriber:
     ref:
       apiVersion: v1

diff --git a/services/feedback-service/README.md b/services/feedback-service/README.md
@@ -45,7 +45,7 @@ and these headers:
 connection: close
 content-length: 180
 ce-time: 2023-09-26T11:29:10.252868+00:00
-ce-type: com.knative.dev.feedback.event
+ce-type: eventmesh.ai-demo.feedback
 ce-source: feedback-service
 ce-id: 2ea7f9e1-2ca7-4984-bfb5-d4c1064d12da
 ce-specversion: 1.0

diff --git a/services/feedback-service/app.py b/services/feedback-service/app.py
@@ -62,7 +62,7 @@ def receive_feedback():
     }
 
     ce_attributes = {
-        "type": "com.knative.dev.feedback.event",
+        "type": "eventmesh.ai-demo.feedback",
         "source": SOURCE_DECLARATION,
     }
     event = CloudEvent(ce_attributes, ce_data)

diff --git a/services/minio-webhook-source/README.md b/services/minio-webhook-source/README.md
@@ -52,7 +52,7 @@ and these headers:
 connection: close
 content-length: 180
 ce-time: 2023-09-26T11:29:10.252868+00:00
-ce-type: com.knative.dev.minio.event
+ce-type: eventmesh.ai-demo.storage
 ce-source: pod.my-namespace.my-pod
 ce-id: 2ea7f9e1-2ca7-4984-bfb5-d4c1064d12da
 ce-specversion: 1.0

diff --git a/services/minio-webhook-source/app.py b/services/minio-webhook-source/app.py
@@ -122,7 +122,7 @@ def receive_event():
     }
 
     ce_attributes = {
-        "type": "com.knative.dev.minio.event",
+        "type": "eventmesh.ai-demo.storage",
         "source": SOURCE_DECLARATION,
     }
     event = CloudEvent(ce_attributes, ce_data)

diff --git a/services/prediction-service/README.md b/services/prediction-service/README.md
@@ -1,10 +1,10 @@
 # Prediction service
 
 This service:
-- Receives a `com.knative.dev.minio.event` event
+- Receives a `eventmesh.ai-demo.storage` event
 - Downloads the image from Minio
 - Sends the image to the KServe inference service
-- Replies with the prediction result as a `com.knative.dev.prediction.event` event
+- Replies with the prediction result as a `eventmesh.ai-demo.prediction` event
 
 This image is published at `quay.io/kevent-mesh/ai-demo-prediction-service`.
 
@@ -114,7 +114,7 @@ Test:
 # Send a sample event
 curl -i 'http://localhost:8083/'                      \
   -H 'ce-time: 2023-09-26T12:35:14.372688+00:00'      \
-  -H 'ce-type: com.knative.dev.minio.event'           \
+  -H 'ce-type: eventmesh.ai-demo.storage'           \
   -H 'ce-source: pod.ai-demo.minio-webhook-service'   \
   -H 'ce-id: a9254f41-4d32-45d2-8293-e90d96876de1'    \
   -H 'ce-specversion: 1.0'                            \
@@ -145,7 +145,7 @@ Content-Length: 125
 ce-specversion: 1.0
 ce-id: df0340be-6e7e-4136-8445-895b8de32a0b
 ce-source: prediction-service
-ce-type: com.knative.dev.prediction.event
+ce-type: eventmesh.ai-demo.prediction
 ce-time: 2023-09-27T12:11:02.451656+00:00
 Access-Control-Allow-Origin: *
 Connection: close

diff --git a/services/prediction-service/app.py b/services/prediction-service/app.py
@@ -195,7 +195,7 @@ def prediction_request():
     print(f"Returning prediction result for upload ID {upload_id}: {ce_data}")
 
     ce_attributes = {
-        "type": "com.knative.dev.prediction.event",
+        "type": "eventmesh.ai-demo.prediction",
         "source": SOURCE_DECLARATION,
     }
     event = CloudEvent(ce_attributes, ce_data)