WIP

Author: bjee19

.goreleaser.yml

@@ -15,7 +15,7 @@ builds:
     asmflags:
       - all=-trimpath={{.Env.GOPATH}}
     ldflags:
-      - -s -w -X main.version={{.Version}} -X main.commit={{.Commit}} -X main.date={{.Date}} -X main.telemetryReportPeriod=24h
+      - -s -w -X main.version={{.Version}} -X main.commit={{.Commit}} -X main.date={{.Date}} -X main.telemetryReportPeriod=15s
     main: ./cmd/gateway/
     binary: gateway
 

Makefile

@@ -8,7 +8,7 @@ NGINX_CONF_DIR = internal/mode/static/nginx/conf
 NJS_DIR = internal/mode/static/nginx/modules/src
 NGINX_DOCKER_BUILD_PLUS_ARGS = --secret id=nginx-repo.crt,src=nginx-repo.crt --secret id=nginx-repo.key,src=nginx-repo.key
 BUILD_AGENT=local
-TELEMETRY_REPORT_PERIOD = 24h # also configured in goreleaser.yml
+TELEMETRY_REPORT_PERIOD = 15s # also configured in goreleaser.yml
 GW_API_VERSION = 1.0.0
 INSTALL_WEBHOOK = false
 

internal/mode/static/telemetry/collector_test.go

@@ -6,6 +6,7 @@ import (
 	"fmt"
 	"reflect"
 	"runtime"
+	"strconv"
 
 	. "github.com/onsi/ginkgo/v2"
 	. "github.com/onsi/gomega"
@@ -273,6 +274,26 @@ var _ = Describe("Collector", Ordered, func() {
 					},
 				}
 
+				var boolFlag bool
+				flagset.BoolVar(
+					&boolFlag,
+					"boolFlag",
+					true,
+					"boolean test flag",
+				)
+				intFlag := flagValue[int]{value: 8080}
+				flagset.Var(
+					&intFlag,
+					"intFlag",
+					"int test flag",
+				)
+				stringFlag := flagValue[string]{value: "string-flag"}
+				flagset.Var(
+					&stringFlag,
+					"stringFlag",
+					"string test flag",
+				)
+
 				fakeGraphGetter.GetLatestGraphReturns(graph)
 				fakeConfigurationGetter.GetLatestConfigurationReturns(config)
 
@@ -285,6 +306,10 @@ var _ = Describe("Collector", Ordered, func() {
 					Services:       3,
 					Endpoints:      4,
 				}
+				expData.DeploymentFlagOptions = telemetry.DeploymentFlagOptions{
+					FlagKeys:   []string{"boolFlag", "intFlag", "stringFlag"},
+					FlagValues: []string{"true", "default", "default"},
+				}
 
 				data, err := dataCollector.Collect(ctx)
 
@@ -673,3 +698,32 @@ var _ = Describe("Collector", Ordered, func() {
 		})
 	})
 })
+
+// flagValue holds a generic value and implements the pflag.Value interface.
+type flagValue[T comparable] struct {
+	value T
+}
+
+func (v *flagValue[T]) String() string {
+	switch val := any(v.value).(type) {
+	case int:
+		return strconv.Itoa(val)
+	case string:
+		return val
+	}
+	return ""
+}
+
+func (v *flagValue[T]) Set(_ string) error {
+	return nil
+}
+
+func (v *flagValue[T]) Type() string {
+	switch any(v.value).(type) {
+	case int:
+		return "int"
+	case string:
+		return "string"
+	}
+	return ""
+}