hydroflow 0.10.0

Hydro's low-level dataflow runtime and IR
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
44
45
46
47
48
49
50

use std::net::SocketAddr;

use hydroflow_macro::DemuxEnum;
use serde::{Deserialize, Serialize};

#[derive(Clone, Debug, Serialize, Deserialize, DemuxEnum)]
pub enum KvsMessage {
    ServerResponse { key: String, value: String },
    ClientPut { key: String, value: String },
    ClientGet { key: String },
    PeerGossip { key: String, value: String },
    PeerJoin,
}

#[derive(Clone, Debug, DemuxEnum)]
pub enum KvsMessageWithAddr {
    ServerResponse {
        key: String,
        value: String,
        addr: SocketAddr,
    },
    ClientPut {
        key: String,
        value: String,
        addr: SocketAddr,
    },
    ClientGet {
        key: String,
        addr: SocketAddr,
    },
    PeerGossip {
        key: String,
        value: String,
        addr: SocketAddr,
    },
    PeerJoin {
        addr: SocketAddr,
    },
}
impl KvsMessageWithAddr {
    pub fn from_message(message: KvsMessage, addr: SocketAddr) -> Self {
        match message {
            KvsMessage::ServerResponse { key, value } => Self::ServerResponse { key, value, addr },
            KvsMessage::ClientPut { key, value } => Self::ClientPut { key, value, addr },
            KvsMessage::ClientGet { key } => Self::ClientGet { key, addr },
            KvsMessage::PeerGossip { key, value } => Self::PeerGossip { key, value, addr },
            KvsMessage::PeerJoin => Self::PeerJoin { addr },
        }
    }
}