rtnetlink 0.13.1

manipulate linux networking resources via netlink
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

// SPDX-License-Identifier: MIT

use futures::stream::StreamExt;
use netlink_packet_core::{NetlinkMessage, NLM_F_ACK, NLM_F_REQUEST};
use netlink_packet_route::{
    link::nlas::{Info, InfoBondPort, InfoPortData, InfoPortKind, Nla},
    LinkMessage, RtnlMessage,
};

use crate::{try_nl, Error, Handle};

pub struct BondPortSetRequest {
    handle: Handle,
    index: u32,
    port_nlas: Vec<InfoBondPort>,
}

impl BondPortSetRequest {
    pub(crate) fn new(handle: Handle, index: u32) -> Self {
        BondPortSetRequest {
            handle,
            index,
            port_nlas: Vec::new(),
        }
    }

    /// Execute the request.
    pub async fn execute(self) -> Result<(), Error> {
        let BondPortSetRequest {
            mut handle,
            index,
            port_nlas,
        } = self;

        let mut message = LinkMessage::default();
        message.header.index = index;
        message.nlas.push(Nla::Info(vec![
            Info::PortKind(InfoPortKind::Bond),
            Info::PortData(InfoPortData::BondPort(port_nlas)),
        ]));

        let mut req = NetlinkMessage::from(RtnlMessage::NewLink(message));
        req.header.flags = NLM_F_REQUEST | NLM_F_ACK;

        let mut response = handle.request(req)?;
        while let Some(message) = response.next().await {
            try_nl!(message);
        }
        Ok(())
    }

    /// Return a mutable reference to the Vec<InfoBondPort>
    pub fn info_port_nlas_mut(&mut self) -> &mut Vec<InfoBondPort> {
        &mut self.port_nlas
    }

    /// Adds the `queue_id` attribute to the bond port
    /// This is equivalent to
    /// `ip link set name NAME type bond_slave queue_id QUEUE_ID`.
    pub fn queue_id(mut self, queue_id: u16) -> Self {
        self.port_nlas.push(InfoBondPort::QueueId(queue_id));
        self
    }

    /// Adds the `prio` attribute to the bond port
    /// This is equivalent to `ip link set name NAME type bond_slave prio PRIO`.
    pub fn prio(mut self, prio: i32) -> Self {
        self.port_nlas.push(InfoBondPort::Prio(prio));
        self
    }
}