nlink 0.15.1

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

//! Watch for namespace creation and deletion.
//!
//! This example demonstrates how to monitor network namespace lifecycle
//! events using the NamespaceWatcher (inotify-based) API.
//!
//! Run with: cargo run -p nlink --features namespace_watcher --example namespace_watch
//!
//! Then in another terminal:
//!   sudo ip netns add test1
//!   sudo ip netns del test1

#[cfg(feature = "namespace_watcher")]
use nlink::netlink::{NamespaceEvent, NamespaceWatcher};

#[cfg(feature = "namespace_watcher")]
#[tokio::main]
async fn main() -> nlink::netlink::Result<()> {
    println!("Watching for namespace changes (Ctrl+C to stop)...\n");

    // Option 1: List existing namespaces and start watching atomically
    // This prevents race conditions where a namespace could be missed
    let (existing, mut watcher) = NamespaceWatcher::list_and_watch().await?;

    if existing.is_empty() {
        println!("No existing namespaces found.");
    } else {
        println!("Existing namespaces:");
        for ns in &existing {
            println!("  {}", ns);
        }
    }
    println!();
    println!("Watching for changes...");
    println!("{}", "-".repeat(40));

    while let Some(event) = watcher.recv().await? {
        match event {
            NamespaceEvent::Created { name } => {
                println!("[+] Namespace created: {}", name);
            }
            NamespaceEvent::Deleted { name } => {
                println!("[-] Namespace deleted: {}", name);
            }
            NamespaceEvent::DirectoryCreated => {
                println!("[*] /var/run/netns/ directory created");
            }
            NamespaceEvent::DirectoryDeleted => {
                println!("[*] /var/run/netns/ directory deleted");
            }
            // The enum is non_exhaustive — handle future variants gracefully.
            other => {
                println!("[?] Unknown event: {:?}", other);
            }
        }
    }

    Ok(())
}

#[cfg(not(feature = "namespace_watcher"))]
fn main() {
    eprintln!("This example requires the 'namespace_watcher' feature.");
    eprintln!(
        "Run with: cargo run -p nlink --features namespace_watcher --example namespace_watch"
    );
}