Add headers support to the jobs protocol

Signed-off-by: Valery Piashchynski <[email protected]>

1 files changed, 7 insertions, 36 deletions

diff --git a/plugins/jobs/job/general.go b/plugins/jobs/job/general.go
index d2a27373..0a75f2e6 100644
--- a/plugins/jobs/job/general.go
+++ b/plugins/jobs/job/general.go
@@ -2,14 +2,13 @@ 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"
+	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"
 )
 
 // Job carries information about single job.
@@ -29,31 +28,3 @@ type Job struct {
 	// Options contains set of PipelineOptions specific to job execution. Can be empty.
 	Options *Options `json:"options,omitempty"`
 }
-
-func (j Job) ID() string {
-	panic("implement me")
-}
-
-func (j Job) Priority() int64 {
-	panic("implement me")
-}
-
-func (j Job) Body() []byte {
-	panic("implement me")
-}
-
-func (j Job) Context() ([]byte, error) {
-	panic("implement me")
-}
-
-func (j Job) Ack() error {
-	panic("implement me")
-}
-
-func (j Job) Nack() error {
-	panic("implement me")
-}
-
-func (j Job) Requeue(delay uint32) error {
-	panic("implement me")
-}