summaryrefslogtreecommitdiff
path: root/plugins/jobs/job/general.go
diff options
context:
space:
mode:
Diffstat (limited to 'plugins/jobs/job/general.go')
-rw-r--r--plugins/jobs/job/general.go29
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"`
+}