Documentation ¶
Index ¶
- func JobAcknowledge(w http.ResponseWriter, req *http.Request, conf *config.Config, ...) error
- func JobPublish(w http.ResponseWriter, req *http.Request, conf *config.Config, ...) error
- func JobReject(w http.ResponseWriter, req *http.Request, conf *config.Config, ...) error
- func Run(conf *config.Config)
- func Watchdog(ticker *time.Ticker, conf *config.Config, jobManifest *job.Manifest, ...)
- type JobSchema
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func JobAcknowledge ¶
func JobAcknowledge( w http.ResponseWriter, req *http.Request, conf *config.Config, jobManifest *job.Manifest, broker *broker.Shim) error
JobCheckout is executed when a workload finishes a job, and registers it as completed
func JobPublish ¶
func JobPublish( w http.ResponseWriter, req *http.Request, conf *config.Config, jobManifest *job.Manifest, broker *broker.Shim) error
JobCheckout is executed when a workload finishes a job, and registers it as completed
Types ¶
Click to show internal directories.
Click to hide internal directories.