ant-node 0.10.1

Pure quantum-proof network node for the Autonomi decentralized network
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
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73

//! Node event system.

use tokio::sync::broadcast;

/// Events emitted by the node.
#[derive(Debug, Clone)]
pub enum NodeEvent {
    /// Node has started successfully.
    Started,

    /// Node is shutting down.
    ShuttingDown,

    /// Connected to a peer.
    PeerConnected {
        /// Peer identifier.
        peer_id: String,
    },

    /// Disconnected from a peer.
    PeerDisconnected {
        /// Peer identifier.
        peer_id: String,
    },

    /// Data stored successfully.
    DataStored {
        /// Data address/key.
        address: String,
    },

    /// Data retrieved successfully.
    DataRetrieved {
        /// Data address/key.
        address: String,
    },

    /// Upgrade available.
    UpgradeAvailable {
        /// New version.
        version: String,
    },

    /// Upgrade started.
    UpgradeStarted {
        /// Version being installed.
        version: String,
    },

    /// Upgrade completed.
    UpgradeComplete {
        /// New version.
        version: String,
    },

    /// Error occurred.
    Error {
        /// Error message.
        message: String,
    },
}

/// Channel for receiving node events.
pub type NodeEventsChannel = broadcast::Receiver<NodeEvent>;

/// Sender for node events.
pub type NodeEventsSender = broadcast::Sender<NodeEvent>;

/// Create a new event channel pair.
#[must_use]
pub fn create_event_channel() -> (NodeEventsSender, NodeEventsChannel) {
    broadcast::channel(256)
}