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
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145

//! Async netlink protocol implementation for Linux.
//!
//! This module provides a complete netlink implementation from scratch,
//! supporting RTNetlink (routing), traffic control, and other subsystems.
//!
//! # Quick Start
//!
//! ```ignore
//! use nlink::netlink::{Connection, Route};
//!
//! let conn = Connection::<Route>::new()?;
//!
//! // Query interfaces
//! let links = conn.get_links().await?;
//! for link in &links {
//!     println!("{}: {}", link.ifindex(), link.name_or("?"));
//! }
//!
//! // Build ifindex -> name map for resolving routes/addresses
//! let names = conn.get_interface_names().await?;
//! ```
//!
//! # Event Monitoring
//!
//! Subscribe to multicast groups and use the stream API to monitor events:
//!
//! ```ignore
//! use nlink::netlink::{Connection, Route, RtnetlinkGroup, NetworkEvent};
//! use tokio_stream::StreamExt;
//!
//! let mut conn = Connection::<Route>::new()?;
//! conn.subscribe(&[RtnetlinkGroup::Link, RtnetlinkGroup::Ipv4Addr])?;
//!
//! let mut events = conn.events();
//! while let Some(event) = events.next().await {
//!     match event? {
//!         NetworkEvent::NewLink(link) => println!("New link: {:?}", link.name),
//!         NetworkEvent::NewAddress(addr) => println!("New address: {:?}", addr.address),
//!         _ => {}
//!     }
//! }
//! ```
//!
//! # Traffic Control (TC)
//!
//! The `tc` module provides typed configuration for qdiscs:
//!
//! ```ignore
//! use nlink::netlink::tc::NetemConfig;
//! use std::time::Duration;
//!
//! // Add network emulation with delay and packet loss
//! let netem = NetemConfig::new()
//!     .delay(Duration::from_millis(100))
//!     .jitter(Duration::from_millis(10))
//!     .loss(1.0)  // 1% packet loss
//!     .build();
//!
//! conn.add_qdisc("eth0", netem).await?;
//!
//! // Update the configuration
//! let updated = NetemConfig::new()
//!     .delay(Duration::from_millis(50))
//!     .build();
//! conn.change_qdisc("eth0", "root", updated).await?;
//!
//! // Delete the qdisc
//! conn.del_qdisc("eth0", "root").await?;
//! ```

pub mod action;
pub mod addr;
pub mod attr;
pub mod audit;
pub mod batch;
pub mod bridge_vlan;
mod builder;
pub mod config;
pub mod connection;
pub mod connector;
pub mod diagnostics;
mod error;
pub mod events;
pub mod fdb;
pub mod fib_lookup;
pub mod filter;
#[cfg(test)]
mod fixtures;
pub mod genl;
pub mod impair;
mod interface_ref;
pub mod link;
pub mod message;
pub mod messages;
pub mod mpls;
pub mod namespace;
pub mod namespace_events;
#[cfg(feature = "namespace_watcher")]
pub mod namespace_watcher;
pub mod neigh;
pub mod netfilter;
pub mod nexthop;
pub mod nftables;
pub mod parse;
mod protocol;
pub mod ratelimit;
pub mod route;
pub mod rule;
pub mod selinux;
#[cfg(feature = "sockdiag")]
mod sockdiag;
mod socket;
pub mod srv6;
pub mod stats;
mod stream;
pub mod sysctl;
pub mod tc;
pub mod tc_handle;
pub mod tc_options;
pub mod types;
pub mod uevent;
pub mod xfrm;

pub use attr::{AttrIter, NlAttr};
pub use batch::{Batch, BatchResults};
pub use builder::{MessageBuilder, NestToken};
pub use connection::{Connection, RtnetlinkGroup};
pub use error::{Error, Result};
pub use events::NetworkEvent;
pub use interface_ref::InterfaceRef;
pub use message::{MessageIter, NLMSG_HDRLEN, NlMsgHdr, NlMsgType};
pub use namespace::NamespaceSpec;
pub use namespace_events::{NamespaceEventSubscriber, NamespaceNetlinkEvent};
#[cfg(feature = "namespace_watcher")]
pub use namespace_watcher::{
    NamespaceEvent, NamespaceEventStream, NamespaceWatcher, NamespaceWatcherConfig,
};
pub use parse::{FromNetlink, ToNetlink};
pub use protocol::{
    Audit, Connector, Devlink, Ethtool, FibLookup, Generic, KobjectUevent, Macsec, Mptcp,
    Netfilter, Nftables, Nl80211, ProtocolState, Route, SELinux, SockDiag, Wireguard, Xfrm,
};
pub use socket::{NetlinkSocket, Protocol, rtnetlink_groups};
pub use stream::{EventSource, EventSubscription, OwnedEventStream};
pub use tc_options::NetemParameter;