in logsapi/subscribe.go [128:144]
func (lc *Client) sendRequest(url string, data []byte, extensionID string) (*http.Response, error) {
req, err := http.NewRequest(http.MethodPut, url, bytes.NewBuffer(data))
if err != nil {
return nil, fmt.Errorf("failed to create request: %w", err)
}
req.Header.Set("Content-Type", "application/json")
req.Header.Set("Lambda-Extension-Identifier", extensionID)
req.Header.Set("User-Agent", version.UserAgent)
resp, err := lc.httpClient.Do(req)
if err != nil {
return nil, fmt.Errorf("request failed: %w", err)
}
return resp, nil
}