From ccaf1ffafe6a04244d7b20bc0cfc30dbc0a5ebb5 Mon Sep 17 00:00:00 2001 From: Arash Hatami Date: Sun, 29 Sep 2024 06:03:50 +0330 Subject: [PATCH] fix(backend): http - add header (#596) Signed-off-by: Arash Hatami --- pkg/backend/http/sink.go | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/pkg/backend/http/sink.go b/pkg/backend/http/sink.go index cca7861c..9e090785 100644 --- a/pkg/backend/http/sink.go +++ b/pkg/backend/http/sink.go @@ -6,6 +6,7 @@ package http import ( "context" + "net/http" "net/url" "github.com/rs/zerolog/log" @@ -60,7 +61,7 @@ func (s *Sink) Dequeue(ctx context.Context, envelopes []envelope.Envelope, outpu log.Error().Err(err).Msg("🔴 " + output + " is not a valid url") return err } - _, err = request.PostEnvelopes(*url, envelopes, nil) + _, err = request.PostEnvelopes(*url, envelopes, http.Header{}) if err != nil { log.Error().Err(err).Interface("metadata", s.Metadata()).Msg("🔴 could not dequeue payloads") }