Method EventStreamReader

pkg/apiclient/http1/facade.go:52–91

(ctx context.Context, in interface{}, path string)

}

func (h Facade) EventStreamReader(ctx context.Context, in interface{}, path string) (*bufio.Reader, error) {
	log := logging.RequireLoggerFromContext(ctx)
	method := "GET"
	u, err := h.url(method, path, in)
	if err != nil {
		return nil, err
	}
	req, err := http.NewRequestWithContext(ctx, http.MethodGet, u.String(), nil)
	if err != nil {
		return nil, err
	}
	headers, err := parseHeaders(h.headers)
	if err != nil {
		return nil, err
	}
	req.Header = headers
	req.Header.Set("Accept", "text/event-stream")
	req.Header.Set("Authorization", h.authorization)
	log.WithField("url", u).Debug(ctx, "curl -H 'Accept: text/event-stream' -H 'Authorization: ******'")
	client := h.httpClient
	if h.httpClient == nil {
		client = &http.Client{
			Transport: &http.Transport{
				TLSClientConfig: &tls.Config{
					InsecureSkipVerify: h.insecureSkipVerify,
				},
			},
		}
	}
	resp, err := client.Do(req)
	if err != nil {
		return nil, err
	}
	err = errFromResponse(resp)
	if err != nil {
		resp.Body.Close()
		return nil, err
	}
	return bufio.NewReader(resp.Body), nil
}

func (h Facade) do(ctx context.Context, in interface{}, out interface{}, method string, path string) error {
	log := logging.RequireLoggerFromContext(ctx)