in lambda/extensions_api_client.go [70:90]
func (c *extensionAPIClient) next(id string) (response extensionEventResponse, err error) {
url := c.baseURL + "event/next"
req, _ := http.NewRequest(http.MethodGet, url, nil)
req.Header.Add(headerExtensionIdentifier, id)
res, err := c.httpClient.Do(req)
if err != nil {
err = fmt.Errorf("failed to get extension event: %v", err)
return
}
defer res.Body.Close()
_, _ = io.Copy(ioutil.Discard, res.Body)
if res.StatusCode != http.StatusOK {
err = fmt.Errorf("failed to register extension, got response status: %d %s", res.StatusCode, http.StatusText(res.StatusCode))
return
}
err = json.NewDecoder(res.Body).Decode(&response)
return
}