in internal/conn/http/http.go [241:257]
func (c *Client) setup(ctx context.Context, event *bytes.Reader, headers []string) (*policy.Request, error) {
if event.Len() == 0 {
return nil, fmt.Errorf("event is empty")
}
r := rsc{event}
req, err := runtime.NewRequest(ctx, http.MethodPost, c.endpoint)
if err != nil {
return nil, err
}
req.Raw().Header["Accept"] = appJSON
for i := 0; i < len(headers); i += 2 {
req.Raw().Header.Add(headers[i], headers[i+1])
}
return req, req.SetBody(r, "application/json")
}