Function Logs

tests/utils/pods/pod.go:117–141

Logs gathers pod logs

(
	ctx context.Context,
	kubeInterface kubernetes.Interface,
	namespace, podName string,
)

// Logs gathers pod logs
func Logs(
	ctx context.Context,
	kubeInterface kubernetes.Interface,
	namespace, podName string,
) (string, error) {
	req := kubeInterface.CoreV1().Pods(namespace).GetLogs(podName, &corev1.PodLogOptions{})
	podLogs, err := req.Stream(ctx)
	if err != nil {
		return "", err
	}
	defer func() {
		innerErr := podLogs.Close()
		if err == nil && innerErr != nil {
			err = innerErr
		}
	}()

	// Create a buffer to hold JSON data
	buf := new(bytes.Buffer)
	_, err = io.Copy(buf, podLogs)
	if err != nil {
		return "", err
	}
	return buf.String(), nil
}

// Get gets a pod by namespace and name
func Get(