|
|
|
@ -99,12 +99,12 @@ func (ep *endpoint) createJob(reqID string, content []byte) (*jw.Job, error) {
|
|
|
|
|
return job, err |
|
|
|
|
} |
|
|
|
|
|
|
|
|
|
func (ep *endpoint) nextJob(reqID string) (*jw.Job, error) { |
|
|
|
|
func (ep *endpoint) nextJob(reqID, namespace string) (*jw.Job, error) { |
|
|
|
|
var job *jw.Job |
|
|
|
|
|
|
|
|
|
err := request. |
|
|
|
|
New(ep.URL). |
|
|
|
|
Path("api/jobs"). |
|
|
|
|
Path("api/jobs/"+namespace). |
|
|
|
|
Get(). |
|
|
|
|
BasicAuth(ep.Username, ep.Password). |
|
|
|
|
ID(reqID). |
|
|
|
|