diff options
| author | Paul Buetow <pbuetow@mimecast.com> | 2020-07-02 13:29:45 +0100 |
|---|---|---|
| committer | Paul Buetow <pbuetow@mimecast.com> | 2020-07-02 13:29:45 +0100 |
| commit | 7fff78dc69be2fdaa6646d98283a5a5991fdc757 (patch) | |
| tree | 57e121a4e501e99648ded9340c20d9918b563b33 /internal/mapr/aggregateset.go | |
| parent | 6c780b7cbafd5559a73b9bfc913be7c1e144c220 (diff) | |
send $line base64 encoded over the wire
Diffstat (limited to 'internal/mapr/aggregateset.go')
| -rw-r--r-- | internal/mapr/aggregateset.go | 8 |
1 files changed, 1 insertions, 7 deletions
diff --git a/internal/mapr/aggregateset.go b/internal/mapr/aggregateset.go index fdf8db2..d8705bd 100644 --- a/internal/mapr/aggregateset.go +++ b/internal/mapr/aggregateset.go @@ -6,8 +6,6 @@ import ( "fmt" "strconv" "strings" - - "github.com/mimecast/dtail/internal/io/logger" ) // AggregateSet represents aggregated key/value pairs from the @@ -86,11 +84,7 @@ func (s *AggregateSet) Serialize(ctx context.Context, groupKey string, ch chan<- sb.WriteString(k) sb.WriteString("=") if k == "$line" { - decoded, err := base64.StdEncoding.DecodeString(v) - if err != nil { - logger.Error("Unable to decode $line", err, v) - } - sb.WriteString(string(decoded)) + sb.WriteString(base64.StdEncoding.EncodeToString([]byte(v))) sb.WriteString("|") continue } |