ydb 0.10.3

Crate contains generated low-level grpc code from YDB API protobuf, used as base for ydb crate
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55

use ydb_grpc::ydb_proto::topic::{AlterPartitioningSettings, PartitioningSettings};

#[derive(Debug, serde::Serialize)]
pub(crate) struct RawPartitioningSettings {
    pub min_active_partitions: i64,
    pub partition_count_limit: i64,
}

impl From<PartitioningSettings> for RawPartitioningSettings {
    fn from(value: PartitioningSettings) -> Self {
        Self {
            min_active_partitions: value.min_active_partitions,
            partition_count_limit: value.max_active_partitions,
        }
    }
}

impl From<RawPartitioningSettings> for PartitioningSettings {
    fn from(value: RawPartitioningSettings) -> Self {
        #[allow(deprecated)]
        Self {
            min_active_partitions: value.min_active_partitions,
            partition_count_limit: value.partition_count_limit,
            max_active_partitions: value.partition_count_limit,
            auto_partitioning_settings: None,
        }
    }
}

#[derive(Debug, serde::Serialize)]
pub(crate) struct RawAlterPartitioningSettings {
    pub set_min_active_partitions: Option<i64>,
    pub set_partition_count_limit: Option<i64>,
}

impl From<AlterPartitioningSettings> for RawAlterPartitioningSettings {
    fn from(value: AlterPartitioningSettings) -> Self {
        Self {
            set_min_active_partitions: value.set_min_active_partitions,
            set_partition_count_limit: value.set_max_active_partitions,
        }
    }
}

impl From<RawAlterPartitioningSettings> for AlterPartitioningSettings {
    fn from(value: RawAlterPartitioningSettings) -> Self {
        #[allow(deprecated)]
        Self {
            set_min_active_partitions: value.set_min_active_partitions,
            set_partition_count_limit: value.set_partition_count_limit,
            set_max_active_partitions: value.set_partition_count_limit,
            alter_auto_partitioning_settings: None,
        }
    }
}