Method GetAssignment

controller/client/controller.go:184–195

GetAssignment gets the job assignment of the ares-subscriber

(jobNamespace, instance string)

// GetAssignment gets the job assignment of the ares-subscriber
func (c *ControllerHTTPClient) GetAssignment(jobNamespace, instance string) (assignment *models.IngestionAssignment, err error) {
	request, err := c.buildRequest(http.MethodGet, fmt.Sprintf("assignment/%s/assignments/%s", jobNamespace, instance), nil)
	if err != nil {
		err = utils.StackError(err, "Failed to buildRequest")
		return
	}

	request.Header.Add(utils.HTTPContentTypeHeaderKey, utils.HTTPContentTypeApplicationJson)
	assignment = &models.IngestionAssignment{}
	err = c.getJSONResponse(request, assignment)
	return assignment, err
}

// SetNamespace sets the namespace which the ControllerHTTPClient connects to
func (c *ControllerHTTPClient) SetNamespace(namespace string) {