in bulk/job.go [309:329]
func (j *Job) setState(state State) (Response, error) {
url := j.session.ServiceURL() + bulk2Endpoint + "/" + j.info.ID
jobState := struct {
State string `json:"state"`
}{
State: string(state),
}
body, err := json.Marshal(jobState)
if err != nil {
return Response{}, err
}
request, err := http.NewRequest(http.MethodPatch, url, bytes.NewReader(body))
if err != nil {
return Response{}, err
}
request.Header.Add("Accept", "application/json")
request.Header.Add("Content-Type", "application/json")
j.session.AuthorizationHeader(request)
return j.response(request)
}