dolphindb 3.3.1

A Rust native API for DolphinDB
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

use crate::types::VectorImpl;

#[derive(Debug, Clone)]
pub struct Message {
    offset: i64,
    topic: String,

    msg: VectorImpl,
}

impl Message {
    pub(crate) fn new(offset: i64, topic: String, msg: VectorImpl) -> Self {
        Self { offset, topic, msg }
    }

    pub fn topic(&self) -> &String {
        &self.topic
    }

    pub fn offset(&self) -> i64 {
        self.offset
    }

    pub fn msg(&self) -> &VectorImpl {
        &self.msg
    }
}