chore: add resume test

Author: fraidev

.github/workflows/ci.yml

@@ -995,6 +995,58 @@ jobs:
           path: diagnostics*.gz
           retention-days: 1
 
+  local_resume_test:
+    name: Resume local cluster test on (${{ matrix.run }})
+    needs: build_primary_binaries
+    runs-on: ${{ matrix.os }}
+    strategy:
+ #     fail-fast: false
+      matrix:
+        os: [ubuntu-latest]
+        rust-target: [x86_64-unknown-linux-musl]
+        run: [r1]
+    steps:
+      - uses: actions/checkout@v4
+      # Download artifacts
+      - name: Download artifact - fluvio
+        uses: actions/download-artifact@v4
+        with:
+          name: fluvio-${{ matrix.rust-target }}
+          path: ~/bin
+      - name: Download artifact - fluvio-run
+        uses: actions/download-artifact@v4
+        with:
+          name: fluvio-run-${{ matrix.rust-target }}
+          path: ~/bin
+      - name: Mark executable
+        run: |
+          chmod +x ~/bin/fluvio-run
+          chmod +x ~/bin/fluvio && ~/bin/fluvio version
+          echo "${HOME}/bin" >> $GITHUB_PATH
+      - name: Install Parallel
+        run: sudo apt-get install -y parallel
+
+      - name: Run resume test with CI artifacts
+        timeout-minutes: 10
+        env:
+          TEST_DATA_BYTES: 10000
+        run: |
+          date
+          make FLUVIO_MODE=local FLUVIO_BIN=~/bin/fluvio resume-test
+
+      - name: Run diagnostics
+        if: ${{ !success() }}
+        timeout-minutes: 5
+        run: fluvio cluster diagnostics
+      - name: Upload logs
+        timeout-minutes: 5
+        if: ${{ !success() }}
+        uses: actions/upload-artifact@v4
+        with:
+          name: local_upgrade_${{ matrix.run }}_log
+          path: diagnostics*.gz
+          retention-days: 1
+
   # Smoke test across different version of fluvio
   cli_smoke:
     name: CLI smoke test (${{ matrix.test }}) CLI (${{ matrix.cli_version }}) on cluster (${{ matrix.cluster_version }})

makefiles/test.mk

@@ -187,6 +187,16 @@ upgrade-test: build-cli build_k8_image
 	./tests/upgrade-test.sh
 endif
 
+ifeq (${CI},true)
+# In CI, we expect all artifacts to already be built and loaded for the script
+resume-test:
+	./tests/local-resume-test.sh
+else
+# When not in CI (i.e. development), load the dev k8 image before running test
+resume-test: build-cli
+	./tests/local-resume-test.sh
+endif
+
 # When running in development, might need to run `cargo clean` to ensure correct fluvio binary is used
 validate-release-stable:
 	./tests/fluvio-validate-release.sh $(VERSION) $(GIT_COMMIT)

tests/local-resume-test.sh

@@ -0,0 +1,38 @@
+# #!/bin/bash
+${FLUVIO_BIN} cluster delete --force
+rm -rf ~/.fluvio
+${FLUVIO_BIN} cluster start --local
+
+seq 1 10 | parallel -j 10 ${FLUVIO_BIN} topic create test-topic-{}
+seq 1 10 | parallel -j 10 ${FLUVIO_BIN} remote register test-remote-{}
+
+${FLUVIO_BIN} cluster shutdown
+${FLUVIO_BIN} cluster resume
+
+# Create topic
+${FLUVIO_BIN} topic create test-topic-11 # THIS WAS HANGING
+
+TOPIC_LIST=$(${FLUVIO_BIN} topic list 2>/dev/null)
+PARTITION_LIST=$(${FLUVIO_BIN} partition list 2>/dev/null)
+REMOTE_LIST=$(${FLUVIO_BIN} remote list 2>/dev/null)
+
+# Check if the topic list has 11+1 lines
+if [ $(echo "$TOPIC_LIST" | wc -l) -eq 12 ]; then
+    echo "PASS"
+else
+    echo "FAIL"
+fi
+
+# Check if the partition list has 11+1 lines
+if [ $(echo "$PARTITION_LIST" | wc -l) -eq 12 ]; then
+    echo "PASS"
+else
+    echo "FAIL"
+fi
+
+# Check if the remote list has 10+1 lines
+if [ $(echo "$REMOTE_LIST" | wc -l) -eq 11 ]; then
+    echo "PASS"
+else
+    echo "FAIL"
+fi