Function ExpectRemoteContainerFileContents

e2e/framework/helper.go:158–170

(labelSelector, container string, namespace string, filePath string, contents string)

}

func ExpectRemoteContainerFileContents(labelSelector, container string, namespace string, filePath string, contents string) {
	kubeClient, err := kube.NewKubeHelper()
	ExpectNoErrorWithOffset(1, err)

	err = wait.PollUntilContextTimeout(context.TODO(), time.Second, time.Minute*2, true, func(_ context.Context) (done bool, err error) {
		out, err := kubeClient.ExecByContainer(labelSelector, container, namespace, []string{"cat", filePath})
		if err != nil {
			return false, nil
		}
		return out == contents, nil
	})
	ExpectNoErrorWithOffset(1, err)
}

func ExpectLocalFileContentsImmediately(filePath string, contents string) {
	out, err := os.ReadFile(filePath)