in bulk/job.go [342:359]
func (j *Job) Delete() error {
url := j.session.ServiceURL() + bulk2Endpoint + "/" + j.info.ID
request, err := http.NewRequest(http.MethodDelete, url, nil)
if err != nil {
return err
}
j.session.AuthorizationHeader(request)
response, err := j.session.Client().Do(request)
if err != nil {
return err
}
if response.StatusCode != http.StatusNoContent {
return errors.New("job error: unable to delete job")
}
return nil
}