risingwave_hummock_sdk/
state_table_info.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 risingwave_pb::hummock::PbStateTableInfo;
16use serde::{Deserialize, Serialize};
17
18#[derive(Serialize, Deserialize, Clone)]
19pub struct StateTableInfo {
20    #[serde(default)]
21    pub committed_epoch: u64,
22    #[serde(default)]
23    pub compaction_group_id: u64,
24}
25
26impl From<StateTableInfo> for PbStateTableInfo {
27    fn from(i: StateTableInfo) -> Self {
28        (&i).into()
29    }
30}
31
32impl From<&StateTableInfo> for PbStateTableInfo {
33    fn from(i: &StateTableInfo) -> Self {
34        Self {
35            committed_epoch: i.committed_epoch,
36            compaction_group_id: i.compaction_group_id,
37        }
38    }
39}
40
41impl From<PbStateTableInfo> for StateTableInfo {
42    fn from(i: PbStateTableInfo) -> Self {
43        (&i).into()
44    }
45}
46
47impl From<&PbStateTableInfo> for StateTableInfo {
48    fn from(i: &PbStateTableInfo) -> Self {
49        Self {
50            committed_epoch: i.committed_epoch,
51            compaction_group_id: i.compaction_group_id,
52        }
53    }
54}
risingwave_hummock_sdk/state_table_info.rs

risingwave_hummock_sdk/
state_table_info.rs
