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/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": [ 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 {