nextest

Signed-off-by: Zahari Dichev <zaharidichev@gmail.com>

Author: zaharidichev

.github/workflows/pr.yml

@@ -120,10 +120,16 @@ jobs:
       - name: Install Rust (rustup)
         run: rustup update stable --no-self-update && rustup default stable
         shell: bash
+      - name: Install nextest
+        run: curl -LsSf https://get.nexte.st/latest/windows-tar | tar zxf - -C ${CARGO_HOME:-~/.cargo}/bin
+        shell: bash
       - run: rustup target add x86_64-pc-windows-gnu
       - name: Install nasm
         run: choco install nasm
         shell: cmd
+      - name: Install protoc
+        run: choco install protoc
+        shell: cmd
       - name: Install LLVM and Clang
         uses: KyleMayes/install-llvm-action@v2.0.5
         with:
@@ -137,8 +143,12 @@ jobs:
         run: cargo fmt -- --check
       - name: clippy
         run: cargo clippy  --target=x86_64-pc-windows-gnu --workspace --all-targets --frozen
+      - name: tests no run
+        run: cargo nextest run  --target=x86_64-pc-windows-gnu --workspace --frozen --exclude=linkerd2-proxy --no-run
       - name: tests
-        run: cargo test --target=x86_64-pc-windows-gnu --workspace --exclude=linkerd2-proxy --frozen
+        run: cargo nextest run  --target=x86_64-pc-windows-gnu --workspace --frozen --exclude=linkerd2-proxy
+        env:
+          NEXTEST_RETRIES: 3
 
 
   # rust-crates:

linkerd/app/integration/src/tests/telemetry.rs

@@ -882,21 +882,19 @@ async fn metrics_have_no_double_commas() {
 }
 
 #[cfg(target_os = "linux")]
-mod process {
-    #[tokio::test]
-    async fn metrics_has_start_time() {
-        let Fixture {
-            metrics,
-            proxy: _proxy,
-            _profile,
-            dst_tx: _dst_tx,
-            pol_out_tx: _pol_out_tx,
-            ..
-        } = Fixture::inbound().await;
-        let uptime_regex = regex::Regex::new(r"process_start_time_seconds \d+")
-            .expect("compiling regex shouldn't fail");
-        assert_eventually!(uptime_regex.find(&metrics.get("/metrics").await).is_some())
-    }
+#[tokio::test]
+async fn metrics_has_start_time() {
+    let Fixture {
+        metrics,
+        proxy: _proxy,
+        _profile,
+        dst_tx: _dst_tx,
+        pol_out_tx: _pol_out_tx,
+        ..
+    } = Fixture::inbound().await;
+    let uptime_regex = regex::Regex::new(r"process_start_time_seconds \d+")
+        .expect("compiling regex shouldn't fail");
+    assert_eventually!(uptime_regex.find(&metrics.get("/metrics").await).is_some())
 }
 
 mod transport {

linkerd/app/integration/src/tests/transparency.rs

@@ -1369,8 +1369,8 @@ mod proxy_to_proxy {
             "transparency.test.svc.cluster.local",
         );
         let res = client.request(client.request_builder("/")).await.unwrap();
-        // tracing::info!(res);
-        assert_eq!(res.status(), http::StatusCode::BAD_GATEWAY);
+        tracing::info!("result {:?}", res);
+        assert_eq!(res.status(), http::StatusCode::GATEWAY_TIMEOUT);
 
         // ensure panics from the server are propagated
         proxies.join_servers().await;