diff options
Diffstat (limited to 'plugins/jobs/interface.go')
| -rw-r--r-- | plugins/jobs/interface.go | 13 |
1 files changed, 9 insertions, 4 deletions
diff --git a/plugins/jobs/interface.go b/plugins/jobs/interface.go index d013d320..b4862038 100644 --- a/plugins/jobs/interface.go +++ b/plugins/jobs/interface.go @@ -1,9 +1,14 @@ package jobs -// todo naming +import ( + "github.com/spiral/roadrunner/v2/plugins/jobs/pipeline" + "github.com/spiral/roadrunner/v2/plugins/jobs/structs" +) + +// Consumer todo naming type Consumer interface { - Push() + Push(*pipeline.Pipeline, *structs.Job) (string, error) Stat() - Consume(*Pipeline) - Register(*Pipeline) + Consume(*pipeline.Pipeline) + Register(*pipeline.Pipeline) } |