diff options
Diffstat (limited to 'common/jobs/interface.go')
| -rw-r--r-- | common/jobs/interface.go | 7 |
1 files changed, 3 insertions, 4 deletions
diff --git a/common/jobs/interface.go b/common/jobs/interface.go index 426d5606..e94e97b1 100644 --- a/common/jobs/interface.go +++ b/common/jobs/interface.go @@ -1,6 +1,7 @@ package jobs import ( + "github.com/spiral/roadrunner/v2/pkg/events" priorityqueue "github.com/spiral/roadrunner/v2/pkg/priority_queue" "github.com/spiral/roadrunner/v2/plugins/jobs/pipeline" "github.com/spiral/roadrunner/v2/plugins/jobs/structs" @@ -12,14 +13,12 @@ type Consumer interface { Register(pipeline *pipeline.Pipeline) error Run(pipeline *pipeline.Pipeline) error Stop() error - // List of the pipelines - List() []string Pause(pipeline string) Resume(pipeline string) } type Constructor interface { - JobsConstruct(configKey string, queue priorityqueue.Queue) (Consumer, error) - FromPipeline(pipe *pipeline.Pipeline, queue priorityqueue.Queue) (Consumer, error) + JobsConstruct(configKey string, e events.Handler, queue priorityqueue.Queue) (Consumer, error) + FromPipeline(pipe *pipeline.Pipeline, e events.Handler, queue priorityqueue.Queue) (Consumer, error) } |