Add prometheus metrics for the jobs, update tests

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

1 files changed, 5 insertions, 0 deletions

diff --git a/plugins/jobs/drivers/ephemeral/consumer.go b/plugins/jobs/drivers/ephemeral/consumer.go
index 34778642..f0992cd6 100644
--- a/plugins/jobs/drivers/ephemeral/consumer.go
+++ b/plugins/jobs/drivers/ephemeral/consumer.go
@@ -113,6 +113,7 @@ func (j *JobConsumer) State(_ context.Context) (*jobState.State, error) {
 		Queue:    pipe.Name(),
 		Active:   atomic.LoadInt64(j.active),
 		Delayed:  atomic.LoadInt64(j.delayed),
+		Ready:    ready(atomic.LoadUint32(&j.listeners)),
 	}, nil
 }
 
@@ -267,3 +268,7 @@ func (j *JobConsumer) consume() {
 		}
 	}()
 }
+
+func ready(r uint32) bool {
+	return r > 0
+}