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

drivers state.

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

1 files changed, 14 insertions, 5 deletions

diff --git a/plugins/informer/interface.go b/plugins/informer/interface.go
index bbc1a048..9277b85b 100644
--- a/plugins/informer/interface.go
+++ b/plugins/informer/interface.go
@@ -1,7 +1,10 @@
 package informer
 
 import (
-	"github.com/spiral/roadrunner/v2/pkg/process"
+	"context"
+
+	"github.com/spiral/roadrunner/v2/pkg/state/job"
+	"github.com/spiral/roadrunner/v2/pkg/state/process"
 )
 
 /*
@@ -9,17 +12,23 @@ Informer plugin should not receive any other plugin in the Init or via Collects
 Because Availabler implementation should present in every plugin
 */
 
+// Statistic interfaces ==============
+
 // Informer used to get workers from particular plugin or set of plugins
 type Informer interface {
 	Workers() []*process.State
 }
 
+// JobsStat interface provide statistic for the jobs plugin
+type JobsStat interface {
+	// JobsState returns slice with the attached drivers information
+	JobsState(ctx context.Context) ([]*job.State, error)
+}
+
+// Statistic interfaces end ============
+
 // Availabler interface should be implemented by every plugin which wish to report to the PHP worker that it available in the RR runtime
 type Availabler interface {
 	// Available method needed to collect all plugins which are available in the runtime.
 	Available()
 }
-
-type JobsStat interface {
-	Stat()
-}