Merge branch 'main' into ipvlan_and_ipvtap

Author: xujunjie-cover

CHANGELOG

@@ -1,4 +1,16 @@
 # Changelog
+## [0.19.0] - 2025-12-09
+### Breaking changes
+ - Please check breaking changes of netlink-packet-route 0.19.0
+
+### New features
+ - vlan: Add wrapper for setting VLAN protocol and flags. (50fbcb3)
+ - Add function on RouteMessageBuilder for setting route mark. (c0edfbf)
+ - Support creating multicast netlink connection. (84dfe67)
+
+### Bug fixes
+ - Swap 'futures' dependency for 'futures-util' and 'futures-channel'. (26eda64)
+
 ## [0.18.1] - 2025-09-09
 ### Breaking changes
  - N/A

Cargo.toml

@@ -1,6 +1,6 @@
 [package]
 name = "rtnetlink"
-version = "0.18.1"
+version = "0.19.0"
 authors = ["Corentin Henry <corentinhenry@gmail.com>"]
 edition = "2021"
 homepage = "https://github.com/rust-netlink/rtnetlink"
@@ -18,11 +18,12 @@ tokio_socket = ["netlink-proto/tokio_socket", "tokio"]
 smol_socket = ["netlink-proto/smol_socket", "async-global-executor"]
 
 [dependencies]
-futures = "0.3.11"
+futures-util = "0.3.11"
+futures-channel = "0.3.11"
 log = "0.4.8"
 thiserror = "1"
 netlink-sys = { version = "0.8" }
-netlink-packet-route = { version = "0.25" }
+netlink-packet-route = { version = "0.26" }
 netlink-packet-core = { version = "0.8" }
 netlink-proto = { default-features = false, version = "0.12.0" }
 nix = { version = "0.30.0", default-features = false, features = ["fs", "mount", "sched", "signal"] }

examples/add_address.rs

@@ -2,7 +2,7 @@
 
 use std::env;
 
-use futures::stream::TryStreamExt;
+use futures_util::stream::TryStreamExt;
 use ipnetwork::IpNetwork;
 use rtnetlink::{new_connection, Error, Handle};
 

examples/add_neighbour.rs

@@ -2,7 +2,7 @@
 
 use std::{convert::TryFrom, env, net::IpAddr};
 
-use futures::stream::TryStreamExt;
+use futures_util::stream::TryStreamExt;
 use rtnetlink::{new_connection, Error, Handle};
 
 #[tokio::main]

examples/add_route_pref_src.rs

@@ -2,7 +2,7 @@
 
 use std::{env, net::Ipv4Addr};
 
-use futures::TryStreamExt;
+use futures_util::TryStreamExt;
 use ipnetwork::Ipv4Network;
 use rtnetlink::{new_connection, Error, Handle, RouteMessageBuilder};
 

examples/create_macvlan.rs

@@ -2,7 +2,7 @@
 
 use std::{env, str::FromStr};
 
-use futures::stream::TryStreamExt;
+use futures_util::stream::TryStreamExt;
 use macaddr::MacAddr;
 use rtnetlink::{
     new_connection, packet_route::link::MacVlanMode, Error, Handle, LinkMacVlan,

examples/create_macvtap.rs

@@ -2,7 +2,7 @@
 
 use std::env;
 
-use futures::stream::TryStreamExt;
+use futures_util::stream::TryStreamExt;
 use rtnetlink::{
     new_connection, packet_route::link::MacVtapMode, Error, Handle, LinkMacVtap,
 };

examples/create_netkit.rs

@@ -0,0 +1,17 @@
+// SPDX-License-Identifier: MIT
+
+use rtnetlink::{new_connection, packet_route::link::NetkitMode, LinkNetkit};
+
+#[tokio::main]
+async fn main() -> Result<(), String> {
+    let (connection, handle, _) = new_connection().unwrap();
+    tokio::spawn(connection);
+
+    // Create a netkit pair in L3 mode
+    handle
+        .link()
+        .add(LinkNetkit::new("netkit0", "netkit0-peer", NetkitMode::L3).build())
+        .execute()
+        .await
+        .map_err(|e| format!("{e}"))
+}

examples/create_netkit_advanced.rs

@@ -0,0 +1,41 @@
+// SPDX-License-Identifier: MIT
+
+use rtnetlink::{
+    new_connection,
+    packet_route::link::{NetkitMode, NetkitPolicy, NetkitScrub},
+    LinkNetkit,
+};
+
+#[tokio::main]
+async fn main() -> Result<(), String> {
+    let (connection, handle, _) = new_connection().unwrap();
+    tokio::spawn(connection);
+
+    // Create a fully-configured netkit pair in L3 mode
+    // This example shows all available configuration options
+    handle
+        .link()
+        .add(
+            LinkNetkit::new("netkit0", "netkit0-peer", NetkitMode::L3)
+                .policy(NetkitPolicy::Pass) // Forward packets normally on primary
+                .peer_policy(NetkitPolicy::Pass) // Forward packets normally on peer
+                .scrub(NetkitScrub::Default) // Apply default packet scrubbing
+                .peer_scrub(NetkitScrub::Default) // Apply scrubbing on peer
+                .headroom(256) // Reserve 256 bytes of headroom
+                .tailroom(128) // Reserve 128 bytes of tailroom
+                .up() // Bring the interface up
+                .build(),
+        )
+        .execute()
+        .await
+        .map_err(|e| format!("{e}"))?;
+
+    println!("Created netkit pair: netkit0 <-> netkit0-peer");
+    println!("  Mode: L3 (IP mode)");
+    println!("  Policy: Pass (Forward)");
+    println!("  Scrub: Default");
+    println!("  Headroom: 256 bytes");
+    println!("  Tailroom: 128 bytes");
+
+    Ok(())
+}

examples/create_vxlan.rs

@@ -2,7 +2,7 @@
 
 use std::env;
 
-use futures::stream::TryStreamExt;
+use futures_util::stream::TryStreamExt;
 use rtnetlink::{new_connection, Error, Handle, LinkVxlan};
 
 #[tokio::main]