diff options
Diffstat (limited to 'common')
| -rw-r--r-- | common/jobs/interface.go | 12 |
1 files changed, 4 insertions, 8 deletions
diff --git a/common/jobs/interface.go b/common/jobs/interface.go index 786eca0e..deb90cde 100644 --- a/common/jobs/interface.go +++ b/common/jobs/interface.go @@ -8,16 +8,12 @@ import ( // Consumer todo naming type Consumer interface { - Push(job *structs.Job) (*string, error) - Consume(job *pipeline.Pipeline) + Push(job *structs.Job) error + Register(pipeline *pipeline.Pipeline) error + List() []*pipeline.Pipeline - Stop(pipeline string) - StopAll() + Pause(pipeline string) Resume(pipeline string) - ResumeAll() - - Register(pipe string) error - Stat() } type Constructor interface { |