diff options
Diffstat (limited to 'common')
| -rw-r--r-- | common/jobs/interface.go | 1 |
1 files changed, 1 insertions, 0 deletions
diff --git a/common/jobs/interface.go b/common/jobs/interface.go index deb90cde..3c29447d 100644 --- a/common/jobs/interface.go +++ b/common/jobs/interface.go @@ -10,6 +10,7 @@ import ( type Consumer interface { Push(job *structs.Job) error Register(pipeline *pipeline.Pipeline) error + Consume(pipeline *pipeline.Pipeline) error List() []*pipeline.Pipeline Pause(pipeline string) |