ax_types 0.1.0

Core types for use by and with the ax family
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

use crate::NodeId;
use im::OrdMap;
use serde::{Deserialize, Serialize};
use std::time::Duration;

/// Node Information
#[derive(Debug, Serialize, Deserialize, Clone, PartialEq, Eq)]
#[serde(rename_all = "camelCase")]
pub struct NodeInfoResponse {
    /// Number of currently connected nodes
    pub connected_nodes: usize,
    /// Uptime of the node
    pub uptime: Duration,
    /// Version string of the node
    pub version: String,
    /// Swarm status as seen by the node
    #[serde(default, skip_serializing_if = "Option::is_none")]
    pub swarm_state: Option<SwarmState>,
}

#[derive(Default, Debug, Clone, PartialEq, Eq, Serialize, Deserialize)]
#[serde(rename_all = "camelCase")]
pub struct SwarmState {
    pub peers_status: OrdMap<NodeId, PeerStatus>,
}

#[derive(Debug, Clone, Copy, PartialEq, Eq, Serialize, Deserialize)]
pub enum PeerStatus {
    /// Acknowledge replication within two gossip cycles
    LowLatency,
    /// Acknowledge replication within five gossip cycles
    HighLatency,
    /// Acknowledge replication of at least half of all streams within
    /// five gossip cycles
    PartiallyWorking,
    /// Acknowledge replication of less than half of all streams within
    /// five gossip cycles
    NotWorking,
}