hanabi-core 0.1.0-alpha.2

Core library for Hanabi
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

use std::num::NonZeroU64;

#[derive(Debug, Clone, Eq, PartialEq, Hash, serde::Serialize, serde::Deserialize)]
pub struct Message {
    metadata: MessageMetadata,
    data: bytes::Bytes,
}

impl Message {
    pub fn new(metadata: MessageMetadata, data: bytes::Bytes) -> Self {
        Self { metadata, data }
    }

    pub fn metadata(&self) -> &MessageMetadata {
        &self.metadata
    }

    pub fn data(&self) -> &bytes::Bytes {
        &self.data
    }
}

#[derive(Debug, Clone, Eq, PartialEq, Hash, serde::Serialize, serde::Deserialize)]
pub struct MessageMetadata {
    topic: String,
    timestamp: NonZeroU64,
}

impl MessageMetadata {
    pub fn new(topic: String, timestamp: NonZeroU64) -> Self {
        Self { topic, timestamp }
    }

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

    pub fn timestamp(&self) -> NonZeroU64 {
        self.timestamp
    }
}