feat: add option to disable metrics reporting

Author: christophwitzko

cmd/plugin-registry/main.go

@@ -56,25 +56,29 @@ func run(log *logrus.Logger) error {
 		log.Warn("request cache disabled")
 	}
 
-	ocTaskID := fmt.Sprintf("plugin-registry-%d", rand.Int())
-	log.Infof("setting up metrics exporter (opencensus_task=%s)...", ocTaskID)
-	labels := &stackdriver.Labels{}
-	labels.Set("version", version, "version of the plugin-registry")
-	labels.Set("stage", cfg.Stage, "stage of the plugin-registry")
-	labels.Set("opencensus_task", ocTaskID, "Opencensus task identifier")
-	exporter, err := metrics.NewExporter(stackdriver.Options{
-		ProjectID:    cfg.ProjectID,
-		MetricPrefix: "plugin-registry",
-		OnError: func(err error) {
-			log.Warnf("exporter error: %v", err)
-		},
-		DefaultMonitoringLabels: labels,
-	})
-	if err != nil {
-		return err
+	if !cfg.DisableMetrics {
+		ocTaskID := fmt.Sprintf("plugin-registry-%d", rand.Int())
+		log.Infof("setting up metrics exporter (opencensus_task=%s)...", ocTaskID)
+		labels := &stackdriver.Labels{}
+		labels.Set("version", cfg.Version, "version of the plugin-registry")
+		labels.Set("stage", cfg.Stage, "stage of the plugin-registry")
+		labels.Set("opencensus_task", ocTaskID, "Opencensus task identifier")
+		exporter, eErr := metrics.NewExporter(stackdriver.Options{
+			ProjectID:    cfg.ProjectID,
+			MetricPrefix: "plugin-registry",
+			OnError: func(err error) {
+				log.Warnf("exporter error: %v", err)
+			},
+			DefaultMonitoringLabels: labels,
+		})
+		if eErr != nil {
+			return eErr
+		}
+		defer exporter.Flush()
+		defer exporter.StopMetricsExporter()
+	} else {
+		log.Warn("metrics disabled")
 	}
-	defer exporter.Flush()
-	defer exporter.StopMetricsExporter()
 
 	log.Infof("connecting to database (stage=%s)...", cfg.Stage)
 	// set global collection prefix

internal/config/server.go

@@ -28,6 +28,7 @@ type ServerConfig struct {
 	PluginCacheHost             string `envconfig:"PLUGIN_CACHE_HOST" required:"true"`
 	DisableRequestCache         bool   `envconfig:"DISABLE_REQUEST_CACHE"`
 	Version                     string
+	DisableMetrics              bool `envconfig:"DISABLE_METRICS"`
 }
 
 func NewServerConfigFromEnv() (*ServerConfig, error) {