Workaround for an issue in https://github.com/argoproj/argo-cd/issues/5715

parse_argo.go

package parse_argo

import (
	"io"
	"regexp"

	"github.com/go-logfmt/logfmt"
	"github.com/msoap/byline"
)

type ParseArgo struct {
	dec *logfmt.Decoder	
}

func NewParseArgo(r io.Reader) ParseArgo {
	dropLines := byline.NewReader(r).GrepByRegexp(regexp.MustCompile(`^time=`))
	return ParseArgo{ dec: logfmt.NewDecoder(dropLines) }
}

func (p ParseArgo) NextLine() map[string]string, error {
	var result map[string]string
	dec := p.dec
	if dec.ScanRecord() {
		result = make(map[string]string)
		for dec.ScanKeyval() {
			result[string(dec.Key())] = string(dec.Value())
		}
	}
	return result, dec.Err()
}