Update broadcast tests, add redis flusing. Initial impl of the job

drivers state.

Signed-off-by: Valery Piashchynski <[email protected]>

1 files changed, 6 insertions, 1 deletions

diff --git a/common/jobs/interface.go b/common/jobs/interface.go
index c957df2b..4b5ff70e 100644
--- a/common/jobs/interface.go
+++ b/common/jobs/interface.go
@@ -5,11 +5,12 @@ import (
 
 	"github.com/spiral/roadrunner/v2/pkg/events"
 	priorityqueue "github.com/spiral/roadrunner/v2/pkg/priority_queue"
+	jobState "github.com/spiral/roadrunner/v2/pkg/state/job"
 	"github.com/spiral/roadrunner/v2/plugins/jobs/job"
 	"github.com/spiral/roadrunner/v2/plugins/jobs/pipeline"
 )
 
-// Consumer todo naming
+// Consumer represents a single jobs driver interface
 type Consumer interface {
 	Push(ctx context.Context, job *job.Job) error
 	Register(ctx context.Context, pipeline *pipeline.Pipeline) error
@@ -18,8 +19,12 @@ type Consumer interface {
 
 	Pause(ctx context.Context, pipeline string)
 	Resume(ctx context.Context, pipeline string)
+
+	// State provide information about driver state
+	State(ctx context.Context) (*jobState.State, error)
 }
 
+// Constructor constructs Consumer interface. Endure abstraction.
 type Constructor interface {
 	JobsConstruct(configKey string, e events.Handler, queue priorityqueue.Queue) (Consumer, error)
 	FromPipeline(pipe *pipeline.Pipeline, e events.Handler, queue priorityqueue.Queue) (Consumer, error)