nlink 0.13.0

Async netlink library for Linux network configuration
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

//! Printable implementation for TcMessage.

use std::io::Write;

use crate::{
    netlink::messages::TcMessage,
    output::{OutputOptions, Printable},
};

impl Printable for TcMessage {
    fn print_text<W: Write>(&self, w: &mut W, opts: &OutputOptions) -> std::io::Result<()> {
        let dev = crate::util::get_ifname_or_index(self.ifindex());

        write!(
            w,
            "qdisc {} {} dev {} ",
            self.kind().unwrap_or(""),
            self.handle(),
            dev
        )?;

        let parent = self.parent();
        if parent.is_root() {
            write!(w, "root ")?;
        } else if parent.is_ingress() {
            write!(w, "ingress ")?;
        } else if !parent.is_unspec() {
            write!(w, "parent {} ", parent)?;
        }

        write!(w, "refcnt 2")?; // placeholder

        writeln!(w)?;

        if opts.stats {
            writeln!(
                w,
                " Sent {} bytes {} pkt (dropped {}, overlimits {} requeues {})",
                self.bytes(),
                self.packets(),
                self.drops(),
                self.overlimits(),
                self.requeues()
            )?;
            writeln!(w, " backlog {}b {}p", self.backlog(), self.qlen())?;
        }

        Ok(())
    }

    fn to_json(&self) -> serde_json::Value {
        let dev = crate::util::get_ifname_or_index(self.ifindex());

        serde_json::json!({
            "dev": dev,
            "kind": self.kind().unwrap_or(""),
            "handle": self.handle().to_string(),
            "parent": self.parent().to_string(),
            "bytes": self.bytes(),
            "packets": self.packets(),
            "drops": self.drops(),
            "overlimits": self.overlimits(),
            "requeues": self.requeues(),
            "qlen": self.qlen(),
            "backlog": self.backlog(),
        })
    }
}