rest: add tags to task watch events

intelsdi-x · Mar 22, 2016 · f6acee8 · f6acee8
1 parent 00093b4
commit f6acee8
Show file tree

Hide file tree

Showing 2 changed files with 6 additions and 4 deletions.
diff --git a/mgmt/rest/rbody/task.go b/mgmt/rest/rbody/task.go
@@ -250,10 +250,11 @@ func (s *StreamedTaskEvent) ToJSON() string {
 }
 
 type StreamedMetric struct {
-	Namespace string      `json:"namespace"`
-	Data      interface{} `json:"data"`
-	Source    string      `json:"source"`
-	Timestamp time.Time   `json:"timestamp"`
+	Namespace string            `json:"namespace"`
+	Data      interface{}       `json:"data"`
+	Source    string            `json:"source"`
+	Timestamp time.Time         `json:"timestamp"`
+	Tags      map[string]string `json:"tags"`
 }
 
 type StreamedMetrics []StreamedMetric

diff --git a/mgmt/rest/task.go b/mgmt/rest/task.go
@@ -365,6 +365,7 @@ func (t *TaskWatchHandler) CatchCollection(m []core.Metric) {
 			Data:      m[i].Data(),
 			Source:    m[i].Source(),
 			Timestamp: m[i].Timestamp(),
+			Tags:      m[i].Tags(),
 		}
 	}
 	t.mChan <- rbody.StreamedTaskEvent{