Add envfunc to export kind cluster logs

examples/kind/kind_with_config/main_test.go

@@ -39,6 +39,7 @@ func TestMain(m *testing.M) {
 
 	testenv.Finish(
 		envfuncs.DeleteNamespace(namespace),
+		envfuncs.ExportKindClusterLogs(kindClusterName, "./logs"),
 		envfuncs.DestroyKindCluster(kindClusterName),
 	)
 	os.Exit(testenv.Run(m))

pkg/envfuncs/kind_funcs.go

@@ -205,3 +205,26 @@ func LoadImageArchiveToCluster(name, imageArchive string) env.Func {
 		return ctx, nil
 	}
 }
+
+// ExportKindClusterLogs returns an EnvFunc that
+// retrieves a previously saved kind Cluster in the context (using the name), and then export cluster logs
+// in the provided destination.
+func ExportKindClusterLogs(name, dest string) env.Func {
+	return func(ctx context.Context, cfg *envconf.Config) (context.Context, error) {
+		clusterVal := ctx.Value(kindContextKey(name))
+		if clusterVal == nil {
+			return ctx, fmt.Errorf("export kind cluster logs: context cluster is nil")
+		}
+
+		cluster, ok := clusterVal.(*kind.Cluster)
+		if !ok {
+			return ctx, fmt.Errorf("export kind cluster logs: unexpected type for cluster value")
+		}
+
+		if err := cluster.ExportLogs(dest); err != nil {
+			return ctx, fmt.Errorf("load image archive: %w", err)
+		}
+
+		return ctx, nil
+	}
+}

support/kind/kind.go

@@ -130,6 +130,21 @@ func (k *Cluster) GetKubeCtlContext() string {
 	return fmt.Sprintf("kind-%s", k.name)
 }
 
+// ExportLogs export all cluster logs to the provided path.
+func (k *Cluster) ExportLogs(dest string) error {
+	log.V(4).Info("Exporting kind cluster logs to ", dest)
+	if err := k.findOrInstallKind(k.e); err != nil {
+		return err
+	}
+
+	p := k.e.RunProc(fmt.Sprintf(`kind export logs %s --name %s`, dest, k.name))
+	if p.Err() != nil {
+		return fmt.Errorf("kind: export cluster logs failed: %s: %s", p.Err(), p.Result())
+	}
+
+	return nil
+}
+
 func (k *Cluster) Destroy() error {
 	log.V(4).Info("Destroying kind cluster ", k.name)
 	if err := k.findOrInstallKind(k.e); err != nil {