Add Harvester provider

Author: futuretea

detector.go

@@ -20,6 +20,7 @@ func init() {
 	allProviders[providers.Docker] = providers.IsDocker
 	allProviders[providers.EKS] = providers.IsEKS
 	allProviders[providers.GKE] = providers.IsGKE
+	allProviders[providers.Harvester] = providers.IsHarvester
 	allProviders[providers.K3s] = providers.IsK3s
 	allProviders[providers.Minikube] = providers.IsMinikube
 	allProviders[providers.RKE] = providers.IsRKE

providers/harvester.go

@@ -0,0 +1,26 @@
+package providers
+
+import (
+	"context"
+
+	metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
+	"k8s.io/client-go/kubernetes"
+)
+
+const Harvester = "harvester"
+
+func IsHarvester(ctx context.Context, k8sClient kubernetes.Interface) (bool, error) {
+	// Look for nodes that have an Harvester specific label
+	listOpts := metav1.ListOptions{
+		LabelSelector: "harvesterhci.io/managed",
+		// Only need one
+		Limit: 1,
+	}
+
+	nodes, err := k8sClient.CoreV1().Nodes().List(ctx, listOpts)
+	if err != nil {
+		return false, err
+	}
+
+	return len(nodes.Items) > 0, nil
+}

providers/k3s.go

@@ -10,6 +10,10 @@ import (
 const K3s = "k3s"
 
 func IsK3s(ctx context.Context, k8sClient kubernetes.Interface) (bool, error) {
+	if isHarvester, err := IsHarvester(ctx, k8sClient); err != nil || isHarvester {
+		return false, err
+	}
+
 	v, err := k8sClient.Discovery().ServerVersion()
 	if err != nil {
 		return false, err

providers/rke2.go

@@ -10,6 +10,10 @@ import (
 const RKE2 = "rke2"
 
 func IsRKE2(ctx context.Context, k8sClient kubernetes.Interface) (bool, error) {
+	if isHarvester, err := IsHarvester(ctx, k8sClient); err != nil || isHarvester {
+		return false, err
+	}
+
 	v, err := k8sClient.Discovery().ServerVersion()
 	if err != nil {
 		return false, err