feat(backend/assets): added metric (total_assets)

backend/cmd/assets/main.go

@@ -1,7 +1,9 @@
 package main
 
 import (
+	"context"
 	"log"
+	"openreplay/backend/pkg/monitoring"
 	"os"
 	"os/signal"
 	"syscall"
@@ -15,7 +17,13 @@ import (
 	"openreplay/backend/pkg/queue/types"
 )
 
+/*
+Assets
+*/
+
 func main() {
+	metrics := monitoring.New("assets")
+
 	log.SetFlags(log.LstdFlags | log.LUTC | log.Llongfile)
 
 	cfg := config.New()
@@ -27,6 +35,11 @@ func main() {
 		cfg.AssetsSizeLimit,
 	)
 
+	totalAssets, err := metrics.RegisterCounter("assets_total")
+	if err != nil {
+		log.Printf("can't create assets_total metric: %s", err)
+	}
+
 	consumer := queue.NewMessageConsumer(
 		cfg.GroupCache,
 		[]string{cfg.TopicCache},
@@ -34,6 +47,7 @@ func main() {
 			switch msg := message.(type) {
 			case *messages.AssetCache:
 				cacher.CacheURL(sessionID, msg.URL)
+				totalAssets.Add(context.Background(), 1)
 			case *messages.ErrorEvent:
 				if msg.Source != "js_exception" {
 					return

backend/cmd/db/main.go

@@ -21,6 +21,10 @@ import (
 	"openreplay/backend/pkg/queue/types"
 )
 
+/*
+DB
+*/
+
 func main() {
 	log.SetFlags(log.LstdFlags | log.LUTC | log.Llongfile)
 

backend/cmd/ender/main.go

@@ -18,6 +18,10 @@ import (
 	"openreplay/backend/pkg/queue/types"
 )
 
+/*
+Ender
+*/
+
 func main() {
 	metrics := monitoring.New("ender")
 

backend/cmd/heuristics/main.go

@@ -19,6 +19,10 @@ import (
 	"time"
 )
 
+/*
+Heuristics
+*/
+
 func main() {
 	log.SetFlags(log.LstdFlags | log.LUTC | log.Llongfile)
 

backend/cmd/http/main.go

@@ -17,6 +17,10 @@ import (
 	"openreplay/backend/pkg/queue"
 )
 
+/*
+HTTP
+*/
+
 func main() {
 	metrics := monitoring.New("http")
 

backend/cmd/integrations/main.go

@@ -17,6 +17,10 @@ import (
 	"openreplay/backend/pkg/token"
 )
 
+/*
+Integrations
+*/
+
 func main() {
 	log.SetFlags(log.LstdFlags | log.LUTC | log.Llongfile)
 

backend/cmd/sink/main.go

@@ -21,6 +21,10 @@ import (
 	"openreplay/backend/pkg/url/assets"
 )
 
+/*
+Sink
+*/
+
 func main() {
 	metrics := monitoring.New("sink")
 
@@ -74,7 +78,7 @@ func main() {
 			// If message timestamp is empty, use at least ts of session start
 			ts := message.Meta().Timestamp
 			if ts == 0 {
-				log.Printf("zero ts; sessID: %d, msg: %+v", sessionID, message)
+				//log.Printf("zero ts; sessID: %d, msg: %+v", sessionID, message)
 			} else {
 				// Log ts of last processed message
 				counter.Update(sessionID, time.UnixMilli(ts))

backend/cmd/storage/main.go

@@ -17,6 +17,10 @@ import (
 	s3storage "openreplay/backend/pkg/storage"
 )
 
+/*
+Storage
+*/
+
 func main() {
 	metrics := monitoring.New("storage")