+type ErrorInfo struct {
+ // A URI reference that identifies the problem type.
+ Type string `json:"type" swaggertype:"string"`
+ // A short, human-readable summary of the problem type.
+ Title string `json:"title" swaggertype:"string"`
+ // The HTTP status code generated by the origin server for this occurrence of the problem.
+ Status int `json:"status" swaggertype:"integer" example:"400"`
+ // A human-readable explanation specific to this occurrence of the problem.
+ Detail string `json:"detail" swaggertype:"string" example:"Info job type not found"`
+ // A URI reference that identifies the specific occurrence of the problem.
+ Instance string `json:"instance" swaggertype:"string"`
+} // @name ErrorInfo
+
+type ProducerCallbackHandler struct {
+ jobsManager jobs.JobsManager
+}
+
+func NewProducerCallbackHandler(jm jobs.JobsManager) *ProducerCallbackHandler {
+ return &ProducerCallbackHandler{
+ jobsManager: jm,
+ }
+}
+
+func NewRouter(jm jobs.JobsManager, hcf func(http.ResponseWriter, *http.Request)) *mux.Router {
+ callbackHandler := NewProducerCallbackHandler(jm)