metrics agent infrastructure

controller/controller.go

@@ -11,6 +11,7 @@ import (
 )
 
 var str *store.Store
+var mtr *metricsAgent
 
 const version = "v0.2.0"
 
@@ -43,6 +44,9 @@ func Run(cfg *Config) error {
 		return errors.Wrap(err, "error opening store")
 	}
 
+	mtr = newMetricsAgent(cfg.MetricsConfig)
+	go mtr.run()
+
 	server := rest_server_zrok.NewServer(api)
 	defer func() { _ = server.Shutdown() }()
 	server.Host = cfg.Endpoint.Host
@@ -51,5 +55,6 @@ func Run(cfg *Config) error {
 	if err := server.Serve(); err != nil {
 		return errors.Wrap(err, "api server error")
 	}
+
 	return nil
 }

controller/metrics.go

@@ -1,5 +1,10 @@
 package controller
 
+import (
+	"github.com/sirupsen/logrus"
+	"time"
+)
+
 type MetricsConfig struct {
 	Influx *InfluxConfig
 }
@@ -10,3 +15,20 @@ type InfluxConfig struct {
 	Org    string
 	Token  string
 }
+
+type metricsAgent struct {
+	cfg *MetricsConfig
+}
+
+func newMetricsAgent(cfg *MetricsConfig) *metricsAgent {
+	return &metricsAgent{cfg: cfg}
+}
+
+func (mtr *metricsAgent) run() {
+	logrus.Info("starting")
+	defer logrus.Info("exiting")
+
+	for {
+		time.Sleep(24 * time.Hour)
+	}
+}