refactor: update event and sensor type (#506)

argoproj · Feb 25, 2020 · 97d4ca7 · 97d4ca7
1 parent 3883e47
commit 97d4ca7
Show file tree

Hide file tree

Showing 3 changed files with 28 additions and 9 deletions.
diff --git a/pkg/apis/events/doc.go b/pkg/apis/events/doc.go
@@ -0,0 +1 @@
+package events
diff --git a/pkg/apis/events/event-data.go b/pkg/apis/events/event-data.go
@@ -138,7 +138,7 @@ type KafkaEventData struct {
 	// Partition refers to the Kafka partition
 	Partition int `json:"partition"`
 	// Body refers to the message value
-	Body []byte `json:"value"`
+	Body []byte `json:"body"`
 	// Timestamp of the message
 	Timestamp string `json:"timestamp"`
 }
@@ -155,25 +155,25 @@ type MQTTEventData struct {
 	// MessageId is the unique ID for the message
 	MessageId int `json:"messageId"`
 	// Payload is the message payload.
-	Body []byte `json:"payload"`
+	Body []byte `json:"body"`
 }
 
 // NATSEventData represents the event data generated by the NATS gateway.
 type NATSEventData struct {
 	// Name of the subject.
 	Subject string `json:"subject"`
 	// Message data.
-	Body []byte `json:"data"`
+	Body []byte `json:"body"`
 }
 
 // NSQEventData represents the event data generated by the NSQ gateway.
 type NSQEventData struct {
 	// Body is the message data.
-	Body []byte
+	Body []byte `json:"body"`
 	// Timestamp of the message.
-	Timestamp string
+	Timestamp string `json:"timestamp"`
 	// NSQDAddress is the address of the nsq host.
-	NSQDAddress string
+	NSQDAddress string `json:"nsqdAddress"`
 }
 
 // RedisEventData represents the event data generated by the Redis gateway.
@@ -183,7 +183,7 @@ type RedisEventData struct {
 	// Message pattern
 	Pattern string `json:"pattern"`
 	// Message body
-	Body string `json:"payload"`
+	Body string `json:"body"`
 }
 
 // ResourceEventData represents the event data generated by the Resource gateway.

diff --git a/pkg/apis/sensor/v1alpha1/openapi_generated.go b/pkg/apis/sensor/v1alpha1/openapi_generated.go