Feat/telemetry platform

internal/telemetry/cluster.go

@@ -2,6 +2,8 @@ package telemetry
 
 import (
 	"context"
+	"errors"
+	"strings"
 
 	metaV1 "k8s.io/apimachinery/pkg/apis/meta/v1"
 )
@@ -35,3 +37,36 @@ func (c *Collector) K8sVersion() (string, error) {
 	}
 	return sv.String(), nil
 }
+
+// Platform returns a string representing platform name.
+func (c *Collector) Platform(ctx context.Context) (string, error) {
+	nodes, err := c.Config.K8sClientReader.CoreV1().Nodes().List(ctx, metaV1.ListOptions{})
+	if err != nil {
+		return "", err
+	}
+	if len(nodes.Items) == 0 {
+		return "", errors.New("no nodes in the cluster, cannot determine platform name")
+	}
+	return lookupPlatform(nodes.Items[0].Spec.ProviderID), nil
+}
+
+// lookupPlatform takes a string representing a K8s PlatformID
+// retrieved from a cluster node and returns a string
+// representing the platform name.
+func lookupPlatform(providerID string) string {
+	provider := strings.TrimSpace(providerID)
+	if provider == "" {
+		return "other"
+	}
+
+	provider = strings.ToLower(providerID)
+
+	p := strings.Split(provider, ":")
+	if len(p) == 0 {
+		return "other"
+	}
+	if p[0] == "" {
+		return "other"
+	}
+	return p[0]
+}