From d099e47ab28dd044d34e18347a4c714b8af3d612 Mon Sep 17 00:00:00 2001 From: Valery Piashchynski Date: Wed, 14 Jul 2021 11:35:12 +0300 Subject: SQS driver. Fix isssues in the AMQP driver. Signed-off-by: Valery Piashchynski --- plugins/jobs/job/general.go | 31 +++++++++++++++++++++++++++++++ 1 file changed, 31 insertions(+) create mode 100644 plugins/jobs/job/general.go (limited to 'plugins/jobs/job/general.go') diff --git a/plugins/jobs/job/general.go b/plugins/jobs/job/general.go new file mode 100644 index 00000000..2c7d04f0 --- /dev/null +++ b/plugins/jobs/job/general.go @@ -0,0 +1,31 @@ +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" + RRTimeout string = "rr_timeout" + RRDelay string = "rr_delay" + RRPriority string = "rr_priority" + RRMaxAttempts string = "rr_max_attempts" +) + +// 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"` +} -- cgit v1.2.3