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 | 41fb325372034c7a42bf0157cdc08894d8371247 (patch) | |
| tree | 57e121a4e501e99648ded9340c20d9918b563b33 /internal/mapr/aggregateset.go | |
| parent | 490615493acc8deb0b29c19cfdcd6ca067760c4b (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 } |