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, 0 deletions

diff --git a/pkg/state/job/state.go b/pkg/state/job/state.go
new file mode 100644
index 00000000..e5b142b5
--- /dev/null
+++ b/pkg/state/job/state.go
@@ -0,0 +1,6 @@
+package job
+
+type State struct {
+	Queue  string
+	Active int64
+}