support overriding event type (#984)

knative · Mar 3, 2020 · a49a7c7 · a49a7c7
1 parent 9b3ad64
commit a49a7c7
Showing 1 changed file with 7 additions and 1 deletion.
diff --git a/cmd/appender/main.go b/cmd/appender/main.go
@@ -41,7 +41,8 @@ https://knative.dev/docs/eventing/sequence/
 */
 
 type envConfig struct {
-	Msg string `envconfig:"MESSAGE" default:"boring default msg, change me with env[MESSAGE]"`
+	Msg  string `envconfig:"MESSAGE" default:"boring default msg, change me with env[MESSAGE]"`
+	Type string `envconfig:"TYPE"`
 }
 
 var (
@@ -73,6 +74,11 @@ func gotEvent(event cloudevents.Event, resp *cloudevents.EventResponse) error {
 		Data:    data,
 	}
 
+	// Resolve type
+	if env.Type != "" {
+		r.Context.SetType(env.Type)
+	}
+
 	r.SetDataContentType(cloudevents.ApplicationJSON)
 
 	log.Println("Transform the event to: ")