Function streamOperatorLogsToZip

internal/cmd/plugin/report/logs.go:42–74

streamOperatorLogsToZip streams the operator pod logs to a new section in the ZIP

(
	ctx context.Context,
	pods []corev1.Pod,
	dirName string,
	name string,
	logTimeStamp bool,
	zipper *zip.Writer,
)

// streamOperatorLogsToZip streams the operator pod logs to a new section in the ZIP
func streamOperatorLogsToZip(
	ctx context.Context,
	pods []corev1.Pod,
	dirName string,
	name string,
	logTimeStamp bool,
	zipper *zip.Writer,
) error {
	logsDir := filepath.Join(dirName, name)
	if _, err := zipper.Create(logsDir + "/"); err != nil {
		return fmt.Errorf("could not add '%s' to zip: %w", logsDir, err)
	}

	for i := range pods {
		pod := pods[i]
		path := filepath.Join(logsDir, fmt.Sprintf("%s-logs.jsonl", pod.Name))
		writer, zipperErr := zipper.Create(path)
		if zipperErr != nil {
			return fmt.Errorf("could not add '%s' to zip: %w", path, zipperErr)
		}

		streamPodLogs := podlogs.NewPodLogsWriter(pod, kubernetes.NewForConfigOrDie(ctrl.GetConfigOrDie()))
		opts := &corev1.PodLogOptions{
			Timestamps: logTimeStamp,
			Previous:   true,
		}
		if err := streamPodLogs.Single(ctx, writer, opts); err != nil {
			return err
		}
	}

	return nil
}

// streamClusterLogsToZip streams the logs from the pods in the cluster, one by
// one, each in a new file, within  a folder