Create local kind cluster install

common/config/providers.go

@@ -6,6 +6,7 @@ import (
 
 	"github.com/pulumi/pulumi-awsx/sdk/v2/go/awsx"
 	"github.com/pulumi/pulumi-command/sdk/go/command"
+	"github.com/pulumi/pulumi-docker/sdk/v4/go/docker"
 	"github.com/pulumi/pulumi-eks/sdk/v2/go/eks"
 	"github.com/pulumi/pulumi-random/sdk/v4/go/random"
 	"github.com/pulumi/pulumi-tls/sdk/v4/go/tls"
@@ -22,6 +23,7 @@ const (
 	ProviderAWSX    ProviderID = "awsx"
 	ProviderEKS     ProviderID = "eks"
 	ProviderAzure   ProviderID = "azure"
+	ProviderDocker  ProviderID = "docker"
 )
 
 func dummyProvidersFactory() map[ProviderID]func(ctx *pulumi.Context, name string) (pulumi.ProviderResource, error) {
@@ -46,6 +48,10 @@ func dummyProvidersFactory() map[ProviderID]func(ctx *pulumi.Context, name strin
 			provider, err := eks.NewProvider(ctx, name, nil)
 			return provider, err
 		},
+		ProviderDocker: func(ctx *pulumi.Context, name string) (pulumi.ProviderResource, error) {
+			provider, err := docker.NewProvider(ctx, name, nil)
+			return provider, err
+		},
 	}
 }
 

components/datadog/agent/kubernetes_helm.go

@@ -393,7 +393,7 @@ func (values HelmValues) configureFakeintake(e config.CommonEnvironment, fakeint
 		},
 		pulumi.Map{
 			"name":  pulumi.String("DD_LOGS_CONFIG_ADDITIONAL_ENDPOINTS"),
-			"value": pulumi.Sprintf(`[{"host": "%s"}]`, fakeintake.Host),
+			"value": pulumi.Sprintf(`[{"host": "%s", "port": %v, "use_ssl": "%t"}]`, fakeintake.Host, fakeintake.Port, fakeintake.Scheme == "https"),
 		},
 		pulumi.Map{
 			"name":  pulumi.String("DD_LOGS_CONFIG_USE_HTTP"),

components/datadog/fakeintake/docker.go

@@ -0,0 +1,52 @@
+package fakeintake
+
+import (
+	"log"
+	"net"
+
+	"github.com/DataDog/test-infra-definitions/common/config"
+	"github.com/DataDog/test-infra-definitions/components"
+	"github.com/pulumi/pulumi-docker/sdk/v4/go/docker"
+	"github.com/pulumi/pulumi/sdk/v3/go/pulumi"
+)
+
+const hostPort = 30080
+
+func NewLocalDockerFakeintake(e config.CommonEnvironment, resourceName string) (*Fakeintake, error) {
+	return components.NewComponent(e, resourceName, func(comp *Fakeintake) error {
+
+		_, err := docker.NewContainer(e.Ctx, e.CommonNamer.ResourceName("local-docker-container"), &docker.ContainerArgs{
+			Image: pulumi.String("public.ecr.aws/datadog/fakeintake:latest"),
+			Ports: docker.ContainerPortArray{
+				&docker.ContainerPortArgs{
+					Internal: pulumi.Int(80),
+					External: pulumi.Int(hostPort),
+				},
+			},
+		}, e.WithProviders(config.ProviderDocker))
+		if err != nil {
+			return err
+		}
+
+		localIP := getLocalIP()
+
+		comp.Host = pulumi.Sprintf(localIP.String())
+		comp.Port = hostPort
+		comp.Scheme = "http"
+		comp.URL = pulumi.Sprintf("%s://%s:%d", comp.Scheme, comp.Host, comp.Port)
+
+		return nil
+	})
+}
+
+func getLocalIP() net.IP {
+	conn, err := net.Dial("udp", "255.255.255.255:80") // initiate a connection to get the local address, the url does not need to exist
+	if err != nil {
+		log.Fatal(err)
+	}
+	defer conn.Close()
+
+	localAddr := conn.LocalAddr().(*net.UDPAddr)
+
+	return localAddr.IP
+}

components/kubernetes/kind-cluster.yaml

@@ -9,3 +9,4 @@ containerdConfigPatches:
 networking:
   apiServerAddress: "0.0.0.0"
   apiServerPort: 8443
+

components/kubernetes/kind.go

@@ -3,6 +3,7 @@ package kubernetes
 import (
 	_ "embed"
 	"fmt"
+
 	"regexp"
 	"strings"
 
@@ -108,3 +109,60 @@ func NewKindCluster(env config.CommonEnvironment, vm *remote.Host, resourceName,
 		return nil
 	}, opts...)
 }
+
+func NewLocalKindCluster(env config.CommonEnvironment, resourceName, kindClusterName string, kubeVersion string, opts ...pulumi.ResourceOption) (*Cluster, error) {
+	return components.NewComponent(env, resourceName, func(clusterComp *Cluster) error {
+		opts = utils.MergeOptions[pulumi.ResourceOption](opts, pulumi.Parent(clusterComp))
+		commonEnvironment := env
+
+		kindVersionConfig, err := getKindVersionConfig(kubeVersion)
+		if err != nil {
+			return err
+		}
+
+		runner := command.NewLocalRunner(env, command.LocalRunnerArgs{
+			// User:      user.Username,
+			OSCommand: command.NewUnixOSCommand(),
+		})
+
+		clusterConfigFilePath := fmt.Sprintf("/tmp/kind-cluster-%s.yaml", kindClusterName)
+		clusterConfig, err := runner.Command("kind-config", &command.Args{
+			Create: pulumi.Sprintf("cat - | tee %s > /dev/null", clusterConfigFilePath),
+			Delete: pulumi.Sprintf("rm -f %s", clusterConfigFilePath),
+			Stdin:  pulumi.String(kindClusterConfig),
+		}, opts...)
+		if err != nil {
+			return err
+		}
+
+		nodeImage := fmt.Sprintf("%s:%s", kindNodeImageRegistry, kindVersionConfig.nodeImageVersion)
+		createCluster, err := runner.Command(
+			commonEnvironment.CommonNamer.ResourceName("kind-create-cluster", resourceName),
+			&command.Args{
+				Create:   pulumi.Sprintf("kind create cluster --name %s --config %s --image %s --wait %s", kindClusterName, clusterConfigFilePath, nodeImage, kindReadinessWait),
+				Delete:   pulumi.Sprintf("kind delete cluster --name %s", kindClusterName),
+				Triggers: pulumi.Array{pulumi.String(kindClusterConfig)},
+			},
+			utils.MergeOptions(opts, utils.PulumiDependsOn(clusterConfig), pulumi.DeleteBeforeReplace(true))...,
+		)
+		if err != nil {
+			return err
+		}
+
+		kubeConfigCmd, err := runner.Command(
+			commonEnvironment.CommonNamer.ResourceName("kind-kubeconfig", resourceName),
+			&command.Args{
+				Create: pulumi.Sprintf("kind get kubeconfig --name %s", kindClusterName),
+			},
+			utils.MergeOptions(opts, utils.PulumiDependsOn(createCluster))...,
+		)
+		if err != nil {
+			return err
+		}
+
+		clusterComp.KubeConfig = kubeConfigCmd.Stdout
+		clusterComp.ClusterName = pulumi.String(kindClusterName).ToStringOutput()
+
+		return nil
+	}, opts...)
+}