veilid-tools 0.5.4

A collection of baseline tools for Rust development use by Veilid and Veilid-enabled Rust applications
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
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89

use super::*;

#[derive(Debug)]
pub struct VirtualGateway {
    machine: Machine,
    gateway_id: GatewayId,
}

impl VirtualGateway {
    /////////////////////////////////////////////////////////////
    // Public Interface

    pub async fn find() -> VirtualNetworkResult<Option<Self>> {
        let machine = default_machine().unwrap_or_log();
        Self::find_with_machine(machine).await
    }

    pub async fn find_with_machine(machine: Machine) -> VirtualNetworkResult<Option<Self>> {
        machine
            .router_client
            .clone()
            .find_gateway(machine.id)
            .await
            .map(|opt_gateway_id| opt_gateway_id.map(|gateway_id| Self::new(machine, gateway_id)))
    }

    pub async fn get_routed_local_address(
        &self,
        address_type: VirtualAddressType,
    ) -> VirtualNetworkResult<IpAddr> {
        self.machine
            .router_client
            .clone()
            .get_routed_local_address(self.machine.id, address_type)
            .await
    }

    pub async fn get_external_address(&self) -> VirtualNetworkResult<IpAddr> {
        self.machine
            .router_client
            .clone()
            .get_external_address(self.gateway_id)
            .await
    }

    pub async fn add_port(
        &self,
        protocol: VirtualProtocolType,
        external_port: Option<u16>,
        local_address: SocketAddr,
        lease_duration_ms: u32,
        description: String,
    ) -> VirtualNetworkResult<u16> {
        self.machine
            .router_client
            .clone()
            .add_port(
                self.gateway_id,
                protocol,
                external_port,
                local_address,
                lease_duration_ms,
                description,
            )
            .await
    }

    pub async fn remove_port(
        &self,
        protocol: VirtualProtocolType,
        external_port: u16,
    ) -> VirtualNetworkResult<()> {
        self.machine
            .router_client
            .clone()
            .remove_port(self.gateway_id, protocol, external_port)
            .await
    }

    /////////////////////////////////////////////////////////////
    // Private Implementation

    fn new(machine: Machine, gateway_id: GatewayId) -> Self {
        Self {
            machine,
            gateway_id,
        }
    }
}