test/e2e stream runtime SDK extension controller logs to artifacts

test/e2e/cluster_upgrade_runtimesdk.go

@@ -27,6 +27,7 @@ import (
 	. "github.com/onsi/ginkgo"
 	. "github.com/onsi/gomega"
 	"github.com/pkg/errors"
+	appsv1 "k8s.io/api/apps/v1"
 	corev1 "k8s.io/api/core/v1"
 	apierrors "k8s.io/apimachinery/pkg/api/errors"
 	metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
@@ -148,6 +149,36 @@ func clusterUpgradeWithRuntimeSDKSpec(ctx context.Context, inputGetter func() cl
 		err = input.BootstrapClusterProxy.GetClient().Create(ctx, responses)
 		Expect(err).ToNot(HaveOccurred(), "Failed to create the responses configmap")
 
+		By("Wait for test Extension Deployment to be running")
+		deploymentList := &appsv1.DeploymentList{}
+		Eventually(func() error {
+			if err := input.BootstrapClusterProxy.GetClient().List(ctx, deploymentList, client.InNamespace(namespace.Name)); err != nil {
+				return err
+			}
+			if len(deploymentList.Items) == 0 {
+				return errors.New("expected to find at least one deployment")
+			}
+			return nil
+		}, time.Minute, 3*time.Second).Should(Succeed(), "Failed to list deployments for the cluster API controllers")
+
+		By("Start streaming logs of the Extension Deployment")
+		Expect(deploymentList.Items).ToNot(BeEmpty(), "The list of controller deployments should not be empty")
+		for _, deployment := range deploymentList.Items {
+			d := deployment.DeepCopy()
+			framework.WaitForDeploymentsAvailable(ctx, framework.WaitForDeploymentsAvailableInput{
+				Getter:     input.BootstrapClusterProxy.GetClient(),
+				Deployment: d,
+			}, input.E2EConfig.GetIntervals(specName, "wait-controllers")...)
+
+			// Start streaming logs from all controller providers
+			framework.WatchDeploymentLogs(ctx, framework.WatchDeploymentLogsInput{
+				GetLister:  input.BootstrapClusterProxy.GetClient(),
+				ClientSet:  input.BootstrapClusterProxy.GetClientSet(),
+				Deployment: d,
+				LogPath:    filepath.Join(input.ArtifactFolder, "clusters", input.BootstrapClusterProxy.GetName(), "logs", namespace.Name),
+			})
+		}
+
 		By("Creating a workload cluster")
 
 		clusterctl.ApplyClusterTemplateAndWait(ctx, clusterctl.ApplyClusterTemplateAndWaitInput{