Merge pull request #102 from streamdal/blinktag/fix_uptime_telemetry

Fix uptime tags

README.md

@@ -9,11 +9,11 @@ The server component in the Streamdal ecosystem.
 
 The server exposes 3 APIs:
 
-1. gRPC API on port `9090`
+1. gRPC API on port `8082`
    1. Used by SDKs
-2. gRPC-Web API on port `9091`
+2. gRPC-Web API on port `8083`
    1. Used by the UI component
-3. REST API on port `8080`
+3. REST API on port `8081`
    1. Exposes metrics, prometheus and health-check endpoints
 
 ## Development

deps/deps.go

@@ -7,17 +7,12 @@ import (
 	"strings"
 	"time"
 
-	"github.com/sirupsen/logrus"
-
-	"github.com/streamdal/server/util"
-
 	"github.com/InVisionApp/go-health/v2"
 	gllogrus "github.com/InVisionApp/go-logger/shims/logrus"
 	"github.com/cactus/go-statsd-client/v5/statsd"
 	"github.com/pkg/errors"
 	"github.com/redis/go-redis/v9"
-
-	"github.com/streamdal/server/types"
+	"github.com/sirupsen/logrus"
 
 	"github.com/streamdal/server/backends/cache"
 	"github.com/streamdal/server/config"
@@ -30,6 +25,8 @@ import (
 	"github.com/streamdal/server/services/pubsub"
 	"github.com/streamdal/server/services/store"
 	"github.com/streamdal/server/services/telemetry"
+	"github.com/streamdal/server/types"
+	"github.com/streamdal/server/util"
 	"github.com/streamdal/server/wasm"
 )
 
@@ -199,7 +196,6 @@ func (d *Dependencies) setupServices(cfg *config.Config) error {
 			return errors.Wrap(err, "unable to create new statsd client")
 		}
 		d.Telemetry = t
-		fmt.Printf("\n\nConnected to telemetry: %s\n\n", cfg.TelemetryAddress)
 	} else {
 		d.Telemetry = &telemetry.DummyTelemetry{}
 	}
@@ -329,9 +325,8 @@ func (d *Dependencies) RunUptimeTelemetry() {
 	defer ticker.Stop()
 
 	tags := []statsd.Tag{
-		//{"install_id", d.Config.InstallID},
-		//{"node_id", d.Config.NodeID},
-		{"sample_tag", "mark"},
+		{"install_id", d.Config.InstallID},
+		{"node_id", d.Config.NodeID},
 	}
 
 	// Send started telemetry