CLOUDP-299552 - Detect rancher and vmware (#4131)

# Summary

- adds detection for rancher
- refactors detection to also rely on server version if possible

## Proof of Work

- unit tests
- following the official code to detect rancher:
https://github.com/rancher/kubernetes-provider-detector/tree/master/providers
- following the hidden docs of vmware for detection:
https://vstellar.com/2021/09/upgrade-tanzu-kubernetes-grid-from-v1-3-x-to-1-4-x/#:~:text=NAMESPACE%20STATUS%20CONTROLPLANE%20WORKERS%20KUBERNETES,1%20management%20prod
+
https://manuals.plus/m/b40c126bfb839c9d3b0b924eca541d644c6e32165341146f5a4cd33e6db82330#:~:text=VMware%20Tanzu%20distributes%20Kubernetes%20software,You

```

12345 | [root@tkg-bootstrapper ~]# kubectl version Client Version: version.Info{Major:"1", Minor:"21", GitVersion:"v1.21.2+vmware.1", GitCommit:"54e7e68e30dd3f9f7bb4f814c9d112f54f0fb273", GitTreeState:"clean", BuildDate:"2021-06-28T22:17:36Z", GoVersion:"go1.16.5", Compiler:"gc", Platform:"linux/amd64"} Server Version: version.Info{Major:"1", Minor:"20", GitVersion:"v1.20.5+vmware.2", GitCommit:"13a5d1c1f3860de79bb2aa1448af2025c974d111", GitTreeState:"clean", BuildDate:"2021-05-16T00:39:21Z", GoVersion:"go1.15.8", Compiler:"gc", Platform:"linux/amd64"}
-- | --
```
^--- according to the posts

## Checklist
- [x] Have you linked a jira ticket and/or is the ticket in the title?
- [ ] Have you checked whether your jira ticket required DOCSP changes?
- [ ] Have you checked for release_note changes?

Author: nammn

pkg/telemetry/cluster.go

@@ -2,6 +2,7 @@ package telemetry
 
 import (
 	"context"
+	"strings"
 	"time"
 
 	"k8s.io/apimachinery/pkg/version"
@@ -16,11 +17,26 @@ import (
 const (
 	unknown   = "Unknown"
 	eks       = "AWS (EKS)"
+	vmware    = "VmWare"
 	gke       = "Google (GKE)"
 	aks       = "Azure (AKS)"
 	openshift = "Openshift"
+	rke       = "RKE"
+	rke2      = "RKE2"
 )
 
+var kubernetesFlavourLabelsMapping = map[string]string{
+	"eks.amazonaws.com/nodegroup":    eks,
+	"cloud.google.com/gke-nodepool":  gke,
+	"kubernetes.azure.com/agentpool": aks,
+	"node.openshift.io/os_id":        openshift,
+}
+
+var kubernetesFlavourAnnotationsMapping = map[string]string{
+	"rke.cattle.io/external-ip": rke,
+	"rke.cattle.io/internal-ip": rke,
+}
+
 // detectClusterInfo detects the Kubernetes version and cluster flavor
 func detectClusterInfos(ctx context.Context, memberClusterMap map[string]ConfigClient) []KubernetesClusterUsageSnapshotProperties {
 	var clusterProperties []KubernetesClusterUsageSnapshotProperties
@@ -53,7 +69,7 @@ func getKubernetesClusterProperty(ctx context.Context, discoveryClient discovery
 		}
 	}
 
-	kubernetesFlavour := detectKubernetesFlavour(ctx, uncachedClient)
+	kubernetesFlavour := detectKubernetesFlavour(ctx, uncachedClient, kubernetesAPIVersion)
 
 	property := KubernetesClusterUsageSnapshotProperties{
 		KubernetesClusterID:  kubeClusterUUID,
@@ -74,38 +90,46 @@ func getServerVersion(discoveryClient discovery.DiscoveryInterface) *version.Inf
 }
 
 // detectKubernetesFlavour detects the cloud provider based on node labels.
-func detectKubernetesFlavour(ctx context.Context, uncachedClient kubeclient.Reader) string {
-	nodes := &corev1.NodeList{}
-	// Limit is propagated to the apiserver which propagates to etcd as it is. Thus, there is not a lot of
-	// work required on the APIServer and ETCD to retrieve that node even in large clusters
-	listOptions := &kubeclient.ListOptions{
-		Limit: 1,
+func detectKubernetesFlavour(ctx context.Context, uncachedClient kubeclient.Reader, kubeGitApiVersion string) string {
+	// Check Kubernetes API version for known cloud providers
+	switch {
+	case strings.Contains(kubeGitApiVersion, "+rke2"):
+		return rke2
+	case strings.Contains(kubeGitApiVersion, "-gke"):
+		return gke
+	case strings.Contains(kubeGitApiVersion, "-eks"):
+		return eks
+	case strings.Contains(kubeGitApiVersion, "+vmware"):
+		return vmware
 	}
 
-	if err := uncachedClient.List(ctx, nodes, listOptions); err != nil {
+	// Limit is propagated to the apiserver which propagates to etcd as it is. Thus, there is not a lot of
+	// work required on the APIServer and ETCD to retrieve that node even in large clusters
+	nodes := &corev1.NodeList{}
+	if err := uncachedClient.List(ctx, nodes, &kubeclient.ListOptions{Limit: 1}); err != nil {
 		Logger.Debugf("Failed to fetch node to detect the cloud provider: %s", err)
 		return unknown
 	}
-
 	if len(nodes.Items) == 0 {
 		Logger.Debugf("No nodes found, returning Unknown")
 		return unknown
 	}
 
-	labels := nodes.Items[0].Labels
+	node := nodes.Items[0]
+	labels, annotations := node.Labels, node.Annotations
 
-	if _, ok := labels["eks.amazonaws.com/nodegroup"]; ok {
-		return eks
-	}
-	if _, ok := labels["cloud.google.com/gke-nodepool"]; ok {
-		return gke
-	}
-	if _, ok := labels["kubernetes.azure.com/agentpool"]; ok {
-		return aks
+	for key, provider := range kubernetesFlavourLabelsMapping {
+		if _, exists := labels[key]; exists {
+			return provider
+		}
 	}
-	if _, ok := labels["node.openshift.io/os_id"]; ok {
-		return openshift
+
+	for key, provider := range kubernetesFlavourAnnotationsMapping {
+		if _, exists := annotations[key]; exists {
+			return provider
+		}
 	}
+
 	return unknown
 }
 

pkg/telemetry/cluster_test.go

@@ -173,6 +173,7 @@ func TestDetectKubernetesFlavour(t *testing.T) {
 	tests := []struct {
 		name            string
 		labels          map[string]string
+		gitVersion      string
 		expectedFlavour string
 	}{
 		{
@@ -185,6 +186,12 @@ func TestDetectKubernetesFlavour(t *testing.T) {
 			labels:          map[string]string{"something": "default"},
 			expectedFlavour: unknown,
 		},
+		{
+			name:            "based on gitversion",
+			labels:          map[string]string{"something": "default"},
+			gitVersion:      "v123-gke",
+			expectedFlavour: gke,
+		},
 	}
 
 	for _, tt := range tests {
@@ -198,7 +205,7 @@ func TestDetectKubernetesFlavour(t *testing.T) {
 			}
 
 			fakeClient := fake.NewClientBuilder().WithObjects(node).Build()
-			cloudProvider := detectKubernetesFlavour(ctx, fakeClient)
+			cloudProvider := detectKubernetesFlavour(ctx, fakeClient, tt.gitVersion)
 
 			assert.Equal(t, tt.expectedFlavour, cloudProvider)
 		})

pkg/telemetry/types.go

@@ -61,7 +61,7 @@ var AllEventTypes = []EventType{
 	Clusters,
 }
 
-var EventTypeMappingToEnvVar map[EventType]string = map[EventType]string{
+var EventTypeMappingToEnvVar = map[EventType]string{
 	Deployments: "MDB_OPERATOR_TELEMETRY_COLLECTION_DEPLOYMENTS",
 	Clusters:    "MDB_OPERATOR_TELEMETRY_COLLECTION_CLUSTERS",
 	Operators:   "MDB_OPERATOR_TELEMETRY_COLLECTION_OPERATORS",