in bulk/job.go [362:380]
func (j *Job) Upload(body io.Reader) error {
url := j.session.ServiceURL() + bulk2Endpoint + "/" + j.info.ID + "/batches"
request, err := http.NewRequest(http.MethodPut, url, body)
if err != nil {
return err
}
request.Header.Add("Content-Type", "text/csv")
j.session.AuthorizationHeader(request)
response, err := j.session.Client().Do(request)
if err != nil {
return err
}
if response.StatusCode != http.StatusCreated {
return errors.New("job error: unable to upload job")
}
return nil
}