diff options
Diffstat (limited to 'plugins/jobs/job/general.go')
-rw-r--r-- | plugins/jobs/job/general.go | 29 |
1 files changed, 29 insertions, 0 deletions
diff --git a/plugins/jobs/job/general.go b/plugins/jobs/job/general.go new file mode 100644 index 00000000..390f44b5 --- /dev/null +++ b/plugins/jobs/job/general.go @@ -0,0 +1,29 @@ +package job + +// constant keys to pack/unpack messages from different drivers +const ( + RRID string = "rr_id" + RRJob string = "rr_job" + RRHeaders string = "rr_headers" + RRPipeline string = "rr_pipeline" + RRDelay string = "rr_delay" + RRPriority string = "rr_priority" +) + +// Job carries information about single job. +type Job struct { + // Job contains name of job broker (usually PHP class). + Job string `json:"job"` + + // Ident is unique identifier of the job, should be provided from outside + Ident string `json:"id"` + + // Payload is string data (usually JSON) passed to Job broker. + Payload string `json:"payload"` + + // Headers with key-value pairs + Headers map[string][]string `json:"headers"` + + // Options contains set of PipelineOptions specific to job execution. Can be empty. + Options *Options `json:"options,omitempty"` +} |