prns-runtime-tokio 0.3.6

Tokio host runtime for Personal Reticulum
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

use std::string::String;
use std::vec::Vec;

use tokio::sync::oneshot;

use crate::identity::{IdentityHash, PublicIdentityMaterial};
use crate::wire::DestinationHash;

pub use crate::engine::RouteSnapshot;

type CoreInterfaceIfacSnapshot =
    prns_runtime::runtime::node_introspection::InterfaceIfacSnapshot<String>;
type CoreInterfaceInventoryEntry =
    prns_runtime::runtime::node_introspection::InterfaceInventoryEntry<String>;

pub(crate) use prns_runtime::runtime::node_introspection::HeapAnnounceRateHistory as AnnounceRateHistory;
pub use prns_runtime::runtime::node_introspection::{
    logical_interface_inventory, AnnounceRateSnapshot, NodeIntrospection,
};
pub type InterfaceIfacSnapshot = CoreInterfaceIfacSnapshot;
pub type InterfaceInventoryEntry = CoreInterfaceInventoryEntry;

#[derive(Debug, Clone, Copy, PartialEq, Eq)]
pub enum DestinationIdentityQuery {
    Destination(DestinationHash),
    Identity(IdentityHash),
}

#[derive(Debug, Clone, Copy, PartialEq, Eq)]
pub struct DestinationIdentitySnapshot {
    pub destination: DestinationHash,
    pub identity: IdentityHash,
    pub public: PublicIdentityMaterial,
}

#[derive(Debug, Clone, PartialEq, Eq)]
pub struct EngineInspectionSnapshot {
    pub link_count: u32,
    pub routes: Vec<RouteSnapshot>,
    pub destination_identities: Vec<DestinationIdentitySnapshot>,
}

pub enum NodeIntrospectionRequest {
    LinkCount {
        reply: oneshot::Sender<u32>,
    },
    AnnounceRates {
        reply: oneshot::Sender<Vec<AnnounceRateSnapshot>>,
    },
    Routes {
        reply: oneshot::Sender<Vec<RouteSnapshot>>,
    },
    Route {
        destination: DestinationHash,
        reply: oneshot::Sender<Option<RouteSnapshot>>,
    },
    DestinationIdentityHash {
        destination: DestinationHash,
        reply: oneshot::Sender<Option<IdentityHash>>,
    },
    DestinationIdentity {
        query: DestinationIdentityQuery,
        reply: oneshot::Sender<Option<DestinationIdentitySnapshot>>,
    },
    DestinationIdentities {
        reply: oneshot::Sender<Vec<DestinationIdentitySnapshot>>,
    },
    EngineSnapshot {
        reply: oneshot::Sender<EngineInspectionSnapshot>,
    },
}