Log stuff

Author: rajsinghtech

kustomization/deployment.yaml

@@ -14,11 +14,14 @@ spec:
     spec:
       containers:
         - name: fleet-telemetry-consumer
-          image: quay.io/rajsinghcpre/fleet-telemetry-consumer:v0.0.1
+          image: quay.io/rajsinghcpre/fleet-telemetry-consumer:v0.0.2
           command: ["/fleet-telemetry-consumer", "-config", "/etc/fleet-telemetry-consumer/config.json"]
           volumeMounts:
             - name: config-volume
               mountPath: /etc/fleet-telemetry-consumer
+          ports:
+            - containerPort: 2112
+              name: metrics
       volumes:
         - name: config-volume
           configMap:

kustomization/kustomization.yaml

@@ -3,7 +3,8 @@ kind: Kustomization
 
 resources:
   - deployment.yaml
-
+  - service.yaml
+  - serviceMonitor.yaml
 configMapGenerator:
   - name: fleet-telemetry-consumer-config
     files:

kustomization/service.yaml

@@ -0,0 +1,14 @@
+apiVersion: v1
+kind: Service
+metadata:
+  name: fleet-telemetry-consumer
+  labels:
+    app: fleet-telemetry-consumer
+spec:
+  selector:
+    app: fleet-telemetry-consumer
+  ports:
+    - name: metrics
+      port: 2112
+      targetPort: 2112
+      protocol: TCP

kustomization/serviceMonitor.yaml

@@ -0,0 +1,16 @@
+apiVersion: monitoring.coreos.com/v1
+kind: ServiceMonitor
+metadata:
+  name: fleet-telemetry-consumer
+  labels:
+    app: fleet-telemetry-consumer
+spec:
+  selector:
+    matchLabels:
+      app: fleet-telemetry-consumer
+  namespaceSelector:
+    any: true
+  endpoints:
+    - port: metrics
+      path: /metrics
+      interval: 15s

main.go

@@ -97,6 +97,14 @@ func main() {
             continue
         }
 
+        // Output the message to console
+        vehicleDataJSON, err := json.MarshalIndent(vehicleData, "", "  ")
+        if err != nil {
+            log.Printf("Failed to marshal vehicle data to JSON: %v\n", err)
+            continue
+        }
+        fmt.Printf("Received message: %s\n", vehicleDataJSON)
+
         // Process each Datum in the Payload
         for _, datum := range vehicleData.Data {
             fieldName := datum.Key.String() // Get the field name from the enum
@@ -167,8 +175,8 @@ func main() {
                 // Handle LocationValue separately
                 lat := v.LocationValue.Latitude
                 lon := v.LocationValue.Longitude
-                vehicleDataGauge.WithLabelValues(fieldName+"_latitude", vehicleData.Vin).Set(lat)
-                vehicleDataGauge.WithLabelValues(fieldName+"_longitude", vehicleData.Vin).Set(lon)
+                vehicleDataGauge.WithLabelValues("Latitude", vehicleData.Vin).Set(lat)
+                vehicleDataGauge.WithLabelValues("Longitude", vehicleData.Vin).Set(lon)
                 continue // Skip the rest since we've handled this case
             default:
                 // Skip non-numeric or unsupported types