github-mirrors/VictoriaMetrics
1
0
Fork 0
mirror of https://github.com/VictoriaMetrics/VictoriaMetrics.git synced 2025-01-10 15:14:09 +00:00
Code Issues Projects Releases Packages Wiki Activity

app/{vmagent/insert} fix typo in Firehose

Browse source 
Signed-off-by: Artem Navoiev <tenmozes@gmail.com>
This commit is contained in:
Artem Navoiev 2024-04-02 17:41:21 +02:00 committed by Aliaksandr Valialkin
parent 456180b9d9
commit f668489051
No known key found for this signature in database
GPG key ID: 52C003EE2BCDB9EB
1 changed files with 1 additions and 1 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

2
app/vmagent/opentelemetry/request_handler.go
View file

@ -30,7 +30,7 @@ func InsertHandler(at *auth.Token, req *http.Request) error {
isGzipped := req.Header.Get("Content-Encoding") == "gzip" isGzipped := req.Header.Get("Content-Encoding") == "gzip"
var processBody func([]byte) ([]byte, error) var processBody func([]byte) ([]byte, error)
if req.Header.Get("Content-Type") == "application/json" { if req.Header.Get("Content-Type") == "application/json" {
if req.Header.Get("X-Amz-Firehouse-Protocol-Version") != "" { if req.Header.Get("X-Amz-Firehose-Protocol-Version") != "" {
processBody = firehose.ProcessRequestBody processBody = firehose.ProcessRequestBody
} else { } else {
return fmt.Errorf("json encoding isn't supported for opentelemetry format. Use protobuf encoding") return fmt.Errorf("json encoding isn't supported for opentelemetry format. Use protobuf encoding")