write_stdout: add tabulated data format

Add a new write_stdout format called "fields". If specified, write a
tabulated list of fields. It's easier to read than raw json or text
outputs.

Signed-off-by: Adrian Moreno <[email protected]>

Author: amorenoz

docs/api.md

@@ -142,7 +142,7 @@ 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), fields 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), fields 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)