dbeel 0.1.0

dbeel is a fast and minimal distributed thread-per-core document database.
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

use bincode::Options;
use kinded::Kinded;
use serde::{Deserialize, Serialize};

use crate::{
    error::Result, messages::NodeMetadata, utils::bincode::bincode_options,
};

#[derive(Serialize, Deserialize, Debug, Clone, Kinded)]
#[kinded(derive(Hash))]
pub enum GossipEvent {
    Alive(NodeMetadata),
    Dead(String),
    CreateCollection(String, u16),
    DropCollection(String),
}

#[derive(Serialize, Deserialize)]
pub struct GossipMessage {
    pub source: String,
    pub event: GossipEvent,
}

impl GossipMessage {
    #[must_use]
    pub fn new(source: String, event: GossipEvent) -> Self {
        Self { source, event }
    }
}

pub fn deserialize_gossip_message(buf: &[u8]) -> Result<GossipMessage> {
    Ok(
        bincode_options()
            .deserialize_from::<_, GossipMessage>(&mut &buf[..])?,
    )
}

pub fn serialize_gossip_message(message: &GossipMessage) -> Result<Vec<u8>> {
    Ok(bincode_options().serialize(&message)?)
}