From 3a6c2303f20445702cfc094e825330bea5962783 Mon Sep 17 00:00:00 2001 From: Michael Chiang Date: Mon, 9 Oct 2023 15:52:01 -0700 Subject: [PATCH 1/2] added header fields to http sender --- pkg/plugins/http/sender.go | 3 +++ pkg/plugins/http/types.go | 5 +++-- 2 files changed, 6 insertions(+), 2 deletions(-) diff --git a/pkg/plugins/http/sender.go b/pkg/plugins/http/sender.go index 1b17e899..bfd41926 100644 --- a/pkg/plugins/http/sender.go +++ b/pkg/plugins/http/sender.go @@ -138,6 +138,9 @@ func (s *Sender) Send(event event.Event) { event.Nack(err) return } + for k, v := range s.config.Headers { + req.Header.Set(k, v) + } ctx := event.Context() s.b3Propagator.Inject(ctx, propagation.HeaderCarrier(req.Header)) start := time.Now() diff --git a/pkg/plugins/http/types.go b/pkg/plugins/http/types.go index 0854c3c6..4334d973 100644 --- a/pkg/plugins/http/types.go +++ b/pkg/plugins/http/types.go @@ -98,8 +98,9 @@ type Receiver struct { } type SenderConfig struct { - Url string `json:"url"` - Method string `json:"method"` + Url string `json:"url"` + Method string `json:"method"` + Headers map[string]string `json:"headers,omitempty"` } type Sender struct { From eb4d39e9fc2ce6d578c6c96444d13c69cade2618 Mon Sep 17 00:00:00 2001 From: Michael Chiang Date: Mon, 9 Oct 2023 17:14:01 -0700 Subject: [PATCH 2/2] fix sender config validation --- pkg/plugins/http/sender_config.go | 3 +++ 1 file changed, 3 insertions(+) diff --git a/pkg/plugins/http/sender_config.go b/pkg/plugins/http/sender_config.go index 94214593..1bea00c8 100644 --- a/pkg/plugins/http/sender_config.go +++ b/pkg/plugins/http/sender_config.go @@ -47,6 +47,9 @@ const senderSchema = ` }, "method": { "type": "string" + }, + "headers": { + "type": "object" } }, "required": [