Method setjobStatus

job_queue_rabbitmq.go:107–131

(ctx context.Context, job benchJob, status string, res agentExecRes)

}

func (q jobQueue) setjobStatus(ctx context.Context, job benchJob, status string, res agentExecRes) error {
	log.WithField("status", status).Info("Set job status")
	jobStatus := &jobStatus{
		ID:      job.ID,
		Status:  status,
		Message: res.Message,
		Error:   res.Error,
		StdErr:  "",
		StdOut:  "",
	}
	b, err := json.Marshal(jobStatus)
	if err != nil {
		return err
	}
	err = q.ch.Publish(
		"jobs_status_ex", // exchange
		"jobs_status_rk", // routing key
		false,            // mandatory
		false,            // immediate
		amqp.Publishing{
			ContentType: "text/plain",
			Body:        b,
		})
	return err
}

func (q jobQueue) setjobReceived(ctx context.Context, job benchJob) error {
	return q.setjobStatus(ctx, job, "received", agentExecRes{})