diff options
| author | Valery Piashchynski <[email protected]> | 2021-07-07 18:33:04 +0300 |
|---|---|---|
| committer | Valery Piashchynski <[email protected]> | 2021-07-07 18:33:04 +0300 |
| commit | 60c229c8506df465586434309af5acd1f84e2406 (patch) | |
| tree | 18fdf380b7e032415d656e84bcc3c7a057f194a8 /common | |
| parent | 127186a72d4b8d30f6ada72ade661d8713490728 (diff) | |
Updated ephemeral plugin, PQ and protobuf...
Implement core of the root jobs plugin with a proper drivers/pipelines
handling mechanism.
Add delayed jobs for the ephemeral plugin.
Remove ResumeAll, Resume, StopAll, Stop. Replaced with Pause/Resume with
a slice of the pipelines.
Other small improvements.
Signed-off-by: Valery Piashchynski <[email protected]>
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 { |