Function streamWriteYAMLResponseCommon

pkg/util/http.go:116–130

StreamWriteYAMLResponseCommon stream writes data as http response

(w http.ResponseWriter, iter chan any, logger log.Logger, marshalFn func(in any) (out []byte, err error))

// StreamWriteYAMLResponseCommon stream writes data as http response
func streamWriteYAMLResponseCommon(w http.ResponseWriter, iter chan any, logger log.Logger, marshalFn func(in any) (out []byte, err error)) {
	w.Header().Set("Content-Type", "application/yaml")
	for v := range iter {
		data, err := marshalFn(v)
		if err != nil {
			level.Error(logger).Log("msg", "yaml marshal failed", "err", err)
			continue
		}
		_, err = w.Write(data)
		if err != nil {
			level.Error(logger).Log("msg", "write http response failed", "err", err)
			return
		}
	}
}

// StreamWriteYAMLResponse stream writes data as http response using yaml v2 library
func StreamWriteYAMLResponse(w http.ResponseWriter, iter chan any, logger log.Logger) {