chore: enable merge group

.github/workflows/ci.yml

@@ -1,10 +1,7 @@
 name: CI
 
 on:
-  push:
-    branches:
-      - staging
-      - trying
+  merge_group:
   pull_request:
     branches: [master]
 
@@ -142,7 +139,6 @@ jobs:
 
   done:
     name: Done
-    if: github.event_name == 'push' && github.ref == 'refs/heads/staging'
     needs:
       - unit_test
       - check_fmt
@@ -151,5 +147,23 @@ jobs:
       - unit_test_k8_client_feature_flags
     runs-on: ubuntu-latest
     steps:
+      - name: Dump needs context
+        env:
+          CONTEXT: ${{ toJson(needs) }}
+        run: |
+          echo -e "\033[33;1;4mDump context\033[0m"
+          echo -e "$CONTEXT\n"
+      - name: Report failure on cancellation
+        if: ${{ contains(needs.*.result, 'cancelled') || cancelled() }}
+        run: exit 1
+      - name: Failing test and build
+        if: ${{ contains(needs.*.result, 'failure') }}
+        run: exit 1
+      - name: Don't allow skipped
+        if: ${{ contains(needs.*.result, 'skipped')  && github.event_name == 'merge_group' }}
+        run: exit 1
+      - name: Successful test and build
+        if: ${{ !(contains(needs.*.result, 'failure')) }}
+        run: exit 0
       - name: Done
         run: echo "Done!"

src/k8-client/src/client/mod.rs

@@ -44,6 +44,7 @@ mod executor {
 
     use fluvio_future::task::spawn;
 
+    #[allow(dead_code)]
     pub(crate) struct FluvioHyperExecutor;
 
     impl<F: Future + Send + 'static> Executor<F> for FluvioHyperExecutor {

src/k8-types/src/app/stateful.rs

@@ -37,7 +37,8 @@ impl Spec for StatefulSetSpec {
 
     // statefulset doesnt' like to change volume claim template
     fn make_same(&mut self, other: &Self) {
-        self.volume_claim_templates = other.volume_claim_templates.clone();
+        self.volume_claim_templates
+            .clone_from(&other.volume_claim_templates)
     }
 }
 

src/k8-types/src/core/service.rs

@@ -45,7 +45,7 @@ impl Spec for ServiceSpec {
 
     fn make_same(&mut self, other: &Self) {
         if other.cluster_ip.is_empty() {
-            self.cluster_ip = "".to_owned();
+            "".clone_into(&mut self.cluster_ip);
         }
     }
 }