summaryrefslogtreecommitdiff
path: root/plugins/jobs/structs/job.go
diff options
context:
space:
mode:
Diffstat (limited to 'plugins/jobs/structs/job.go')
-rw-r--r--plugins/jobs/structs/job.go51
1 files changed, 0 insertions, 51 deletions
diff --git a/plugins/jobs/structs/job.go b/plugins/jobs/structs/job.go
deleted file mode 100644
index 1ef4d2ca..00000000
--- a/plugins/jobs/structs/job.go
+++ /dev/null
@@ -1,51 +0,0 @@
-package structs
-
-import (
- json "github.com/json-iterator/go"
- "github.com/spiral/roadrunner/v2/utils"
-)
-
-// Job carries information about single job.
-type Job struct {
- // Job contains name of job broker (usually PHP class).
- Job string `json:"job"`
-
- // Payload is string data (usually JSON) passed to Job broker.
- Payload string `json:"payload"`
-
- // Options contains set of PipelineOptions specific to job execution. Can be empty.
- Options *Options `json:"options,omitempty"`
-}
-
-func (j *Job) ID() *string {
- return j.Options.ID
-}
-
-func (j *Job) Priority() *uint64 {
- return j.Options.Priority
-}
-
-// Body packs job payload into binary payload.
-func (j *Job) Body() []byte {
- return utils.AsBytes(j.Payload)
-}
-
-// Context packs job context (job, id) into binary payload.
-func (j *Job) Context() []byte {
- ctx, _ := json.Marshal(
- struct {
- ID *string `json:"id"`
- Job string `json:"job"`
- }{ID: j.Options.ID, Job: j.Job},
- )
-
- return ctx
-}
-
-func (j *Job) Ack() {
-
-}
-
-func (j *Job) Nack() {
-
-}