risingwave_common/system_param/
diff.rs

1// Copyright 2025 RisingWave Labs
2//
3// Licensed under the Apache License, Version 2.0 (the "License");
4// you may not use this file except in compliance with the License.
5// You may obtain a copy of the License at
6//
7//     http://www.apache.org/licenses/LICENSE-2.0
8//
9// Unless required by applicable law or agreed to in writing, software
10// distributed under the License is distributed on an "AS IS" BASIS,
11// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
12// See the License for the specific language governing permissions and
13// limitations under the License.
14
15use super::reader::SystemParamsRead;
16use crate::for_all_params;
17
18macro_rules! define_diff {
19    ($({ $field:ident, $type:ty, $default:expr, $is_mutable:expr, $doc:literal, $($rest:tt)* },)*) => {
20        /// The diff of the system params.
21        ///
22        /// Fields that are changed are set to `Some`, otherwise `None`.
23        #[derive(Default, Debug, Clone)]
24        pub struct SystemParamsDiff {
25            $(
26                #[doc = $doc]
27                pub $field: Option<$type>,
28            )*
29        }
30    }
31}
32for_all_params!(define_diff);
33
34impl SystemParamsDiff {
35    /// Create a diff between the given two system params.
36    pub fn diff(prev: impl SystemParamsRead, curr: impl SystemParamsRead) -> Self {
37        let mut diff = Self::default();
38
39        macro_rules! set_diff_field {
40            ($({ $field:ident, $($rest:tt)* },)*) => {
41                $(
42                    if curr.$field() != prev.$field() {
43                        diff.$field = Some(curr.$field().into());
44                    }
45                )*
46            };
47        }
48        for_all_params!(set_diff_field);
49
50        diff
51    }
52
53    /// Create a diff from the given initial system params.
54    /// All fields will be set to `Some`.
55    pub fn from_initial(initial: impl SystemParamsRead) -> Self {
56        macro_rules! initial_field {
57            ($({ $field:ident, $($rest:tt)* },)*) => {
58                Self {
59                    $(
60                        $field: Some(initial.$field().into()),
61                    )*
62                }
63            };
64        }
65        for_all_params!(initial_field)
66    }
67}
risingwave_common/system_param/diff.rs

risingwave_common/system_param/
diff.rs
