func newJobs()

in bulk/jobs.go [36:56]


func newJobs(session session.ServiceFormatter, parameters Parameters) (*Jobs, error) {
	j := &Jobs{
		session: session,
	}
	url := session.ServiceURL() + bulk2Endpoint
	request, err := j.request(url)
	if err != nil {
		return nil, err
	}
	q := request.URL.Query()
	q.Add("isPkChunkingEnabled", strconv.FormatBool(parameters.IsPkChunkingEnabled))
	q.Add("jobType", string(parameters.JobType))
	request.URL.RawQuery = q.Encode()

	response, err := j.do(request)
	if err != nil {
		return nil, err
	}
	j.response = response
	return j, nil
}