fix(meta): include secret in meta backup for etcd meta store (#17908)

src/meta/src/backup_restore/meta_snapshot_builder.rs

@@ -21,7 +21,7 @@ use risingwave_backup::meta_snapshot_v1::{ClusterMetadata, MetaSnapshotV1};
 use risingwave_backup::MetaSnapshotId;
 use risingwave_hummock_sdk::version::{HummockVersion, HummockVersionDelta};
 use risingwave_pb::catalog::{
-    Connection, Database, Function, Index, Schema, Sink, Source, Subscription, Table, View,
+    Connection, Database, Function, Index, Schema, Secret, Sink, Source, Subscription, Table, View,
 };
 use risingwave_pb::hummock::HummockVersionStats;
 use risingwave_pb::meta::SystemParams;
@@ -124,6 +124,7 @@ impl<S: MetaStore> MetaSnapshotV1Builder<S> {
             .ok_or_else(|| anyhow!("cluster id not found in meta store"))?
             .into();
         let subscription = Subscription::list_at_snapshot::<S>(&meta_store_snapshot).await?;
+        let secret = Secret::list_at_snapshot::<S>(&meta_store_snapshot).await?;
 
         self.snapshot.metadata = ClusterMetadata {
             default_cf,
@@ -144,6 +145,7 @@ impl<S: MetaStore> MetaSnapshotV1Builder<S> {
             system_param,
             cluster_id,
             subscription,
+            secret,
         };
         Ok(())
     }

src/meta/src/backup_restore/restore_impl/v1.rs

@@ -199,5 +199,6 @@ async fn restore_metadata<S: MetaStore>(
     restore_system_param_model(&meta_store, &[snapshot.metadata.system_param]).await?;
     restore_cluster_id(&meta_store, snapshot.metadata.cluster_id.into()).await?;
     restore_metadata_model(&meta_store, &snapshot.metadata.subscription).await?;
+    restore_metadata_model(&meta_store, &snapshot.metadata.secret).await?;
     Ok(())
 }

src/meta/src/model/mod.rs

@@ -207,7 +207,8 @@ macro_rules! for_all_metadata_models {
     ($macro:ident) => {
         $macro! {
             // These items should be included in a meta snapshot.
-            // So be sure to update meta backup/restore when adding new items.
+            // Make sure to update the meta backup&restore methods accordingly when adding new items,
+            // referring to https://github.com/risingwavelabs/risingwave/pull/15371/commits/c5a75320845a38cfb43241ddee16fd5c0e47833b
             { risingwave_pb::hummock::HummockVersionStats },
             { crate::hummock::model::CompactionGroup },
             { risingwave_pb::catalog::Database },

src/storage/backup/src/meta_snapshot_v1.rs

@@ -20,7 +20,7 @@ use itertools::Itertools;
 use risingwave_common::util::iter_util::ZipEqFast;
 use risingwave_hummock_sdk::version::HummockVersion;
 use risingwave_pb::catalog::{
-    Connection, Database, Function, Index, Schema, Sink, Source, Subscription, Table, View,
+    Connection, Database, Function, Index, Schema, Secret, Sink, Source, Subscription, Table, View,
 };
 use risingwave_pb::hummock::{CompactionGroup, HummockVersionStats, PbHummockVersion};
 use risingwave_pb::meta::{SystemParams, TableFragments};
@@ -72,6 +72,10 @@ impl Display for ClusterMetadata {
         writeln!(f, "{:#?}", self.system_param)?;
         writeln!(f, "cluster_id:")?;
         writeln!(f, "{:#?}", self.cluster_id)?;
+        writeln!(f, "subscription:")?;
+        writeln!(f, "{:#?}", self.subscription)?;
+        writeln!(f, "secret:")?;
+        writeln!(f, "{:#?}", self.secret)?;
         Ok(())
     }
 }
@@ -121,6 +125,7 @@ pub struct ClusterMetadata {
     pub system_param: SystemParams,
     pub cluster_id: String,
     pub subscription: Vec<Subscription>,
+    pub secret: Vec<Secret>,
 }
 
 impl ClusterMetadata {
@@ -146,6 +151,7 @@ impl ClusterMetadata {
         Self::encode_prost_message(&self.system_param, buf);
         Self::encode_prost_message(&self.cluster_id, buf);
         Self::encode_prost_message_list(&self.subscription.iter().collect_vec(), buf);
+        Self::encode_prost_message_list(&self.secret.iter().collect_vec(), buf);
         Ok(())
     }
 
@@ -175,6 +181,8 @@ impl ClusterMetadata {
         let cluster_id: String = Self::decode_prost_message(&mut buf)?;
         let subscription: Vec<Subscription> =
             Self::try_decode_prost_message_list(&mut buf).unwrap_or_else(|| Ok(vec![]))?;
+        let secret: Vec<Secret> =
+            Self::try_decode_prost_message_list(&mut buf).unwrap_or_else(|| Ok(vec![]))?;
 
         Ok(Self {
             default_cf,
@@ -195,6 +203,7 @@ impl ClusterMetadata {
             system_param,
             cluster_id,
             subscription,
+            secret,
         })
     }