ydb 0.11.0

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

use ydb_grpc::ydb_proto::topic::stream_write_message::init_request::Partitioning as GrpcInitPartitioning;

#[derive(Clone, Debug, Default)]
pub enum PartitioningStrategy {
    #[default]
    ByProducerId,
    PartitionId(i64),
}

impl PartitioningStrategy {
    pub(crate) fn to_grpc_init_partitioning(&self, producer_id: String) -> GrpcInitPartitioning {
        match self {
            Self::ByProducerId => GrpcInitPartitioning::MessageGroupId(producer_id),
            Self::PartitionId(id) => GrpcInitPartitioning::PartitionId(*id),
        }
    }
}