update integration test pods to refresh logs

Several of the tests, particularly TestApplicationGoCounter in
app_test.go, because packet counts in the logs aren't incrementing. This
change causes the logs to refresh the logs so the packet count changes
can be detected.

Signed-off-by: Billy McFall <[email protected]>

Author: Billy99

release-v0.5.6/bpfman-crds-install.yaml

@@ -65,7 +65,7 @@ func TestApplicationGoCounter(t *testing.T) {
 	}
 
 	for idx, f := range checkFunctions {
-		req := env.Cluster().Client().CoreV1().Pods(appGoCounterUserspaceNs).GetLogs(goAppCounterPod.Name, &corev1.PodLogOptions{})
+		req := env.Cluster().Client().CoreV1().Pods(appGoCounterUserspaceNs).GetLogs(goAppCounterPod.Name, &corev1.PodLogOptions{Follow: true})
 		require.Eventually(t, func() bool {
 			logs, err := req.Stream(ctx)
 			require.NoError(t, err)

release-v0.5.6/bpfman-operator-install.yaml

@@ -43,7 +43,7 @@ func TestKprobeGoCounter(t *testing.T) {
 	require.NoError(t, err)
 	goKprobeCounterPod := pods.Items[0]
 
-	req := env.Cluster().Client().CoreV1().Pods(kprobeGoCounterUserspaceNs).GetLogs(goKprobeCounterPod.Name, &corev1.PodLogOptions{})
+	req := env.Cluster().Client().CoreV1().Pods(kprobeGoCounterUserspaceNs).GetLogs(goKprobeCounterPod.Name, &corev1.PodLogOptions{Follow: true})
 	require.Eventually(t, func() bool {
 		logs, err := req.Stream(ctx)
 		require.NoError(t, err)

test/integration/app_test.go

@@ -43,7 +43,7 @@ func TestTcGoCounter(t *testing.T) {
 	require.NoError(t, err)
 	gotcCounterPod := pods.Items[0]
 
-	req := env.Cluster().Client().CoreV1().Pods(tcGoCounterUserspaceNs).GetLogs(gotcCounterPod.Name, &corev1.PodLogOptions{})
+	req := env.Cluster().Client().CoreV1().Pods(tcGoCounterUserspaceNs).GetLogs(gotcCounterPod.Name, &corev1.PodLogOptions{Follow: true})
 
 	require.Eventually(t, func() bool {
 		logs, err := req.Stream(ctx)

test/integration/kprobe_test.go

@@ -43,7 +43,7 @@ func TestTcxGoCounter(t *testing.T) {
 	require.NoError(t, err)
 	gotcxCounterPod := pods.Items[0]
 
-	req := env.Cluster().Client().CoreV1().Pods(tcxGoCounterUserspaceNs).GetLogs(gotcxCounterPod.Name, &corev1.PodLogOptions{})
+	req := env.Cluster().Client().CoreV1().Pods(tcxGoCounterUserspaceNs).GetLogs(gotcxCounterPod.Name, &corev1.PodLogOptions{Follow: true})
 
 	require.Eventually(t, func() bool {
 		logs, err := req.Stream(ctx)

test/integration/tc_test.go

@@ -43,7 +43,7 @@ func TestTracepointGoCounter(t *testing.T) {
 	require.NoError(t, err)
 	goTracepointCounterPod := pods.Items[0]
 
-	req := env.Cluster().Client().CoreV1().Pods(tracepointGoCounterUserspaceNs).GetLogs(goTracepointCounterPod.Name, &corev1.PodLogOptions{})
+	req := env.Cluster().Client().CoreV1().Pods(tracepointGoCounterUserspaceNs).GetLogs(goTracepointCounterPod.Name, &corev1.PodLogOptions{Follow: true})
 	require.Eventually(t, func() bool {
 		logs, err := req.Stream(ctx)
 		require.NoError(t, err)

test/integration/tcx_test.go

@@ -62,7 +62,7 @@ func TestUprobeGoCounter(t *testing.T) {
 	require.NoError(t, err)
 	goUprobeCounterPod := pods.Items[0]
 
-	req := env.Cluster().Client().CoreV1().Pods(uprobeGoCounterUserspaceNs).GetLogs(goUprobeCounterPod.Name, &corev1.PodLogOptions{})
+	req := env.Cluster().Client().CoreV1().Pods(uprobeGoCounterUserspaceNs).GetLogs(goUprobeCounterPod.Name, &corev1.PodLogOptions{Follow: true})
 	require.Eventually(t, func() bool {
 		logs, err := req.Stream(ctx)
 		require.NoError(t, err)

test/integration/tracepoint_test.go

@@ -125,7 +125,7 @@ func TestXdpGoCounter(t *testing.T) {
 	require.NoError(t, err)
 	goXdpCounterPod := pods.Items[0]
 
-	req := env.Cluster().Client().CoreV1().Pods(xdpGoCounterUserspaceNs).GetLogs(goXdpCounterPod.Name, &corev1.PodLogOptions{})
+	req := env.Cluster().Client().CoreV1().Pods(xdpGoCounterUserspaceNs).GetLogs(goXdpCounterPod.Name, &corev1.PodLogOptions{Follow: true})
 
 	require.Eventually(t, func() bool {
 		logs, err := req.Stream(ctx)