initial log monitoring support

1 files changed, 6 insertions, 0 deletions

diff --git a/internal/mapr/server/aggregate.go b/internal/mapr/server/aggregate.go
index 9403aa9..80a464d 100644
--- a/internal/mapr/server/aggregate.go
+++ b/internal/mapr/server/aggregate.go
@@ -192,6 +192,12 @@ func (a *Aggregate) aggregate(group *mapr.GroupSet, fields map[string]string) {
 	var addedSample bool
 	for _, sc := range a.query.Select {
 		if val, ok := fields[sc.Field]; ok {
+			/*
+				if sc.Field == "$line" {
+					// Complete log line as to arrive untouched on the client side.
+					val = base64.StdEncoding.EncodeToString([]byte(val))
+				}
+			*/
 			if err := set.Aggregate(sc.FieldStorage, sc.Operation, val, false); err != nil {
 				logger.Error(err)
 				continue