Merge pull request #493 from rabbitmq/delay-machine-upgrade

Delay machine upgrade until all members are up-to-date
rabbitmq · Jan 9, 2025 · 7a6b85d · 7a6b85d
2 parents f5ac36b + e9c82a0
commit 7a6b85d
Show file tree

Hide file tree

Showing 6 changed files with 439 additions and 97 deletions.
diff --git a/src/ra.hrl b/src/ra.hrl
@@ -70,7 +70,8 @@
                            voter_status => ra_voter_status(),
                            %% indicates that a snapshot is being sent
                            %% to the peer
-                           status := ra_peer_status()}.
+                           status := ra_peer_status(),
+                           machine_version => ra_machine:version()}.
 
 -type ra_cluster() :: #{ra_server_id() => ra_peer_state()}.
 
@@ -187,6 +188,17 @@
         {query_index :: integer(),
          term :: ra_term()}).
 
+-record(info_rpc,
+        {from :: ra_server_id(),
+         term :: ra_term(),
+         keys :: [ra_server:ra_server_info_key()]}).
+
+-record(info_reply,
+        {from :: ra_server_id(),
+         term :: ra_term(),
+         keys :: [ra_server:ra_server_info_key()],
+         info = #{} :: ra_server:ra_server_info()}).
+
 %% WAL defaults
 -define(WAL_DEFAULT_MAX_SIZE_BYTES, 256 * 1000 * 1000).
 -define(WAL_DEFAULT_MAX_BATCH_SIZE, 8192).