Merge pull request #231 from amorenoz/tabulated-write

Add tabulated output to write_stdout

docs/api.md

@@ -144,7 +144,8 @@ Following is the supported API format for writing to standard output:
 
 <pre>
  stdout:
-         format: the format of each line: printf (default) or json
+         format: the format of each line: printf (default - writes using golang's default map printing), fields (writes one key and value field per line) or json
+
 </pre>
 ## Aggregate metrics API
 Following is the supported API format for specifying metrics aggregations:

pkg/api/write_stdout.go

@@ -1,5 +1,5 @@
 package api
 
 type WriteStdout struct {
-	Format string `yaml:"format,omitempty" json:"format,omitempty" doc:"the format of each line: printf (default) or json"`
+	Format string `yaml:"format,omitempty" json:"format,omitempty" doc:"the format of each line: printf (default - writes using golang's default map printing), fields (writes one key and value field per line) or json"`
 }

pkg/pipeline/write/write_stdout.go

@@ -20,6 +20,9 @@ package write
 import (
 	"encoding/json"
 	"fmt"
+	"os"
+	"sort"
+	"text/tabwriter"
 	"time"
 
 	"github.com/netobserv/flowlogs-pipeline/pkg/config"
@@ -39,6 +42,20 @@ func (t *writeStdout) Write(in []config.GenericMap) {
 			txt, _ := json.Marshal(v)
 			fmt.Println(string(txt))
 		}
+	} else if t.format == "fields" {
+		for _, v := range in {
+			var order sort.StringSlice
+			for fieldName := range v {
+				order = append(order, fieldName)
+			}
+			order.Sort()
+			w := tabwriter.NewWriter(os.Stdout, 0, 0, 1, ' ', 0)
+			fmt.Fprintf(w, "\n\nFlow record at %s:\n", time.Now().Format(time.StampMilli))
+			for _, field := range order {
+				fmt.Fprintf(w, "%v\t=\t%v\n", field, v[field])
+			}
+			w.Flush()
+		}
 	} else {
 		for _, v := range in {
 			fmt.Printf("%s: %v\n", time.Now().Format(time.StampMilli), v)