CL-Softwares
/
telegraf
8
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

chore(parsers.prometheus): Do not warn about unknown format without headers (#16166)

This commit is contained in:
Sven Rebhan 2024-11-12 18:05:11 +01:00 committed by GitHub
parent e5e52f0a4a
commit 54dcd2d8cb
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194
1 changed files with 12 additions and 9 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

21
plugins/parsers/prometheus/parser.go
View File

@ -33,16 +33,19 @@ func (p *Parser) SetDefaultTags(tags map[string]string) {
func (p *Parser) Parse(data []byte) ([]telegraf.Metric, error) {
// Determine the metric transport-type derived from the response header and
// create a matching decoder.
format := expfmt.ResponseFormat(p.Header)
switch format.FormatType() {
case expfmt.TypeProtoText:
// Make sure we have a finishing newline but no trailing one
data = bytes.TrimPrefix(data, []byte("\n"))
if !bytes.HasSuffix(data, []byte("\n")) {
data = append(data, []byte("\n")...)
format := expfmt.NewFormat(expfmt.TypeProtoCompact)
if len(p.Header) > 0 {
format = expfmt.ResponseFormat(p.Header)
switch format.FormatType() {
case expfmt.TypeProtoText:
// Make sure we have a finishing newline but no trailing one
data = bytes.TrimPrefix(data, []byte("\n"))
if !bytes.HasSuffix(data, []byte("\n")) {
data = append(data, []byte("\n")...)
}
case expfmt.TypeUnknown:
p.Log.Debugf("Unknown format %q... Trying to continue...", p.Header.Get("Content-Type"))
}
case expfmt.TypeUnknown:
p.Log.Debugf("Unknown format %q... Trying to continue...", p.Header.Get("Content-Type"))
}
buf := bytes.NewBuffer(data)
decoder := expfmt.NewDecoder(buf, format)