dentaku/netatmo-exporter
1
0
Fork 0
mirror of https://github.com/steinhobelgruen/netatmo-exporter.git synced 2024-11-22 01:13:56 +00:00
Code Issues Releases Wiki Activity

Refresh data on startup

Browse source
This commit is contained in:
Robert Jacob 2020-06-27 18:20:51 +02:00
parent db8d1cbbf4
commit 6c3908e587
2 changed files with 9 additions and 3 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

8
internal/collector/collector.go
View file

@ -112,6 +112,7 @@ var (
nil) nil)
) )
// NetatmoCollector is a Prometheus collector for Netatmo sensor values.
type NetatmoCollector struct { type NetatmoCollector struct {
Log logrus.FieldLogger Log logrus.FieldLogger
RefreshInterval time.Duration RefreshInterval time.Duration
@ -135,7 +136,7 @@ func (c *NetatmoCollector) Describe(dChan chan<- *prometheus.Desc) {
func (c *NetatmoCollector) Collect(mChan chan<- prometheus.Metric) { func (c *NetatmoCollector) Collect(mChan chan<- prometheus.Metric) {
now := time.Now() now := time.Now()
if now.Sub(c.lastRefresh) >= c.RefreshInterval { if now.Sub(c.lastRefresh) >= c.RefreshInterval {
go c.refreshData(now) go c.RefreshData(now)
} }
upValue := 1.0 upValue := 1.0
@ -163,8 +164,9 @@ func (c *NetatmoCollector) Collect(mChan chan<- prometheus.Metric) {
} }
} }
func (c *NetatmoCollector) refreshData(now time.Time) { // RefreshData causes the collector to try to refresh the cached data.
c.Log.Debugf("Refresh interval elapsed: %s > %s", now.Sub(c.lastRefresh), c.RefreshInterval) func (c *NetatmoCollector) RefreshData(now time.Time) {
c.Log.Debugf("Refreshing data. Time since last refresh: %s", now.Sub(c.lastRefresh))
c.lastRefresh = now c.lastRefresh = now
defer func(start time.Time) { defer func(start time.Time) {

4
main.go
View file

@ -3,6 +3,7 @@ package main
import ( import (
"net/http" "net/http"
"os" "os"
"time"
netatmo "github.com/exzz/netatmo-api-go" netatmo "github.com/exzz/netatmo-api-go"
"github.com/prometheus/client_golang/prometheus" "github.com/prometheus/client_golang/prometheus"
@ -45,6 +46,9 @@ func main() {
} }
prometheus.MustRegister(metrics) prometheus.MustRegister(metrics)
// Trigger first refresh
metrics.RefreshData(time.Now())
http.Handle("/metrics", promhttp.HandlerFor(prometheus.DefaultGatherer, promhttp.HandlerOpts{})) http.Handle("/metrics", promhttp.HandlerFor(prometheus.DefaultGatherer, promhttp.HandlerOpts{}))
http.Handle("/version", versionHandler(log)) http.Handle("/version", versionHandler(log))
http.Handle("/", http.RedirectHandler("/metrics", http.StatusFound)) http.Handle("/", http.RedirectHandler("/metrics", http.StatusFound))