From 60c229c8506df465586434309af5acd1f84e2406 Mon Sep 17 00:00:00 2001 From: Valery Piashchynski Date: Wed, 7 Jul 2021 18:33:04 +0300 Subject: 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 --- common/jobs/interface.go | 12 ++++-------- 1 file changed, 4 insertions(+), 8 deletions(-) (limited to 'common') 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 { -- cgit v1.2.3