Merge pull request #1 from wbh1/master

Add metric for "newSessionRequestCount"

Author: wakeful

.gitignore

@@ -1 +1,2 @@
 .idea/
+selenium_grid_exporter

selenium_grid_exporter.go

@@ -28,14 +28,15 @@ var (
 type Exporter struct {
 	URI                       string
 	mutex                     sync.RWMutex
-	up, slotsTotal, slotsFree prometheus.Gauge
+	up, slotsTotal, slotsFree, newSessionRequestCount prometheus.Gauge
 }
 
 type hubResponse struct {
 	Success      bool       `json:"success"`
 	Debug        bool       `json:"debug"`
 	CleanUpCycle int        `json:"cleanUpCycle"`
 	Slots        slotCounts `json:"slotCounts"`
+	NewSession   float64    `json:"newSessionRequestCount"`
 }
 
 type slotCounts struct {
@@ -65,13 +66,20 @@ func NewExporter(uri string) *Exporter {
 			Name:      "slotsFree",
 			Help:      "number of free slots",
 		}),
+		newSessionRequestCount: prometheus.NewGauge(prometheus.GaugeOpts{
+			Namespace: nameSpace,
+			Subsystem: subSystem,
+			Name:      "sessions_backlog",
+			Help:      "number of sessions waiting for a slot",
+		}),
 	}
 }
 
 func (e *Exporter) Describe(ch chan<- *prometheus.Desc) {
 	e.up.Describe(ch)
 	e.slotsTotal.Describe(ch)
 	e.slotsFree.Describe(ch)
+	e.newSessionRequestCount.Describe(ch)
 }
 
 func (e *Exporter) Collect(ch chan<- prometheus.Metric) {
@@ -84,6 +92,7 @@ func (e *Exporter) Collect(ch chan<- prometheus.Metric) {
 	ch <- e.up
 	ch <- e.slotsTotal
 	ch <- e.slotsFree
+	ch <- e.newSessionRequestCount
 
 	return
 }
@@ -109,9 +118,10 @@ func (e *Exporter) scrape() {
 		log.Errorf("Can't decode Selenium Grid response: %v", err)
 		return
 	}
-
+	
 	e.slotsTotal.Set(hResponse.Slots.Total)
 	e.slotsFree.Set(hResponse.Slots.Free)
+	e.newSessionRequestCount.Set(hResponse.NewSession)
 
 }