ydb 0.15.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
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

use std::time::{self, UNIX_EPOCH};

use derive_builder::Builder;
use ydb_grpc::ydb_proto::topic::stream_write_message::write_request::MessageData;

use crate::{errors, YdbError};

#[derive(Builder)]
#[builder(build_fn(error = "errors::YdbError"))]
pub struct TopicWriterMessage {
    #[builder(default = "None")]
    pub(crate) seq_no: Option<i64>,
    #[builder(default = "time::SystemTime::now()")]
    pub(crate) created_at: time::SystemTime,

    pub(crate) data: Vec<u8>,
}

impl TryFrom<TopicWriterMessage> for MessageData {
    type Error = YdbError;

    fn try_from(value: TopicWriterMessage) -> Result<Self, Self::Error> {
        let data_size = value.data.len() as i64;

        let seq_no = value
            .seq_no
            .ok_or_else(|| YdbError::custom("empty message seq_no is provided"))?;

        let created_at = value.created_at.duration_since(UNIX_EPOCH)?;

        Ok(MessageData {
            seq_no,
            created_at: Some(ydb_grpc::google_proto_workaround::protobuf::Timestamp {
                seconds: created_at.as_secs() as i64,
                nanos: created_at.subsec_nanos() as i32,
            }),
            metadata_items: vec![],
            data: value.data,
            uncompressed_size: data_size,
            partitioning: None,
        })
    }
}