Upgrade Client go and implement new methods (#25)

* Upgrade Client go and implement new methods
flyteorg · Jul 1, 2019 · 1b5ef79 · 1b5ef79
1 parent a06e54f
commit 1b5ef79
Show file tree

Hide file tree

Showing 3 changed files with 36 additions and 16 deletions.
diff --git a/Gopkg.lock b/Gopkg.lock
diff --git a/Gopkg.toml b/Gopkg.toml
@@ -57,11 +57,11 @@
 
 [[constraint]]
   name = "k8s.io/apimachinery"
-  version = "kubernetes-1.11.2"
+  version = "kubernetes-1.13.1"
 
 [[constraint]]
   name = "k8s.io/client-go"
-  version = "kubernetes-1.11.2"
+  version = "kubernetes-1.13.1"
 
 [[constraint]]
   name = "github.com/graymeta/stow"

diff --git a/promutils/workqueue.go b/promutils/workqueue.go
@@ -31,6 +31,26 @@ func init() {
 
 type prometheusMetricsProvider struct{}
 
+func (prometheusMetricsProvider) NewUnfinishedWorkSecondsMetric(name string) workqueue.SettableGaugeMetric {
+	unfinishedWork := prometheus.NewGauge(prometheus.GaugeOpts{
+		Subsystem: name,
+		Name:      "unfinished_work_s",
+		Help:      "How many seconds of work in progress in workqueue: " + name,
+	})
+	prometheus.MustRegister(unfinishedWork)
+	return unfinishedWork
+}
+
+func (prometheusMetricsProvider) NewLongestRunningProcessorMicrosecondsMetric(name string) workqueue.SettableGaugeMetric {
+	unfinishedWork := prometheus.NewGauge(prometheus.GaugeOpts{
+		Subsystem: name,
+		Name:      "longest_running_processor_us",
+		Help:      "How many microseconds longest running processor from workqueue" + name + " takes.",
+	})
+	prometheus.MustRegister(unfinishedWork)
+	return unfinishedWork
+}
+
 func (prometheusMetricsProvider) NewDepthMetric(name string) workqueue.GaugeMetric {
 	depth := prometheus.NewGauge(prometheus.GaugeOpts{
 		Subsystem: name,