Added publishing tags by file publisher

examples/tasks/mock_tagged-file.json

@@ -0,0 +1,43 @@
+{
+    "version": 1,
+    "schedule": {
+        "type": "simple",
+        "interval": "1s"
+    },
+    "workflow": {
+        "collect": {
+            "metrics": {
+                "/intel/mock/foo": {},
+                "/intel/mock/bar": {},
+                "/intel/mock/*/baz": {}
+            },
+            "config": {
+                "/intel/mock": {
+                    "name": "root",
+                    "password": "secret"
+                }
+            },
+            "tags": {
+                "/intel/mock": {
+                    "experiment": "1",
+                    "os": "linux"
+                }
+            },
+
+            "process": [
+                {
+                    "plugin_name": "passthru",                    
+                    "process": null,
+                    "publish": [
+                        {
+                            "plugin_name": "file",                            
+                            "config": {
+                                "file": "/tmp/snap_published_mock_file.log"
+                            }
+                        }
+                    ]
+                }
+            ]
+        }
+    }
+}

plugin/publisher/snap-publisher-file/file/file.go

@@ -32,6 +32,7 @@ import (
 	"github.com/intelsdi-x/snap/control/plugin"
 	"github.com/intelsdi-x/snap/control/plugin/cpolicy"
 	"github.com/intelsdi-x/snap/core/ctypes"
+	"strings"
 )
 
 const (
@@ -73,12 +74,24 @@ func (f *filePublisher) Publish(contentType string, content []byte, config map[s
 	}
 	w := bufio.NewWriter(file)
 	for _, m := range metrics {
-		w.WriteString(fmt.Sprintf("%v|%v|%v\n", m.Timestamp(), m.Namespace(), m.Data()))
+		formattedTags := formatMetricTagsAsString(m.Tags())
+		w.WriteString(fmt.Sprintf("%v|%v|%v|%v\n", m.Timestamp(), m.Namespace(), m.Data(), formattedTags))
 	}
 	w.Flush()
 
 	return nil
 }
+// formatMetricTagsAsString returns metric's tags as a string in the following format tagKey:tagValue where the next tags are separated by semicolon
+func formatMetricTagsAsString(metricTags map[string]string) string {
+	var tags string
+	for tag, value := range metricTags {
+		tags += fmt.Sprintf("%s:%s; ", tag, value)
+	}
+	// trim the last semicolon
+	tags = strings.TrimSuffix(tags, "; ")
+
+	return "tags["+tags+"]"
+}
 
 func Meta() *plugin.PluginMeta {
 	return plugin.NewPluginMeta(name, version, pluginType, []string{plugin.SnapGOBContentType}, []string{plugin.SnapGOBContentType})